gfwleak/nms-nmssync
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化注释

Browse Source
This commit is contained in:
default
2018-10-23 19:34:15 +08:00
parent 48f24e37db
commit ea3230250e
4 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
nms_sync/src/com/nms/interceptor/SyncDataInterceptor.java
View File

@@ -35,7 +35,7 @@ public class SyncDataInterceptor implements Interceptor{
//判断metadata表 是否有新增数据 如果有执行sql 修改表结构 //判断metadata表 是否有新增数据 如果有执行sql 修改表结构
if(metadataTableSyncInfo!=null){ 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")); 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){ if(metadatas!=null && metadatas.size()>0){
for(Record metadata:metadatas){ 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")); 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拦截器拦截结束------------"); logger.info("--------数据同步前 syncDataInterceptor拦截器拦截结束------------");
}catch(Exception e){ }catch(Exception e){
e.printStackTrace(); e.printStackTrace();
logger.info("syncDataInterceptor拦截器内部程序出现异常信息"+e.getMessage()); logger.error("syncDataInterceptor拦截器内部程序出现异常信息"+e.getMessage());
} }
} }

2
nms_sync/src/com/nms/interceptor/SyncStoredProcedure.java
View File

@@ -35,7 +35,7 @@ public class SyncStoredProcedure implements ICallback{
proc.execute(); proc.execute();
logger.info("调用存储过程任务结束"); logger.info("调用存储过程任务结束");
} catch (Exception e){ } catch (Exception e){
logger.info("调用存储过程任务出现错误 存储过程名称"+proName+" 表名"+tableName+"参数 "+filedAndType+"------"+fileds); logger.error("调用存储过程任务出现错误 存储过程名称"+proName+" 表名"+tableName+"参数 "+filedAndType+"------"+fileds);
e.printStackTrace(); e.printStackTrace();
} finally{ } finally{
if(conn!=null){ if(conn!=null){

3
nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java
View File

@@ -86,7 +86,7 @@ public class SyncSlaveToMasterThread implements Runnable{
public boolean run() throws SQLException { public boolean run() throws SQLException {
Db.use("masterDataSource").batchSave(record.getStr("table_name"), data, record.getInt("batch_size")); Db.use("masterDataSource").batchSave(record.getStr("table_name"), data, record.getInt("batch_size"));
// 同步完成后 取出最后一条数据的id 更新到table_sync_info表中 用作下次使用 // 同步完成后 取出最后一条数据的id 更新到table_sync_info表中 用作下次使用
logger.info("分库同步增量更新数据完成"); logger.info("分库同步增量更新数据完成 表名为"+record.getStr("table_name"));
logger.info("分库同步最后数据的id信息为"+JSON.toJSONString(lastInsertId)); logger.info("分库同步最后数据的id信息为"+JSON.toJSONString(lastInsertId));
record.set("last_id", lastInsertId); record.set("last_id", lastInsertId);
record.set("last_date", new Date()); record.set("last_date", new Date());
@@ -246,6 +246,7 @@ public class SyncSlaveToMasterThread implements Runnable{
logger.info("分库数据同步主库结束"); logger.info("分库数据同步主库结束");
logger.info("##################################################"); logger.info("##################################################");
} catch (Exception e) { } catch (Exception e) {
logger.error("分库数据同步主库发生错误 异常信息为:"+e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
} }

1
nms_sync/src/com/nms/thread/SyncThread.java
View File

@@ -244,6 +244,7 @@ public class SyncThread implements Runnable {
logger.info("主库数据同步分库结束"); logger.info("主库数据同步分库结束");
logger.info("*****************************************************"); logger.info("*****************************************************");
} catch (Exception e) { } catch (Exception e) {
logger.error("主库数据同步分库发生错误 异常信息为:"+e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
} }