JSON类型做字符串处理

src/main/java/com/dsk/flink/dsc/common/function/AsyncMysqlDataTransferFunction.java

@@ -106,16 +106,29 @@ public class AsyncMysqlDataTransferFunction extends RichAsyncFunction<JSONObject
 
     private static final String[] STR_SQL_TYPE = new String[]{"VARCHAR","CHAR","TINYBLOB","BLOB","MEDIUMBLOB","LONGBLOB","TINYTEXT","TEXT","MEDIUMTEXT","LONGTEXT","TIME","TIMESTAMP","JSON","json"};
 
+    private static final String[] KEYWORD = new String[]{"limit"};
     private static String tranferInsertSql(String table, JSONObject dataObj, JSONObject mysqlType) {
 
         Set<String> columnSet = mysqlType.keySet();
+        StringBuilder sb = new StringBuilder();
+        for (String s : columnSet) {
+            sb.append("`"+s+"`").append(",");
+        }
         List<String> valueList = new ArrayList<>();
         List<String> updateList = new ArrayList<>();
         for (String col : columnSet) {
-            valueList.add(getValueString(dataObj,col,mysqlType.getString(col)));
-            updateList.add(col.concat(" = VALUES(").concat(col).concat(")"));
+            String formatCol = "`"+col+"`";
+            if(Arrays.asList(KEYWORD).contains(col)){
+                valueList.add(getValueString(dataObj,col,mysqlType.getString(col)));
+                updateList.add(formatCol.concat(" = VALUES(").concat(formatCol).concat(")"));
+            }else {
+                valueList.add(getValueString(dataObj,col,mysqlType.getString(col)));
+                updateList.add(col.concat(" = VALUES(").concat(col).concat(")"));
+            }
         }
-        String columnString = String.join(",",columnSet);
+        //String columnString = String.join(",",columnSet);
+        sb.setLength(sb.length()-1);
+        String columnString = sb.toString();
         String valueString = String.join(",",valueList);
         String updateString = String.join(",",updateList);
 
@@ -167,7 +180,7 @@ public class AsyncMysqlDataTransferFunction extends RichAsyncFunction<JSONObject
 
         //需要处理成字符串加引号的类型
         if(Arrays.asList(STR_SQL_TYPE).contains(mysqlType.toUpperCase())){
-            return String.format("'%s'", dataObj.getString(columnKey).replaceAll("'","\\\\'") );
+            return String.format("'%s'", dataObj.getString(columnKey).replace("\\","\\\\").replace("'", "\\'") );
         }
 
         //时间字段处理
@@ -213,6 +226,23 @@ public class AsyncMysqlDataTransferFunction extends RichAsyncFunction<JSONObject
         System.out.println(tranferInsertSql(table,jsonObject,mysqlType));
 
         System.out.println(s2.replaceAll("'","\\\\'"));
+
+        String[] ss = new String[]{"1","2","3" };
+        StringBuilder sb = new StringBuilder();
+        for (String s3 : ss)
+            {
+                sb.append("`"+s3+"?").append(",");
+        }
+        for (String s3 : ss) {
+            System.out.println(s3);
+        }
+        sb.setLength(sb.length()-1);
+        System.out.println(sb.toString());
+
+        String s5 = "交货地址：安徽霍邱供应站及指定地点\\\",\\\"bjsm\\\":null,\\\"jhType\\\":null,\\";
+        System.out.println(s5);
+        System.out.println(s5.replace("\\","\\\\").replace("'", "\\'"));
     }
 
+
 }