Commit 9dfb5d008ece06170006c31a3be3a33da4d019ea

Authored by liquanyu
1 parent c23abccf82

mysql

Showing 1 changed file with 2 additions and 3 deletions

platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java View file @ 9dfb5d0
... ... @@ -69,7 +69,6 @@
69 69 if ("update".equals(sqlCommandType.toLowerCase()) || "delete".equals(sqlCommandType.toLowerCase()))
70 70 {
71 71 sql = getSql(configuration, boundSql, sqlId);
72   - System.out.println("sql = "+sql);
73 72 if (isSyncTable(sql))
74 73 {
75 74  
... ... @@ -98,8 +97,8 @@
98 97 List<Integer> list = (ArrayList)returnValue;
99 98 if (CollectionUtils.isNotEmpty(list))
100 99 {
101   - sql = sql.replaceFirst("\\(","(ID,");
102   - sql = sql.substring(0,sql.lastIndexOf("(")+1)+list.get(0)+","+sql.substring(sql.lastIndexOf("(")+1,sql.length());
  100 +// sql = sql.replaceFirst("\\(","(ID,");
  101 +// sql = sql.substring(0,sql.lastIndexOf("(")+1)+list.get(0)+","+sql.substring(sql.lastIndexOf("(")+1,sql.length());
103 102 System.out.println("============add sync sql = " + sql);
104 103 //发送要同步的sql
105 104 sql = null;