diff --git a/symmetric-db/src/main/java/org/jumpmind/db/platform/AbstractDatabasePlatform.java b/symmetric-db/src/main/java/org/jumpmind/db/platform/AbstractDatabasePlatform.java index 157ff7c681..50546125e8 100644 --- a/symmetric-db/src/main/java/org/jumpmind/db/platform/AbstractDatabasePlatform.java +++ b/symmetric-db/src/main/java/org/jumpmind/db/platform/AbstractDatabasePlatform.java @@ -178,7 +178,7 @@ public void dropTables(boolean continueOnError, Table... tables) { public void dropDatabase(Database database, boolean continueOnError) { String sql = ddlBuilder.dropTables(database); - new SqlScript(sql, getSqlTemplate(), !continueOnError, null).execute(getDatabaseInfo().isRequiresAutoCommitForDdl()); + new SqlScript(sql, getSqlTemplate(), !continueOnError, null).execute(continueOnError ? true : getDatabaseInfo().isRequiresAutoCommitForDdl()); } public void createTables(boolean dropTablesFirst, boolean continueOnError, Table... tables) { @@ -200,7 +200,7 @@ public void createDatabase(Database targetDatabase, boolean dropTablesFirst, boo String delimiter = getDdlBuilder().getDatabaseInfo().getSqlCommandDelimiter(); new SqlScript(createSql, getSqlTemplate(), !continueOnError, false, false, delimiter, null) - .execute(getDatabaseInfo().isRequiresAutoCommitForDdl()); + .execute(continueOnError ? true : getDatabaseInfo().isRequiresAutoCommitForDdl()); } public void alterDatabase(Database desiredDatabase, boolean continueOnError) { @@ -231,7 +231,7 @@ public void alterTables(boolean continueOnError, Table... desiredTables) { log.info("Running alter sql:\n{}", alterSql); String delimiter = getDdlBuilder().getDatabaseInfo().getSqlCommandDelimiter(); new SqlScript(alterSql, getSqlTemplate(), !continueOnError, false, false, delimiter, null) - .execute(getDatabaseInfo().isRequiresAutoCommitForDdl()); + .execute(continueOnError ? true : getDatabaseInfo().isRequiresAutoCommitForDdl()); } else { log.info("Tables up to date. No alters found for {}", tablesProcessed); }