feat(flink): add drop/alter test add add part of queryStatement

Author: Erindcl

src/grammar/flinksql/FlinkSqlLexer.g4

@@ -332,6 +332,7 @@ SINGLE_QUOTE_SYMB:                   '\'';
 DOUBLE_QUOTE_SYMB:                   '"';
 REVERSE_QUOTE_SYMB:                  '`';
 COLON_SYMB:                          ':';
+ASTERISK_SIGN:                       '*';
 
 
 fragment ID_LITERAL:                 [A-Z_0-9a-z]*?[A-Z_a-z]+?[A-Z_0-9a-z]*;

src/grammar/flinksql/FlinkSqlParser.g4

@@ -1,4 +1,4 @@
-parser grammar FlinkSqlParser;
+grammar FlinkSqlParser;
 
 options { tokenVocab=FlinkSqlLexer; }
 
@@ -27,7 +27,7 @@ ddlStatement
     ;
 
 dmlStatement
-    : selectStatement | insertStatement
+    : queryStatement | insertStatement
     ;
 
 
@@ -110,25 +110,74 @@ alterFunction
 // Drop statements
 
 dropTable
-    : DROP TABLE ifExists uid
+    : DROP TABLE ifExists? uid
     ;
 
 dropDatabase
-    : DROP DATABASE ifExists uid dropType=(RESTRICT | CASCADE)?
+    : DROP DATABASE ifExists? uid dropType=(RESTRICT | CASCADE)?
     ;
 
 dropView
-    : DROP TEMPORARY? VIEW ifExists uid
+    : DROP TEMPORARY? VIEW ifExists? uid
     ;
 
 dropFunction
-    : DROP (TEMPORARY|TEMPORARY SYSTEM)? FUNCTION ifExists uid
+    : DROP (TEMPORARY|TEMPORARY SYSTEM)? FUNCTION ifExists? uid
     ;
 
 
 // Select statements
 
+queryStatement
+    : valuesDefinition
+    | (
+        selectStatement
+        | selectWithoutFromDefinition
+        // | queryStatement UNION ALL? queryStatement
+        // | queryStatement EXCEPT queryStatement
+        // | queryStatement INTERSECT queryStatement
+    ) queryOrderByDefinition? queryLimitDefinition? queryOffsetDefinition? queryFetchDefinition?
+    ;
+
 selectStatement
+    : SELECT (ALL | DISTINCT)? 
+    (ASTERISK_SIGN | projectItemDefinition (COMMA projectItemDefinition)*)
+    FROM tableExpression
+    ;
+
+projectItemDefinition // expression (AS? columnAlias)? | tableAlias . *
+    :
+    ;
+
+tableExpression
+    :
+    ;
+
+selectWithoutFromDefinition
+    : 
+    ;
+
+queryOrderByDefinition
+    : ORDER BY orderItemDefition (COMMA orderItemDefition)*
+    ;
+
+orderItemDefition // expression (ASC | DESC)?
+    : 
+    ;
+
+queryLimitDefinition
+    : LIMIT (countDefinition | ALL)
+    ;
+
+countDefinition
+    :
+    ;
+
+queryOffsetDefinition // OFFSET start (ROW | ROWS)
+    :
+    ;
+
+queryFetchDefinition // FETCH (FIRST | NEXT) countDefinition? (ROW | ROWS) ONLY
     :
     ;
 
@@ -153,7 +202,7 @@ valuesDefinition
     : VALUES valuesRowDefinition (COMMA valuesRowDefinition)*
     ;
 
-// TODO 匹配所有的值 任意value
+// TODO 匹配所有的值 任意value 即：(val1 [, val2, ...])
 valuesRowDefinition
     : LR_BRACKET
         .*?

src/lib/flinksql/FlinkSqlParser.interp

@@ -1,3 +1,4 @@
+T__0=1
 SPACE=1
 SPEC_MYSQL_COMMENT=2
 COMMENT_INPUT=3
@@ -303,6 +304,7 @@ SINGLE_QUOTE_SYMB=302
 DOUBLE_QUOTE_SYMB=303
 REVERSE_QUOTE_SYMB=304
 COLON_SYMB=305
+','=1
 'SELECT'=5
 'FROM'=6
 'ADD'=7
@@ -590,7 +592,6 @@ COLON_SYMB=305
 '.'=293
 '('=294
 ')'=295
-','=296
 ';'=297
 '@'=298
 '0'=299

src/lib/flinksql/FlinkSqlParser.tokens

@@ -0,0 +1,20 @@
+token literal names:
+null
+','
+
+token symbolic names:
+null
+null
+
+rule names:
+T__0
+
+channel names:
+DEFAULT_TOKEN_CHANNEL
+HIDDEN
+
+mode names:
+DEFAULT_MODE
+
+atn:
+[3, 24715, 42794, 33075, 47597, 16764, 15335, 30598, 22884, 2, 3, 7, 8, 1, 4, 2, 9, 2, 3, 2, 3, 2, 2, 2, 3, 3, 3, 3, 2, 2, 2, 6, 2, 3, 3, 2, 2, 2, 3, 5, 3, 2, 2, 2, 5, 6, 7, 46, 2, 2, 6, 4, 3, 2, 2, 2, 3, 2, 2]

src/lib/flinksql/FlinkSqlParserLexer.interp

@@ -0,0 +1,51 @@
+// Generated from /Users/erindeng/Desktop/dt-sql-parser/src/grammar/flinksql/FlinkSqlParser.g4 by ANTLR 4.8
+// jshint ignore: start
+var antlr4 = require('antlr4/index');
+
+
+
+var serializedATN = ["\u0003\u608b\ua72a\u8133\ub9ed\u417c\u3be7\u7786\u5964",
+    "\u0002\u0003\u0007\b\u0001\u0004\u0002\t\u0002\u0003\u0002\u0003\u0002",
+    "\u0002\u0002\u0003\u0003\u0003\u0003\u0002\u0002\u0002\u0006\u0002\u0003",
+    "\u0003\u0002\u0002\u0002\u0003\u0005\u0003\u0002\u0002\u0002\u0005\u0006",
+    "\u0007.\u0002\u0002\u0006\u0004\u0003\u0002\u0002\u0002\u0003\u0002",
+    "\u0002"].join("");
+
+
+var atn = new antlr4.atn.ATNDeserializer().deserialize(serializedATN);
+
+var decisionsToDFA = atn.decisionToState.map( function(ds, index) { return new antlr4.dfa.DFA(ds, index); });
+
+function FlinkSqlParserLexer(input) {
+	antlr4.Lexer.call(this, input);
+    this._interp = new antlr4.atn.LexerATNSimulator(this, atn, decisionsToDFA, new antlr4.PredictionContextCache());
+    return this;
+}
+
+FlinkSqlParserLexer.prototype = Object.create(antlr4.Lexer.prototype);
+FlinkSqlParserLexer.prototype.constructor = FlinkSqlParserLexer;
+
+Object.defineProperty(FlinkSqlParserLexer.prototype, "atn", {
+        get : function() {
+                return atn;
+        }
+});
+
+FlinkSqlParserLexer.EOF = antlr4.Token.EOF;
+FlinkSqlParserLexer.T__0 = 1;
+
+FlinkSqlParserLexer.prototype.channelNames = [ "DEFAULT_TOKEN_CHANNEL", "HIDDEN" ];
+
+FlinkSqlParserLexer.prototype.modeNames = [ "DEFAULT_MODE" ];
+
+FlinkSqlParserLexer.prototype.literalNames = [ null, "','" ];
+
+FlinkSqlParserLexer.prototype.symbolicNames = [  ];
+
+FlinkSqlParserLexer.prototype.ruleNames = [ "T__0" ];
+
+FlinkSqlParserLexer.prototype.grammarFileName = "FlinkSqlParser.g4";
+
+
+exports.FlinkSqlParserLexer = FlinkSqlParserLexer;
+

src/lib/flinksql/FlinkSqlParserLexer.js

@@ -0,0 +1,2 @@
+T__0=1
+','=1