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 451993eab..74d13f3e7 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 @@ -47,7 +47,7 @@ import org.springframework.jdbc.datasource.DriverManagerDataSource; @Slf4j public class FlywayInitListener implements ApplicationListener<ApplicationContextInitializedEvent>, Ordered { - private static final String FLYWAY_LOCATIONS = "classpath:db/migration"; + private static final String FLYWAY_LOCATIONS = "classpath:db/migration/mysql"; @Override public void onApplicationEvent(ApplicationContextInitializedEvent applicationEnvironmentPreparedEvent) { @@ -60,7 +60,6 @@ public class FlywayInitListener implements ApplicationListener<ApplicationContex String dataSourceUrl = environment.getProperty("spring.datasource.url"); String dataSourceUsername = environment.getProperty("spring.datasource.username"); String dataSourcePassword = environment.getProperty("spring.datasource.password"); - String driverClassName = environment.getProperty("spring.datasource.driver-class-name"); // flyway的配置 String enabledStr = environment.getProperty("spring.flyway.enabled"); diff --git a/kernel-d-ds-container/ds-container-sdk/src/main/java/cn/stylefeng/roses/kernel/dsctn/persist/sqls/CreateDatabaseSql.java b/kernel-d-ds-container/ds-container-sdk/src/main/java/cn/stylefeng/roses/kernel/dsctn/persist/sqls/CreateDatabaseSql.java index 35269cd5f..e35d26489 100644 --- a/kernel-d-ds-container/ds-container-sdk/src/main/java/cn/stylefeng/roses/kernel/dsctn/persist/sqls/CreateDatabaseSql.java +++ b/kernel-d-ds-container/ds-container-sdk/src/main/java/cn/stylefeng/roses/kernel/dsctn/persist/sqls/CreateDatabaseSql.java @@ -42,7 +42,9 @@ public class CreateDatabaseSql extends AbstractSql { @Override protected String sqlServer() { - return ""; + return "if not exists (select * from sysobjects where name=? and xtype='U')\n" + + " create table ? ;" + + "go"; } @Override