diff --git a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java index 3532e32..f0be702 100644 --- a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java +++ b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java @@ -192,7 +192,7 @@ public class SyncSlaveToMasterThread implements Runnable{ for(Record updateData:updateDatas) { updateData.set("old_id",updateData.getLong(record.getStr("id_name"))); updateData.set("db_id", syncDbInfo.get("id")); - updateData.remove("id"); + updateData.remove(record.getStr("id_name")); updateData.remove("sync_status"); } Db.use("masterDataSource").batchUpdate(record.getStr("table_name"), "old_id,db_id",updateDatas, record.getInt("batch_size")); diff --git a/nms_sync/src/com/nms/thread/SyncThread.java b/nms_sync/src/com/nms/thread/SyncThread.java index ac496e0..2014ce5 100644 --- a/nms_sync/src/com/nms/thread/SyncThread.java +++ b/nms_sync/src/com/nms/thread/SyncThread.java @@ -189,7 +189,7 @@ public class SyncThread implements Runnable { for(Record updateData:updateDatas) { updateData.set("old_id",updateData.getLong(record.getStr("id_name"))); updateData.set("db_id", -1); - updateData.remove("id"); + updateData.remove(record.getStr("id_name")); updateData.remove("sync_status"); } Db.use(url.toString()).batchUpdate(record.getStr("table_name"), "old_id,db_id",updateDatas, record.getInt("batch_size"));