diff options
| author | default <default@DESKTOP-7FEGRP2> | 2018-10-16 20:04:19 +0800 |
|---|---|---|
| committer | default <default@DESKTOP-7FEGRP2> | 2018-10-16 20:04:19 +0800 |
| commit | 79ab895191d45c73d3553282a21181be21310f7d (patch) | |
| tree | ba248a4c455a8e279dcad7d25179423af918fe94 /nms_sync | |
| parent | 23f608778db1270774305389dbf426b873279d99 (diff) | |
update
Diffstat (limited to 'nms_sync')
| -rw-r--r-- | nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java index ea64aaf..490e3cb 100644 --- a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java +++ b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java @@ -54,7 +54,7 @@ public class SyncSlaveToMasterThread implements Runnable{ .find("select * from " + record.getStr("table_name") + " where " + record.getStr("id_name") + " > ? order by "+record.getStr("id_name")+" asc limit " + record.getInt("batch_size"), record.getInt("last_id")); - logger.info("分库同步到主库新增数据信息为"+JSON.toJSONString(data)); + //logger.info("分库同步到主库新增数据信息为"+JSON.toJSONString(data)); if (data != null && data.size() > 0) { final Object lastInsertId = data.get(data.size() - 1).get(record.getStr("id_name")); if(record.getInt("mode").equals(2)) { @@ -161,7 +161,7 @@ public class SyncSlaveToMasterThread implements Runnable{ " select * from table_event_log where table_name = '" + record.getStr("table_name") + "' and id > " + record.getInt("last_id") + " and event = " + record.getInt("event") + " order by id asc limit " + record.getInt("batch_size")); - logger.info("分库同步到主库数据的修改或者删除数据信息为"+JSON.toJSONString(datas)); + //logger.info("分库同步到主库数据的修改或者删除数据信息为"+JSON.toJSONString(datas)); if (datas != null && datas.size() > 0) { Db.use(url.toString()).tx(new IAtom() { @Override @@ -186,7 +186,7 @@ public class SyncSlaveToMasterThread implements Runnable{ .find(" select * from " + record.getStr("table_name") + " where " + record.getStr("id_name") + " in (" + handleStr + ") ", updateIds.toArray()); - logger.info("分库修改的数据信息为"+JSON.toJSONString(updateDatas)); + //logger.info("分库修改的数据信息为"+JSON.toJSONString(updateDatas)); if (updateDatas != null && updateDatas.size() > 0) { if(record.getStr("table_name").equals("event_record_library")||record.getStr("table_name").equals("detection_info_new")) { for(Record updateData:updateDatas) { |