From fe188ce97f5e02ca67e4f7640938a6d73fb5d930 Mon Sep 17 00:00:00 2001 From: Lujie <907298149@qq.com> Date: Wed, 26 May 2021 22:49:26 +0800 Subject: [PATCH] =?UTF-8?q?Flyway=20=E5=85=BC=E5=AE=B9sharding-jdbc?= =?UTF-8?q?=E8=AF=BB=E5=86=99=E5=88=86=E7=A6=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../roses/kernel/db/flyway/FlywayInitListener.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/kernel-d-db/db-sdk-flyway/src/main/java/cn/stylefeng/roses/kernel/db/flyway/FlywayInitListener.java b/kernel-d-db/db-sdk-flyway/src/main/java/cn/stylefeng/roses/kernel/db/flyway/FlywayInitListener.java index 995dc8e0a..bfc5e399b 100644 --- a/kernel-d-db/db-sdk-flyway/src/main/java/cn/stylefeng/roses/kernel/db/flyway/FlywayInitListener.java +++ b/kernel-d-db/db-sdk-flyway/src/main/java/cn/stylefeng/roses/kernel/db/flyway/FlywayInitListener.java @@ -59,6 +59,15 @@ 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"); + } // flyway的配置 String enabledStr = environment.getProperty("spring.flyway.enabled");