extract replaceWhenOrThenSelectFieldTabName method

Author: todd5167

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

@@ -78,12 +78,12 @@ public static void parseJoinCompareOperate(SqlNode condition, List<String> sqlJo
                 parseJoinCompareOperate(sqlNode, sqlJoinCompareOperate);
             }
         } else {
-            String operator = parseOperator(joinCondition.getKind());
+            String operator = transformNotEqualsOperator(joinCondition.getKind());
             sqlJoinCompareOperate.add(operator);
         }
     }
 
-    public static String parseOperator(SqlKind sqlKind) {
+    public static String transformNotEqualsOperator(SqlKind sqlKind) {
         if (StringUtils.equalsIgnoreCase(sqlKind.toString(), "NOT_EQUALS")){
             return "!=";
         }
@@ -188,21 +188,8 @@ public static SqlNode replaceSelectFieldTabName(SqlNode selectNode, Map<String,S
             SqlNodeList thenOperands = sqlCase.getThenOperands();
             SqlNode elseNode = sqlCase.getElseOperand();
 
-            for(int i=0; i<whenOperands.size(); i++){
-                SqlNode oneOperand = whenOperands.get(i);
-                SqlNode replaceNode = replaceSelectFieldTabName(oneOperand, mapTab);
-                if (replaceNode != null) {
-                    whenOperands.set(i, replaceNode);
-                }
-            }
-
-            for(int i=0; i<thenOperands.size(); i++){
-                SqlNode oneOperand = thenOperands.get(i);
-                SqlNode replaceNode = replaceSelectFieldTabName(oneOperand, mapTab);
-                if (replaceNode != null) {
-                    thenOperands.set(i, replaceNode);
-                }
-            }
+            replaceWhenOrThenSelectFieldTabName(mapTab, whenOperands);
+            replaceWhenOrThenSelectFieldTabName(mapTab, thenOperands);
 
             ((SqlCase) selectNode).setOperand(3, replaceSelectFieldTabName(elseNode, mapTab));
             return selectNode;
@@ -214,6 +201,16 @@ public static SqlNode replaceSelectFieldTabName(SqlNode selectNode, Map<String,S
         }
     }
 
+    private static void replaceWhenOrThenSelectFieldTabName(Map<String, String> mapTab, SqlNodeList thenOperands) {
+        for(int i=0; i<thenOperands.size(); i++){
+            SqlNode oneOperand = thenOperands.get(i);
+            SqlNode replaceNode = replaceSelectFieldTabName(oneOperand, mapTab);
+            if (replaceNode != null) {
+                thenOperands.set(i, replaceNode);
+            }
+        }
+    }
+
     public static SqlNode replaceNodeInfo(SqlNode parseNode, Map<String, String> mapTab) {
         if (parseNode.getKind() == IDENTIFIER) {
             SqlIdentifier sqlIdentifier = (SqlIdentifier) parseNode;