Fix uses of transaction

osvaldjr · Aug 1, 2019 · 4881f32 · 4881f32
1 parent f85605b
commit 4881f32
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/pom.xml b/pom.xml
@@ -12,7 +12,7 @@
     <groupId>io.github.osvaldjr</groupId>
     <artifactId>easy-cucumber</artifactId>
     <packaging>jar</packaging>
-    <version>0.0.10</version>
+    <version>0.0.11</version>
     <name>io.github.osvaldjr:easy-cucumber</name>
     <description>Easy Cucumber JVM Testing</description>
 

diff --git a/src/main/java/io/github/osvaldjr/usecases/DatabaseBulkSQLInsertUseCase.java b/src/main/java/io/github/osvaldjr/usecases/DatabaseBulkSQLInsertUseCase.java
@@ -14,6 +14,7 @@ public class DatabaseBulkSQLInsertUseCase {
 
   @Transactional
   public void execute(String sql) {
+    entityManager.joinTransaction();
     entityManager.createNativeQuery(sql).executeUpdate();
   }
 }
diff --git a/src/main/java/io/github/osvaldjr/usecases/DatabaseTableInsertUseCase.java b/src/main/java/io/github/osvaldjr/usecases/DatabaseTableInsertUseCase.java
@@ -27,6 +27,7 @@ public void execute(String tableName, List<TreeMap> lines) {
     String columns = getColumns(lines.get(0));
     String values = getInsertValues(lines);
     String query = format("INSERT INTO %s (%s) VALUES %s;", tableName, columns, values);
+    entityManager.joinTransaction();
     entityManager.createNativeQuery(query).executeUpdate();
   }