Fix errors

alexey-milovidov · alexey-milovidov · commit 9ecbc568903a · 2024-06-17T05:12:45.000+02:00
diff --git a/src/Parsers/Kusto/KQL_ReleaseNote.md b/src/Parsers/Kusto/KQL_ReleaseNote.md
@@ -853,7 +853,7 @@ Please note that the functions listed below only take constant parameters for no
 ## KQL() function
 
  - create table  
-  `CREATE TABLE kql_table4 ENGINE = Memory AS select *, now() as new_column From kql(Customers | project LastName,Age);`  
+  `CREATE TABLE kql_table4 ENGINE = Memory AS select *, now() as new_column From kql($$Customers | project LastName,Age$$);`  
    verify the content of `kql_table`  
     `select * from kql_table`
    
@@ -867,12 +867,12 @@ Please note that the functions listed below only take constant parameters for no
         Age Nullable(UInt8)
     ) ENGINE = Memory;
     ```
-    `INSERT INTO temp select * from kql(Customers|project FirstName,LastName,Age);`  
+    `INSERT INTO temp select * from kql($$Customers|project FirstName,LastName,Age$$);`  
     verify the content of `temp`   
         `select * from temp`
 
- - Select from kql()  
-    `Select * from kql(Customers|project FirstName)`
+ - Select from kql(...)  
+    `Select * from kql($$Customers|project FirstName$$)`
 
 ## KQL operators:
  - Tabular expression statements  
@@ -993,4 +993,3 @@ Please note that the functions listed below only take constant parameters for no
  - dcount()
  - dcountif()
  - bin
- 
diff --git a/src/Parsers/parseQuery.cpp b/src/Parsers/parseQuery.cpp
@@ -295,9 +295,9 @@ ASTPtr tryParseQuery(
       *
       * This shortcut is needed to avoid complex backtracking in case of obviously erroneous queries.
       */
-    if (!ParserKeyword(Keyword::INSERT_INTO).check(token_iterator, expected))
+    IParser::Pos lookahead(token_iterator);
+    if (!ParserKeyword(Keyword::INSERT_INTO).ignore(lookahead))
     {
-        IParser::Pos lookahead(token_iterator);
         while (lookahead->type != TokenType::Semicolon && lookahead->type != TokenType::EndOfStream)
         {
             if (lookahead->isError())
diff --git a/tests/queries/0_stateless/02366_kql_create_table.sql b/tests/queries/0_stateless/02366_kql_create_table.sql
@@ -1,29 +1,29 @@
 DROP TABLE IF EXISTS Customers;
 CREATE TABLE Customers
-(    
+(
     FirstName Nullable(String),
-    LastName String, 
+    LastName String,
     Occupation String,
     Education String,
     Age Nullable(UInt8)
 ) ENGINE = Memory;
 
 INSERT INTO Customers VALUES  ('Theodore','Diaz','Skilled Manual','Bachelors',28),('Stephanie','Cox','Management abcd defg','Bachelors',33),('Peter','Nara','Skilled Manual','Graduate Degree',26),('Latoya','Shen','Professional','Graduate Degree',25),('Apple','','Skilled Manual','Bachelors',28),(NULL,'why','Professional','Partial College',38);
 Select '-- test create table --' ;
-Select * from kql(Customers|project FirstName) limit 1;;
+Select * from kql($$Customers|project FirstName$$) limit 1;;
 DROP TABLE IF EXISTS kql_table1;
-CREATE TABLE kql_table1 ENGINE = Memory AS select *, now() as new_column From kql(Customers | project LastName | filter LastName=='Diaz');
+CREATE TABLE kql_table1 ENGINE = Memory AS select *, now() as new_column From kql($$Customers | project LastName | filter LastName=='Diaz'$$);
 select LastName from kql_table1 limit 1;
 DROP TABLE IF EXISTS kql_table2;
 CREATE TABLE kql_table2
-(    
+(
     FirstName Nullable(String),
-    LastName String, 
+    LastName String,
     Age Nullable(UInt8)
 ) ENGINE = Memory;
-INSERT INTO kql_table2 select * from kql(Customers|project FirstName,LastName,Age | filter FirstName=='Theodore');
+INSERT INTO kql_table2 select * from kql($$Customers|project FirstName,LastName,Age | filter FirstName=='Theodore'$$);
 select * from kql_table2 limit 1;
--- select * from kql(Customers | where FirstName !in ("test", "test2"));
+-- select * from kql($$Customers | where FirstName !in ("test", "test2")$$);
 DROP TABLE IF EXISTS Customers;
 DROP TABLE IF EXISTS kql_table1;
-DROP TABLE IF EXISTS kql_table2;
+DROP TABLE IF EXISTS kql_table2;

Original file line number	Diff line number	Diff line change
`@@ -295,9 +295,9 @@ ASTPtr tryParseQuery(`
`295`	`295`	`*`
`296`	`296`	`* This shortcut is needed to avoid complex backtracking in case of obviously erroneous queries.`
`297`	`297`	`*/`
`298`		`- if (!ParserKeyword(Keyword::INSERT_INTO).check(token_iterator, expected))`
	`298`	`+ IParser::Pos lookahead(token_iterator);`
	`299`	`+ if (!ParserKeyword(Keyword::INSERT_INTO).ignore(lookahead))`
`299`	`300`	`{`
`300`		`- IParser::Pos lookahead(token_iterator);`
`301`	`301`	`while (lookahead->type != TokenType::Semicolon && lookahead->type != TokenType::EndOfStream)`
`302`	`302`	`{`
`303`	`303`	`if (lookahead->isError())`