From df2f3ae265f797e66f239c0ab63f6ab020f255d9 Mon Sep 17 00:00:00 2001 From: tijsrademakers Date: Thu, 7 Feb 2013 10:20:01 +0100 Subject: [PATCH] Set Liquibase auto commit to false for JTA --- .../main/java/org/activiti/engine/impl/db/DbSqlSession.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/modules/activiti-engine/src/main/java/org/activiti/engine/impl/db/DbSqlSession.java b/modules/activiti-engine/src/main/java/org/activiti/engine/impl/db/DbSqlSession.java index 64c2809afc..de59ab7e21 100644 --- a/modules/activiti-engine/src/main/java/org/activiti/engine/impl/db/DbSqlSession.java +++ b/modules/activiti-engine/src/main/java/org/activiti/engine/impl/db/DbSqlSession.java @@ -762,6 +762,7 @@ public class DbSqlSession implements Session { JdbcConnection connection = new JdbcConnection(sqlSession.getConnection()); Database database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(connection); database.setDefaultSchemaName(this.connectionMetadataDefaultSchema); + database.setAutoCommit(false); Liquibase liquibase = new Liquibase("org/activiti/db/liquibase/activiti-master.xml", new ClassLoaderResourceAccessor(), database); liquibase.getDatabase().setDatabaseChangeLogLockTableName("ACT_" + liquibase.getDatabase().getDatabaseChangeLogLockTableName()); liquibase.getDatabase().setDatabaseChangeLogTableName("ACT_" + liquibase.getDatabase().getDatabaseChangeLogTableName()); @@ -776,6 +777,7 @@ public class DbSqlSession implements Session { JdbcConnection connection = new JdbcConnection(sqlSession.getConnection()); Database database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(connection); database.setDefaultSchemaName(this.connectionMetadataDefaultSchema); + database.setAutoCommit(false); Liquibase liquibase = new Liquibase("org/activiti/db/liquibase/activiti-master.xml", new ClassLoaderResourceAccessor(), database); liquibase.getDatabase().setDatabaseChangeLogLockTableName("ACT_" + liquibase.getDatabase().getDatabaseChangeLogLockTableName()); liquibase.getDatabase().setDatabaseChangeLogTableName("ACT_" + liquibase.getDatabase().getDatabaseChangeLogTableName()); @@ -809,6 +811,7 @@ public class DbSqlSession implements Session { JdbcConnection connection = new JdbcConnection(sqlSession.getConnection()); Database database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(connection); database.setDefaultSchemaName(this.connectionMetadataDefaultSchema); + database.setAutoCommit(false); Liquibase liquibase = new Liquibase("org/activiti/db/liquibase/activiti-upgrade-" + dbVersion + ".xml", new ClassLoaderResourceAccessor(), database); liquibase.getDatabase().setDatabaseChangeLogLockTableName("ACT_" + liquibase.getDatabase().getDatabaseChangeLogLockTableName()); liquibase.getDatabase().setDatabaseChangeLogTableName("ACT_" + liquibase.getDatabase().getDatabaseChangeLogTableName()); -- GitLab