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

【7.0.4】整理代码

pull/20/MERGE
fengshuonan 2021-06-01 22:18:40 +08:00
parent f454319b8e
commit 7abbec08fe
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -59,14 +59,16 @@ public class FlywayInitListener extends ContextInitializedListener implements Or
String dataSourceUrl = environment.getProperty("spring.datasource.url");
String dataSourceUsername = environment.getProperty("spring.datasource.username");
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");
Boolean enableSharding = environment.getProperty("spring.shardingsphere.enabled", Boolean.class);
// 如果开启了sharding jdbc，则读取 sharding jdbc 主库配置
if (ObjectUtil.isNotNull(enableSharding) && enableSharding) {
driverClassName = environment.getProperty("spring.shardingsphere.datasource.master.driver-class-name");
dataSourceUrl = environment.getProperty("spring.shardingsphere.datasource.master.url");
dataSourceUsername = environment.getProperty("spring.shardingsphere.datasource.master.username");
dataSourcePassword = environment.getProperty("spring.shardingsphere.datasource.master.password");
}
// flyway的配置