From ea3230250e25d6e0916621920ef8f2a4a11a3782 Mon Sep 17 00:00:00 2001 From: default Date: Tue, 23 Oct 2018 19:34:15 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java | 4 ++-- nms_sync/src/com/nms/interceptor/SyncStoredProcedure.java | 2 +- nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java | 3 ++- nms_sync/src/com/nms/thread/SyncThread.java | 1 + 4 files changed, 6 insertions(+), 4 deletions(-) diff --git a/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java b/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java index 8f6324d..1257e9e 100644 --- a/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java +++ b/nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java @@ -35,7 +35,7 @@ public class SyncDataInterceptor implements Interceptor{ //判断metadata表 是否有新增数据 如果有执行sql 修改表结构 if(metadataTableSyncInfo!=null){ List metadatas = Db.use(url).find("select m.*,cti.table_name from metadata m left join check_type_info cti on m.check_type_id=cti.id where m.id > ? ",metadataTableSyncInfo.getLong("last_id")); - logger.info("metadata表中新增数据信息查询结果为 "+JSON.toJSONString(metadatas)); + //logger.info("metadata表中新增数据信息查询结果为 "+JSON.toJSONString(metadatas)); if(metadatas!=null && metadatas.size()>0){ for(Record metadata:metadatas){ Record isExist = Db.use(url).findFirst("select COUNT(1) count from information_schema.`TABLES` WHERE TABLE_SCHEMA = '"+syncDbInfo.getStr("database_name")+"' and UPPER(TABLE_NAME) = ?",metadata.getStr("table_name")); @@ -109,7 +109,7 @@ public class SyncDataInterceptor implements Interceptor{ logger.info("--------数据同步前 syncDataInterceptor拦截器拦截结束------------"); }catch(Exception e){ e.printStackTrace(); - logger.info("syncDataInterceptor拦截器内部程序出现异常信息"+e.getMessage()); + logger.error("syncDataInterceptor拦截器内部程序出现异常信息"+e.getMessage()); } } diff --git a/nms_sync/src/com/nms/interceptor/SyncStoredProcedure.java b/nms_sync/src/com/nms/interceptor/SyncStoredProcedure.java index 2389a57..9ad6cd0 100644 --- a/nms_sync/src/com/nms/interceptor/SyncStoredProcedure.java +++ b/nms_sync/src/com/nms/interceptor/SyncStoredProcedure.java @@ -35,7 +35,7 @@ public class SyncStoredProcedure implements ICallback{ proc.execute(); logger.info("调用存储过程任务结束"); } catch (Exception e){ - logger.info("调用存储过程任务出现错误 存储过程名称"+proName+" 表名"+tableName+"参数 "+filedAndType+"------"+fileds); + logger.error("调用存储过程任务出现错误 存储过程名称"+proName+" 表名"+tableName+"参数 "+filedAndType+"------"+fileds); e.printStackTrace(); } finally{ if(conn!=null){ diff --git a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java index 131905a..e1664cc 100644 --- a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java +++ b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java @@ -86,7 +86,7 @@ public class SyncSlaveToMasterThread implements Runnable{ public boolean run() throws SQLException { Db.use("masterDataSource").batchSave(record.getStr("table_name"), data, record.getInt("batch_size")); // 同步完成后 取出最后一条数据的id 更新到table_sync_info表中 用作下次使用 - logger.info("分库同步增量更新数据完成"); + logger.info("分库同步增量更新数据完成 表名为"+record.getStr("table_name")); logger.info("分库同步最后数据的id信息为"+JSON.toJSONString(lastInsertId)); record.set("last_id", lastInsertId); record.set("last_date", new Date()); @@ -246,6 +246,7 @@ public class SyncSlaveToMasterThread implements Runnable{ logger.info("分库数据同步主库结束"); logger.info("##################################################"); } catch (Exception e) { + logger.error("分库数据同步主库发生错误 异常信息为:"+e.getMessage()); e.printStackTrace(); } } diff --git a/nms_sync/src/com/nms/thread/SyncThread.java b/nms_sync/src/com/nms/thread/SyncThread.java index 5e11dd7..a05222d 100644 --- a/nms_sync/src/com/nms/thread/SyncThread.java +++ b/nms_sync/src/com/nms/thread/SyncThread.java @@ -244,6 +244,7 @@ public class SyncThread implements Runnable { logger.info("主库数据同步分库结束"); logger.info("*****************************************************"); } catch (Exception e) { + logger.error("主库数据同步分库发生错误 异常信息为:"+e.getMessage()); e.printStackTrace(); } }