This commit is contained in:
default
2018-10-12 11:33:19 +08:00
parent ac756d0149
commit 789b033b12
3 changed files with 10 additions and 9 deletions

View File

@@ -1,12 +1,12 @@
#dbinfo=[{"databaseName":"nms_sync","userName":"nms","isMaster":true,"password":"nms","url":"jdbc:mysql://localhost:3306/nms_sync"}]
#\u6570\u636e\u5e93\u8fde\u63a5\u5730\u5740
dburl=jdbc:mysql://192.168.10.126:3306/nms-dev
dburl=jdbc:mysql://192.168.11.153:3306/nms
#\u6570\u636e\u5e93\u8d26\u6237\u540d
dbusername=root
dbusername=nms
#\u6570\u636e\u5e93\u5bc6\u7801
dbpassword=111111
dbpassword=nms
#\u6570\u636e\u5e93\u540d\u79f0
dbname=nms-dev
dbname=nms
#\u8fde\u63a5\u6c60\u521d\u59cb\u5316\u5927\u5c0f
dbInitialSize=1
#\u6700\u5927\u8fde\u63a5\u6570

View File

@@ -1,12 +1,12 @@
#dbinfo=[{"databaseName":"nms_sync","userName":"nms","isMaster":true,"password":"nms","url":"jdbc:mysql://localhost:3306/nms_sync"}]
#\u6570\u636e\u5e93\u8fde\u63a5\u5730\u5740
dburl=jdbc:mysql://192.168.10.126:3306/nms-dev
dburl=jdbc:mysql://192.168.11.153:3306/nms
#\u6570\u636e\u5e93\u8d26\u6237\u540d
dbusername=root
dbusername=nms
#\u6570\u636e\u5e93\u5bc6\u7801
dbpassword=111111
dbpassword=nms
#\u6570\u636e\u5e93\u540d\u79f0
dbname=nms-dev
dbname=nms
#\u8fde\u63a5\u6c60\u521d\u59cb\u5316\u5927\u5c0f
dbInitialSize=1
#\u6700\u5927\u8fde\u63a5\u6570

View File

@@ -57,7 +57,8 @@ public class SyncData{
scheduleService.scheduleWithFixedDelay(syncThread, 0, Integer.valueOf(PropKit.use("config.properties").get("syncMaterToSlaveTime")), TimeUnit.MILLISECONDS);
// 分库向主库同步数据
logger.info("创建分库数据同步到主库线程执行任务");
//scheduleService.scheduleWithFixedDelay(new SyncSlaveToMasterThread(syncDbInfo), 0, Integer.valueOf(PropKit.use("config.properties").get("syncSlaveToMaterTime")), TimeUnit.MILLISECONDS);
//SyncThread syncSlaveToMasterThread = Duang.duang(new SyncSlaveToMasterThread(syncDbInfo));
//scheduleService.scheduleWithFixedDelay(syncSlaveToMasterThread, 0, Integer.valueOf(PropKit.use("config.properties").get("syncSlaveToMaterTime")), TimeUnit.MILLISECONDS);
}
}else{
logger.info("获取同步记录信息失败 请检查数据库数据信息");