From f8073042d3611c5e52018a6c4c1c723523ba7259 Mon Sep 17 00:00:00 2001 From: default Date: Tue, 13 Nov 2018 15:06:03 +0800 Subject: [PATCH] update --- nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java | 4 ++-- nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java | 3 +++ 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java b/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java index 262a379..e47a404 100644 --- a/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java +++ b/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java @@ -90,8 +90,8 @@ public class SyncDataInterceptor implements Interceptor{ logger.info("check_type_info新增数据创建表结构 参数信息 sql"+sql.toString()); logger.info("check_type_info新增数据创建表结构 参数信息 字段名称"+cIndexFileds.toString()); SyncStoredProcedure syncStoreProcedure=new SyncStoredProcedure("pro_createTable",checkTypeInfo.getStr("TABLE_NAME"), sql.toString(),cIndexFileds.toString()); - Db.use(url).execute(syncStoreProcedure); - logger.info("创建新表操作完成"); + Object execute = Db.use(url).execute(syncStoreProcedure); + logger.info("创建新表操作完成"+execute); //创建完新表结构以后 将同步信息添加到同步表 使新配置的监测数据同步到中心 Record record = new Record(); diff --git a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java index 1812977..124bf4b 100644 --- a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java +++ b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java @@ -34,10 +34,12 @@ public class SyncSlaveToMasterThread implements Runnable{ @Override public void run() { String errorTableName=null; + String errorUrl=null; try { // 主库向分库同步数据 logger.info("开始分库数据同步主库"); // 获取url路径 + errorUrl=syncDbInfo.get("ip"); final StringBuffer url=new StringBuffer(); url.append("jdbc:mysql://" + syncDbInfo.get("ip") + ":" + syncDbInfo.get("port") + "/" + syncDbInfo.get("database_name")+"?useUnicode=true&characterEncoding=utf-8&useOldAliasMetadataBehavior=true&rewriteBatchedStatements=true"); @@ -362,6 +364,7 @@ public class SyncSlaveToMasterThread implements Runnable{ logger.info("分库数据同步主库结束"); logger.info("##################################################"); } catch (Exception e) { + logger.error("分库同步主库数据连接为:"+errorUrl); logger.error("分库同步主库数据当前操作的异常表名为:"+errorTableName); logger.error("分库数据同步主库发生错误 异常信息为:"+e.getMessage()); logger.error("分库数据同步主库发生错误 异常信息",e);