修复case when 中没有解析else字段

Author: dapeng

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

@@ -233,7 +233,6 @@ public Set<String> extractField(SqlNode sqlNode,
         Set<String> fieldFromJoinCondition = extractSelectFieldFromJoinCondition(joinFieldSet, fromTableNameSet, tableRef);
 
         Set<String> extractGroupByField = extractFieldFromGroupByList(parentGroupByList, fromTableNameSet, tableRef);
-
         extractSelectField.addAll(extractCondition);
         extractSelectField.addAll(fieldFromJoinCondition);
         extractSelectField.addAll(extractGroupByField);
@@ -575,6 +574,7 @@ private void extractSelectField(SqlNode selectNode,
                 || selectNode.getKind() == TIMESTAMP_ADD
                 || selectNode.getKind() == TIMESTAMP_DIFF
                 || selectNode.getKind() == LIKE
+                || selectNode.getKind() == COALESCE
 
         ){
             SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;

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

@@ -160,6 +160,10 @@ private static SqlNode replaceNodeInfo(SqlNode groupNode,
                 SqlNode replaceNode = replaceSelectFieldName(sqlNode, oldTbName, newTbName, mappingField);
                 sqlCase.getThenOperands().set(i,replaceNode);
             }
+            if(sqlCase.getElseOperand() != null){
+                SqlNode replaceNode = replaceSelectFieldName(sqlCase.getElseOperand(), oldTbName, newTbName, mappingField);
+                sqlCase.setOperand(3, replaceNode);
+            }
             return sqlCase;
         } else {
             return groupNode;

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

@@ -151,6 +151,7 @@ public static void extractSelectFieldToFieldInfo(SqlNode fieldNode, String fromN
                 || fieldNode.getKind() == TIMESTAMP_ADD
                 || fieldNode.getKind() == TIMESTAMP_DIFF
                 || fieldNode.getKind() == LIKE
+                || fieldNode.getKind() == COALESCE
                 ) {
             SqlBasicCall sqlBasicCall = (SqlBasicCall) fieldNode;
             for (int i = 0; i < sqlBasicCall.getOperands().length; i++) {
@@ -363,6 +364,7 @@ public static void replaceSelectFieldTable(SqlNode selectNode,
                 || selectNode.getKind() == TIMESTAMP_ADD
                 || selectNode.getKind() == TIMESTAMP_DIFF
                 || selectNode.getKind() == LIKE
+                || selectNode.getKind() == COALESCE
 
         ){
             SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
@@ -548,6 +550,7 @@ private static void replaceConditionNode(SqlNode selectNode, String oldTbName, S
                 || selectNode.getKind() == TIMESTAMP_ADD
                 || selectNode.getKind() == TIMESTAMP_DIFF
                 || selectNode.getKind() == LIKE
+                || selectNode.getKind() == COALESCE
 
         ){
             SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
@@ -573,6 +576,7 @@ private static void replaceConditionNode(SqlNode selectNode, String oldTbName, S
 
             sqlCase.getWhenOperands().getList().forEach(sqlNode -> replaceConditionNode(sqlNode, oldTbName, newTbName, fieldReplaceRef));
             sqlCase.getThenOperands().getList().forEach(sqlNode -> replaceConditionNode(sqlNode, oldTbName, newTbName, fieldReplaceRef));
+            replaceConditionNode(sqlCase.getElseOperand(), oldTbName, newTbName, fieldReplaceRef);
         } else {
             throw new RuntimeException(String.format("not support node kind of %s to replace name now.", selectNode.getKind()));
         }
@@ -620,6 +624,7 @@ public static void getConditionRefTable(SqlNode selectNode, Set<String> fieldInf
                 || selectNode.getKind() == TIMESTAMP_ADD
                 || selectNode.getKind() == TIMESTAMP_DIFF
                 || selectNode.getKind() == LIKE
+                || selectNode.getKind() == COALESCE
 
                 ) {
             SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
@@ -645,6 +650,7 @@ public static void getConditionRefTable(SqlNode selectNode, Set<String> fieldInf
 
             sqlCase.getWhenOperands().getList().forEach(sqlNode -> getConditionRefTable(sqlNode, fieldInfos));
             sqlCase.getThenOperands().getList().forEach(sqlNode -> getConditionRefTable(sqlNode, fieldInfos));
+            getConditionRefTable(sqlCase.getElseOperand(), fieldInfos);
         } else {
             throw new RuntimeException(String.format("not support node kind of %s to replace name now.", selectNode.getKind()));
         }