diff --git a/jOOQ-meta-extensions-liquibase/src/main/java/org/jooq/meta/extensions/liquibase/LiquibaseDatabase.java b/jOOQ-meta-extensions-liquibase/src/main/java/org/jooq/meta/extensions/liquibase/LiquibaseDatabase.java index 1fadf8f969..cd9bb69313 100644 --- a/jOOQ-meta-extensions-liquibase/src/main/java/org/jooq/meta/extensions/liquibase/LiquibaseDatabase.java +++ b/jOOQ-meta-extensions-liquibase/src/main/java/org/jooq/meta/extensions/liquibase/LiquibaseDatabase.java @@ -46,6 +46,7 @@ import java.sql.SQLException; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; +import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; @@ -116,6 +117,7 @@ public class LiquibaseDatabase extends AbstractInterpretingDatabase { Database database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(new JdbcConnection(connection())); String contexts = ""; + Map changeLogParameters = new LinkedHashMap<>(); // [#9514] Forward all database.xyz properties to matching Liquibase // Database.setXyz() configuration setter calls @@ -141,6 +143,8 @@ public class LiquibaseDatabase extends AbstractInterpretingDatabase { if ("contexts".equals(property)) contexts = "" + entry.getValue(); + else + changeLogParameters.put(property, entry.getValue()); } } @@ -162,6 +166,7 @@ public class LiquibaseDatabase extends AbstractInterpretingDatabase { : new DirectoryResourceAccessor(new File(rootPath)); Liquibase liquibase = new Liquibase(scripts, ra, database); + changeLogParameters.forEach(liquibase::setChangeLogParameter); liquibase.update(contexts); }