gfwleak/nms-nmssync
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
default
2018-10-17 17:06:01 +08:00
parent 589f49d620
commit 147d8ca8d4
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java
View File

@@ -192,7 +192,7 @@ public class SyncSlaveToMasterThread implements Runnable{
for(Record updateData:updateDatas) { for(Record updateData:updateDatas) {
updateData.set("old_id",updateData.getLong(record.getStr("id_name"))); updateData.set("old_id",updateData.getLong(record.getStr("id_name")));
updateData.set("db_id", syncDbInfo.get("id")); updateData.set("db_id", syncDbInfo.get("id"));
updateData.remove("id"); updateData.remove(record.getStr("id_name"));
updateData.remove("sync_status"); updateData.remove("sync_status");
} }
Db.use("masterDataSource").batchUpdate(record.getStr("table_name"), "old_id,db_id",updateDatas, record.getInt("batch_size")); Db.use("masterDataSource").batchUpdate(record.getStr("table_name"), "old_id,db_id",updateDatas, record.getInt("batch_size"));

2
nms_sync/src/com/nms/thread/SyncThread.java
View File

@@ -189,7 +189,7 @@ public class SyncThread implements Runnable {
for(Record updateData:updateDatas) { for(Record updateData:updateDatas) {
updateData.set("old_id",updateData.getLong(record.getStr("id_name"))); updateData.set("old_id",updateData.getLong(record.getStr("id_name")));
updateData.set("db_id", -1); updateData.set("db_id", -1);
updateData.remove("id"); updateData.remove(record.getStr("id_name"));
updateData.remove("sync_status"); updateData.remove("sync_status");
} }
Db.use(url.toString()).batchUpdate(record.getStr("table_name"), "old_id,db_id",updateDatas, record.getInt("batch_size")); Db.use(url.toString()).batchUpdate(record.getStr("table_name"), "old_id,db_id",updateDatas, record.getInt("batch_size"));