From 8973ef8898685b69288113a4796b95c514dba49a Mon Sep 17 00:00:00 2001 From: chengqf <584883665@139.com> Date: Sat, 15 Apr 2023 12:24:45 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/glxp/api/idc/service/impl/DeleteServiceImpl.java | 5 +++-- .../java/com/glxp/api/idc/service/impl/IdcServiceImpl.java | 1 + 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java b/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java index a5577ebb..a3d88249 100644 --- a/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java +++ b/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java @@ -34,7 +34,8 @@ public class DeleteServiceImpl implements DeleteService { @Override public boolean syncDelete(Map params) { createTable(); - String sql = "insert into idc_delete (id,tableName,uniqueColumn,uniqueValue,updateTime) values ('"+CustomUtil.getId()+"','"+params.get("tableName")+"','"+params.get("uniqueColumn")+"','"+params.get("uniqueValue")+"',now())"; + String sql = "insert into idc_delete (id,tableName,uniqueColumn,updateTime,uniqueValue) values ('"+CustomUtil.getId()+"','"+params.get("tableName")+"','"+params.get("uniqueColumn")+"',now(),'"+params.get("uniqueValue")+"')"; + if(dbDao.save(sql)>0) return true; return false; @@ -42,7 +43,7 @@ public class DeleteServiceImpl implements DeleteService { private void createTable() { try { - jdbcTemplate.execute("create table idc_delete (id varchar(36),tableName varchar(100),uniqueColumn varchar(60),uniqueValue varchar(200),updateTime datetime,PRIMARY KEY (id))"); + jdbcTemplate.execute("create table idc_delete (id varchar(36),tableName varchar(100),uniqueColumn varchar(60),uniqueValue varchar(600),updateTime datetime,PRIMARY KEY (id))"); } catch (Exception e) { diff --git a/src/main/java/com/glxp/api/idc/service/impl/IdcServiceImpl.java b/src/main/java/com/glxp/api/idc/service/impl/IdcServiceImpl.java index 3e7d86fb..06a1eadf 100644 --- a/src/main/java/com/glxp/api/idc/service/impl/IdcServiceImpl.java +++ b/src/main/java/com/glxp/api/idc/service/impl/IdcServiceImpl.java @@ -233,6 +233,7 @@ public class IdcServiceImpl implements IdcService { syncData(syncTables[i], isUpload, syncIp); } } + } }