[flinksql][sql解析失败][19739]

Author: simenliuxing

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

@@ -59,33 +59,40 @@ public static List<String> splitIgnoreQuota(String str, char delimiter){
         boolean inSingleQuotes = false;
         int bracketLeftNum = 0;
         StringBuilder b = new StringBuilder();
-        for (char c : str.toCharArray()) {
-            if(c == delimiter){
+        char[] chars = str.toCharArray();
+        int idx = 0;
+        for (char c : chars) {
+            char flag = 0;
+            if (idx > 0) {
+                flag = chars[idx - 1];
+            }
+            if (c == delimiter) {
                 if (inQuotes) {
                     b.append(c);
-                } else if(inSingleQuotes){
+                } else if (inSingleQuotes) {
                     b.append(c);
-                } else if(bracketLeftNum > 0){
+                } else if (bracketLeftNum > 0) {
                     b.append(c);
-                }else {
+                } else {
                     tokensList.add(b.toString());
                     b = new StringBuilder();
                 }
-            }else if(c == '\"'){
+            } else if (c == '\"' && '\\' != flag && !inSingleQuotes) {
                 inQuotes = !inQuotes;
                 b.append(c);
-            }else if(c == '\''){
+            } else if (c == '\'' && '\\' != flag && !inQuotes) {
                 inSingleQuotes = !inSingleQuotes;
                 b.append(c);
-            }else if(c == '('){
+            } else if (c == '(' && !inSingleQuotes && !inQuotes) {
                 bracketLeftNum++;
                 b.append(c);
-            }else if(c == ')'){
+            } else if (c == ')' && !inSingleQuotes && !inQuotes) {
                 bracketLeftNum--;
                 b.append(c);
-            }else{
+            } else {
                 b.append(c);
             }
+            idx++;
         }
 
         tokensList.add(b.toString());