diff options
| -rw-r--r-- | nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java | 3 | ||||
| -rw-r--r-- | nms_sync/src/com/nms/thread/SyncThread.java | 1 |
2 files changed, 1 insertions, 3 deletions
diff --git a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java index f9aab30..04dadbc 100644 --- a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java +++ b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java @@ -65,14 +65,11 @@ public class SyncSlaveToMasterThread implements Runnable{ //logger.info("分库同步到主库新增数据信息为"+JSON.toJSONString(data)); if (data != null && data.size() > 0) { final Object lastInsertId = data.get(data.size() - 1).get(record.getStr("id_name")); - StringBuffer ssss=new StringBuffer(); if(record.getInt("mode").equals(2)) { for(Record entity:data) { - ssss.append(entity.get("ID")+","); entity.remove(record.getStr("id_name")); } } - System.out.println(ssss.toString()); // 针对监测结果表的id值 自动生成处理 if("detection_info_new".equals(record.getStr("table_name"))) { Db.use(url.toString()).tx(new IAtom() { diff --git a/nms_sync/src/com/nms/thread/SyncThread.java b/nms_sync/src/com/nms/thread/SyncThread.java index 7767931..689a0a1 100644 --- a/nms_sync/src/com/nms/thread/SyncThread.java +++ b/nms_sync/src/com/nms/thread/SyncThread.java @@ -47,6 +47,7 @@ public class SyncThread implements Runnable { //logger.info("查询主库须向分库同步数据信息"+JSON.toJSONString(find)); if (find != null && find.size() > 0) { for (final Record record : find) { + logger.info("主库数据同步到分库 正在操作的表名为："+ record.getStr("table_name")); //如果设定指定字段 则只操作指定字段数据 无则操作全部 final StringBuffer columns=new StringBuffer(); columns.append("*"); |