0003366: Support transactional sync triggers

JumpMind · Jan 17, 2018 · 3352ecd · 3352ecd
1 parent 56505e3
commit 3352ecd
Showing 1 changed file with 3 additions and 3 deletions.
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
@@ -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);
         }