fix(flink): some grammar rules (#465)

* fix: #464 order by + expression

* fix: #464 EXTRACT function

* test: #464 flink JSON_VALUE RETURNING

Author: liuxy0551

src/grammar/flink/FlinkSqlLexer.g4

@@ -171,6 +171,7 @@ KW_FILTER              : 'FILTER';
 KW_FIRST_VALUE         : 'FIRST_VALUE';
 KW_FLOAT               : 'FLOAT';
 KW_FLOOR               : 'FLOOR';
+KW_FOLLOWING           : 'FOLLOWING';
 KW_FOR                 : 'FOR';
 KW_FOREIGN             : 'FOREIGN';
 KW_FRAME_ROW           : 'FRAME_ROW';
@@ -428,6 +429,7 @@ KW_TRUNCATE            : 'TRUNCATE';
 KW_TRY_CAST            : 'TRY_CAST';
 KW_TUESDAY             : 'TUESDAY';
 KW_UESCAPE             : 'UESCAPE';
+KW_UNBOUNDED           : 'UNBOUNDED';
 KW_UNION               : 'UNION';
 KW_UNIQUE              : 'UNIQUE';
 KW_UNKNOWN             : 'UNKNOWN';

src/grammar/flink/FlinkSqlParser.g4

@@ -649,7 +649,9 @@ orderByClause
     ;
 
 orderItemDefinition
-    : columnName ordering=(KW_ASC | KW_DESC)? (KW_NULLS nullOrder=(KW_LAST | KW_FIRST))?
+    : (columnName | valueExpression) ordering=(KW_ASC | KW_DESC)? (
+        KW_NULLS nullOrder=(KW_LAST | KW_FIRST)
+    )?
     ;
 
 limitClause
@@ -699,13 +701,26 @@ patternVariablesDefinition
 
 windowFrame
     : KW_RANGE KW_BETWEEN timeIntervalExpression frameBound
+    | (KW_ROWS | KW_RANGE) KW_BETWEEN frameStart KW_AND frameEnd
     | KW_ROWS KW_BETWEEN DIG_LITERAL frameBound
     ;
 
 frameBound
     : KW_PRECEDING KW_AND KW_CURRENT KW_ROW
     ;
 
+frameStart
+    : KW_UNBOUNDED KW_PRECEDING
+    | DIG_LITERAL KW_PRECEDING
+    | KW_CURRENT KW_ROW
+    ;
+
+frameEnd
+    : KW_CURRENT KW_ROW
+    | DIG_LITERAL KW_FOLLOWING
+    | KW_UNBOUNDED KW_FOLLOWING
+    ;
+
 withinClause
     : KW_WITHIN timeIntervalExpression
     ;
@@ -788,11 +803,11 @@ primaryExpression
     | functionCallExpression               # functionCall
     // | identifier '->' expression                                                               #lambda
     // | '(' identifier (',' identifier)+ ')' '->' expression                                     #lambda
-    | value=primaryExpression LS_BRACKET index=valueExpression RS_BRACKET # subscript
-    | columnNamePath                                                      # columnReference
-    | dereferenceDefinition                                               # dereference
-    | LR_BRACKET expression RR_BRACKET                                    # parenthesizedExpression
-    // | EXTRACT LR_BRACKET field=identifier KW_FROM source=valueExpression RR_BRACKET                             #extract
+    | value=primaryExpression LS_BRACKET index=valueExpression RS_BRACKET              # subscript
+    | columnNamePath                                                                   # columnReference
+    | dereferenceDefinition                                                            # dereference
+    | LR_BRACKET expression RR_BRACKET                                                 # parenthesizedExpression
+    | KW_EXTRACT LR_BRACKET field=identifier KW_FROM source=valueExpression RR_BRACKET # extract
     // | (SUBSTR | SUBSTRING) LR_BRACKET str=valueExpression (KW_FROM | COMMA) pos=valueExpression
     //   ((KW_FOR | COMMA) len=valueExpression)? RR_BRACKET                                                   #substring
     // | TRIM LR_BRACKET trimOption=(BOTH | LEADING | TRAILING)? (trimStr=valueExpression)?