数据删除同步

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<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;
@@ -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) {