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 afdf38ecc..9b9a26807 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 @@ -15,7 +15,6 @@ import com.glxp.api.idc.service.DeleteService; import com.glxp.api.util.CustomUtil; -/*连通检测*/ @Service public class DeleteServiceImpl implements DeleteService { private static final Logger logger = LoggerFactory.getLogger(DeleteServiceImpl.class); @@ -35,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; @@ -43,7 +43,13 @@ 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) { + + } + try { + jdbcTemplate.execute("create index i_idc_delete_table_name on idc_delete (tableName asc)"); } catch (Exception e) {