JSON类型做字符串处理

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

@@ -104,7 +104,7 @@ 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"};
+    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 String tranferInsertSql(String table, JSONObject dataObj, JSONObject mysqlType) {