删除同步

master
chengqf 2 years ago
parent ab7902a4db
commit 8973ef8898

@ -34,7 +34,8 @@ public class DeleteServiceImpl implements DeleteService {
@Override
public boolean syncDelete(Map<String,Object> 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) {

@ -233,6 +233,7 @@ public class IdcServiceImpl implements IdcService {
syncData(syncTables[i], isUpload, syncIp);
}
}
}
}

Loading…
Cancel
Save