diff --git a/wizard-server/src/main/java/org/cobbzilla/wizard/server/listener/FlywayMigrationListener.java b/wizard-server/src/main/java/org/cobbzilla/wizard/server/listener/FlywayMigrationListener.java index f312e5f..5e80bab 100644 --- a/wizard-server/src/main/java/org/cobbzilla/wizard/server/listener/FlywayMigrationListener.java +++ b/wizard-server/src/main/java/org/cobbzilla/wizard/server/listener/FlywayMigrationListener.java @@ -21,7 +21,6 @@ import static org.cobbzilla.util.time.TimeUtil.DATE_FORMAT_YYYYMMDD; @Slf4j public class FlywayMigrationListener extends RestServerLifecycleListenerBase { - public static final String FLYWAY_TABLE_NAME = "flyway_schema_history"; protected RestServer server; @Override public void beforeStart(RestServer server) { @@ -39,12 +38,13 @@ public class FlywayMigrationListener extends public void migrate(PgRestServerConfiguration configuration) { // check to see if flyway tables exist + final var flywayTableName = Flyway.configure().getTable(); boolean baseline = false; try { - configuration.execSql("SELECT * from " + FLYWAY_TABLE_NAME); + configuration.execSql("SELECT * from " + flywayTableName); } catch (UncheckedSqlException e) { if (e.getSqlException() != null && e.getSqlException() instanceof PSQLException && e.getMessage().contains(" does not exist")) { - log.warn(FLYWAY_TABLE_NAME + " table does not exist, will baseline DB"); + log.warn(flywayTableName + " table does not exist, will baseline DB"); baseline = true; } else { throw e;