gitee
/
roses
mirror of https://gitee.com/stylefeng/roses
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

!19 Sharding-jdbc 读写分离 

Merge pull request !19 from sol/7.0.4-develop
pull/19/MERGE
stylefeng 2021-06-01 22:11:00 +08:00 committed by Gitee
parent 8abd1db843 fe188ce97f
commit f454319b8e
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
kernel-d-db/db-sdk-flyway/src/main/java/cn/stylefeng/roses/kernel/db/flyway/FlywayInitListener.java
View File

@ -59,6 +59,15 @@ public class FlywayInitListener extends ContextInitializedListener implements Or
String dataSourceUrl = environment.getProperty("spring.datasource.url"); String dataSourceUrl = environment.getProperty("spring.datasource.url");
String dataSourceUsername = environment.getProperty("spring.datasource.username"); String dataSourceUsername = environment.getProperty("spring.datasource.username");
String dataSourcePassword = environment.getProperty("spring.datasource.password"); String dataSourcePassword = environment.getProperty("spring.datasource.password");
// 判断是否开启 sharding jdbc
Boolean isEnableShardingDb = environment.getProperty("spring.shardingsphere.enabled", Boolean.class);
if (ObjectUtil.isNotNull(isEnableShardingDb) && isEnableShardingDb){
//读取 sharding jdbc 主库配置
dataSourceUrl = environment.getProperty("spring.shardingsphere.datasource.m0.url");
dataSourceUsername = environment.getProperty("spring.shardingsphere.datasource.m0.username");
dataSourcePassword = environment.getProperty("spring.shardingsphere.datasource.m0.password");
driverClassName = environment.getProperty("spring.shardingsphere.datasource.m0.driver-class-name");
}
// flyway的配置 // flyway的配置
String enabledStr = environment.getProperty("spring.flyway.enabled"); String enabledStr = environment.getProperty("spring.flyway.enabled");