优化代码

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

@@ -36,24 +36,6 @@ public class MysqlDataTransferFunction extends ProcessFunction<JSONObject, Tuple
         STR_SQL_TYPE.put("JSON",1);
     }
 
-    /*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("`").append(s).append("`,");
-        }
-        List<String> valueList = new ArrayList<>();
-        for (String col : columnSet) {
-            valueList.add(getValueString(dataObj,col,mysqlType.getString(col)));
-        }
-        sb.setLength(sb.length()-1);
-        String columnString = sb.toString();
-        String valueString = String.join(",",valueList);
-
-        //return String.format("INSERT INTO %s (%s) values (%s) ON DUPLICATE KEY UPDATE %s;",table,columnString,valueString,updateString);
-        return String.format("REPLACE INTO %s (%s) values (%s);",table,columnString,valueString);
-    }*/
     private static String tranferInsertSql(String table, JSONObject dataObj, JSONObject mysqlType) {
         Set<String> columnSet = mysqlType.keySet();
         StringBuilder sb = new StringBuilder("REPLACE INTO ").append(table).append(" (");
@@ -70,17 +52,6 @@ public class MysqlDataTransferFunction extends ProcessFunction<JSONObject, Tuple
     }
 
 
-    /*private static String transferDeleteSql(String table, JSONObject dataObj, JSONObject mysqlType, Set<String> pkNameSet) {
-
-        List<String> whereList = new ArrayList<>();
-        for (String pk : pkNameSet) {
-            String whereString = pk.concat(" = ").concat(getValueString(dataObj,pk,mysqlType.getString(pk)));
-            whereList.add(whereString);
-        }
-        String whereString = String.join(" and ",whereList);
-        return String.format("DELETE FROM %s WHERE %s",table,whereString);
-    }*/
-
     private static String transferDeleteSql(String table, JSONObject dataObj, JSONObject mysqlType, Set<String> pkNameSet) {
         StringBuilder whereClauseBuilder = new StringBuilder();
         for (String pk : pkNameSet) {