Skip to content

Commit de1176d

Browse files
author
yanxi0227
committed
Merge branch '1.5_v3.5.6' into v1.5.0_dev
2 parents 62ee4f9 + bfd2fa7 commit de1176d

File tree

3 files changed

+5
-11
lines changed

3 files changed

+5
-11
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -394,6 +394,10 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
394394
|| selectNode.getKind() == BETWEEN
395395
|| selectNode.getKind() == IS_NULL
396396
|| 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
397401
){
398402
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
399403
for(int i=0; i<sqlBasicCall.getOperands().length; i++){

core/src/main/java/com/dtstack/flink/sql/table/AbsTableParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ public boolean dealKeyPattern(String fieldRow, TableInfo tableInfo){
7979

8080
public void parseFieldsInfo(String fieldsInfo, TableInfo tableInfo){
8181

82-
String[] fieldRows = DtStringUtil.splitIgnoreQuotaBrackets(fieldsInfo, ",");
82+
List<String> fieldRows = DtStringUtil.splitIgnoreQuota(fieldsInfo, ',');
8383
for(String fieldRow : fieldRows){
8484
fieldRow = fieldRow.trim();
8585
boolean isMatcherKey = dealKeyPattern(fieldRow, tableInfo);

core/src/main/java/com/dtstack/flink/sql/util/DtStringUtil.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -84,16 +84,6 @@ public static List<String> splitIgnoreQuota(String str, char delimiter){
8484
return tokensList;
8585
}
8686

87-
/***
88-
* Split the specified string delimiter --- ignored in brackets and quotation marks delimiter
89-
* @param str
90-
* @param delimter
91-
* @return
92-
*/
93-
public static String[] splitIgnoreQuotaBrackets(String str, String delimter){
94-
String splitPatternStr = delimter + "(?![^()]*+\\))(?![^{}]*+})(?![^\\[\\]]*+\\])(?=(?:[^\"]|\"[^\"]*\")*$)";
95-
return str.split(splitPatternStr);
96-
}
9787

9888
public static String replaceIgnoreQuota(String str, String oriStr, String replaceStr){
9989
String splitPatternStr = oriStr + "(?=(?:[^\"]*\"[^\"]*\")*[^\"]*$)(?=(?:[^']*'[^']*')*[^']*$)";

0 commit comments

Comments
 (0)