diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java index 59cc69a..77d053f 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java @@ -69,7 +69,6 @@ public class MysqlDataInterceptor implements Interceptor { if ("update".equals(sqlCommandType.toLowerCase()) || "delete".equals(sqlCommandType.toLowerCase())) { sql = getSql(configuration, boundSql, sqlId); - System.out.println("sql = "+sql); if (isSyncTable(sql)) { @@ -98,8 +97,8 @@ public class MysqlDataInterceptor implements Interceptor { List list = (ArrayList)returnValue; if (CollectionUtils.isNotEmpty(list)) { - sql = sql.replaceFirst("\\(","(ID,"); - sql = sql.substring(0,sql.lastIndexOf("(")+1)+list.get(0)+","+sql.substring(sql.lastIndexOf("(")+1,sql.length()); +// sql = sql.replaceFirst("\\(","(ID,"); +// sql = sql.substring(0,sql.lastIndexOf("(")+1)+list.get(0)+","+sql.substring(sql.lastIndexOf("(")+1,sql.length()); System.out.println("============add sync sql = " + sql); //发送要同步的sql sql = null;