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