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

update

Browse Source
This commit is contained in:
default
2018-11-13 15:06:03 +08:00
parent 2196c2b10d
commit f8073042d3
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -90,8 +90,8 @@ public class SyncDataInterceptor implements Interceptor{
logger.info("check_type_info新增数据创建表结构 参数信息 sql"+sql.toString()); logger.info("check_type_info新增数据创建表结构 参数信息 sql"+sql.toString());
logger.info("check_type_info新增数据创建表结构 参数信息 字段名称"+cIndexFileds.toString()); logger.info("check_type_info新增数据创建表结构 参数信息 字段名称"+cIndexFileds.toString());
SyncStoredProcedure syncStoreProcedure=new SyncStoredProcedure("pro_createTable",checkTypeInfo.getStr("TABLE_NAME"), sql.toString(),cIndexFileds.toString()); SyncStoredProcedure syncStoreProcedure=new SyncStoredProcedure("pro_createTable",checkTypeInfo.getStr("TABLE_NAME"), sql.toString(),cIndexFileds.toString());
Db.use(url).execute(syncStoreProcedure); Object execute = Db.use(url).execute(syncStoreProcedure);
logger.info("创建新表操作完成"); logger.info("创建新表操作完成"+execute);
//创建完新表结构以后 将同步信息添加到同步表 使新配置的监测数据同步到中心 //创建完新表结构以后 将同步信息添加到同步表 使新配置的监测数据同步到中心
Record record = new Record(); Record record = new Record();

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

@@ -34,10 +34,12 @@ public class SyncSlaveToMasterThread implements Runnable{
@Override @Override
public void run() { public void run() {
String errorTableName=null; String errorTableName=null;
String errorUrl=null;
try { try {
// 主库向分库同步数据 // 主库向分库同步数据
logger.info("开始分库数据同步主库"); logger.info("开始分库数据同步主库");
// 获取url路径 // 获取url路径
errorUrl=syncDbInfo.get("ip");
final StringBuffer url=new StringBuffer(); final StringBuffer url=new StringBuffer();
url.append("jdbc:mysql://" + syncDbInfo.get("ip") + ":" + syncDbInfo.get("port") + "/" url.append("jdbc:mysql://" + syncDbInfo.get("ip") + ":" + syncDbInfo.get("port") + "/"
+ syncDbInfo.get("database_name")+"?useUnicode=true&characterEncoding=utf-8&useOldAliasMetadataBehavior=true&rewriteBatchedStatements=true"); + 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("分库数据同步主库结束");
logger.info("##################################################"); logger.info("##################################################");
} catch (Exception e) { } catch (Exception e) {
logger.error("分库同步主库数据连接为:"+errorUrl);
logger.error("分库同步主库数据当前操作的异常表名为:"+errorTableName); logger.error("分库同步主库数据当前操作的异常表名为:"+errorTableName);
logger.error("分库数据同步主库发生错误 异常信息为:"+e.getMessage()); logger.error("分库数据同步主库发生错误 异常信息为:"+e.getMessage());
logger.error("分库数据同步主库发生错误 异常信息",e); logger.error("分库数据同步主库发生错误 异常信息",e);