Skip to content

Commit 637911e

Browse files
committed
Merge branch '3.6.1_not_in' into '1.5_v3.6.1'
sql关键字解析 See merge request !55
2 parents 9ed953b + f64b24d commit 637911e

File tree

1 file changed

+10
-16
lines changed

1 file changed

+10
-16
lines changed

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

Lines changed: 10 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -365,39 +365,33 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
365365
return sqlIdentifier;
366366
}else if(selectNode.getKind() == LITERAL || selectNode.getKind() == LITERAL_CHAIN){//字面含义
367367
return selectNode;
368-
}else if(selectNode.getKind() == OTHER_FUNCTION
368+
}else if( AGGREGATE.contains(selectNode.getKind())
369+
|| AVG_AGG_FUNCTIONS.contains(selectNode.getKind())
370+
|| COMPARISON.contains(selectNode.getKind())
371+
|| selectNode.getKind() == OTHER_FUNCTION
369372
|| selectNode.getKind() == DIVIDE
370373
|| selectNode.getKind() == CAST
371-
|| selectNode.getKind() == SUM
372-
|| selectNode.getKind() == AVG
373-
|| selectNode.getKind() == MAX
374-
|| selectNode.getKind() == MIN
375374
|| selectNode.getKind() == TRIM
376375
|| selectNode.getKind() == TIMES
377376
|| selectNode.getKind() == PLUS
378-
|| selectNode.getKind() == IN
377+
|| selectNode.getKind() == NOT_IN
379378
|| selectNode.getKind() == OR
380379
|| selectNode.getKind() == AND
381-
|| selectNode.getKind() == COUNT
382-
|| selectNode.getKind() == SUM0
383-
|| selectNode.getKind() == LEAD
384-
|| selectNode.getKind() == LAG
385-
|| selectNode.getKind() == EQUALS
386-
|| selectNode.getKind() == NOT_EQUALS
387380
|| selectNode.getKind() == MINUS
388381
|| selectNode.getKind() == TUMBLE
389382
|| selectNode.getKind() == TUMBLE_START
390383
|| selectNode.getKind() == TUMBLE_END
391384
|| selectNode.getKind() == SESSION
392385
|| selectNode.getKind() == SESSION_START
393386
|| selectNode.getKind() == SESSION_END
387+
|| selectNode.getKind() == HOP
388+
|| selectNode.getKind() == HOP_START
389+
|| selectNode.getKind() == HOP_END
394390
|| selectNode.getKind() == BETWEEN
395391
|| selectNode.getKind() == IS_NULL
396392
|| selectNode.getKind() == IS_NOT_NULL
397-
|| selectNode.getKind() == LESS_THAN
398-
|| selectNode.getKind() == GREATER_THAN
399-
|| selectNode.getKind() == LESS_THAN_OR_EQUAL
400-
|| selectNode.getKind() == GREATER_THAN_OR_EQUAL
393+
|| selectNode.getKind() == CONTAINS
394+
401395
){
402396
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
403397
for(int i=0; i<sqlBasicCall.getOperands().length; i++){

0 commit comments

Comments
 (0)