优化注释

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<Record> 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();
 		}
 	}