Migrate survey runs to use the involvement group table

#CTCTOWALTZ-2760 finos#6637
deutschebank · Jun 7, 2023 · 17891dc · 17891dc
1 parent a45c261
commit 17891dc
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/waltz-data/src/main/java/org/finos/waltz/data/involvement_group/InvolvementGroupDao.java b/waltz-data/src/main/java/org/finos/waltz/data/involvement_group/InvolvementGroupDao.java
@@ -15,6 +15,7 @@
 import java.util.stream.Collectors;
 
 import static org.finos.waltz.common.CollectionUtilities.notEmpty;
+import static org.finos.waltz.data.JooqUtilities.summarizeResults;
 import static org.finos.waltz.schema.Tables.INVOLVEMENT_GROUP;
 import static org.finos.waltz.schema.Tables.INVOLVEMENT_GROUP_ENTRY;
 
@@ -61,15 +62,17 @@ public Long createInvolvementGroup(InvolvementGroupCreateCommand cmd) {
                 .getId();
 
         if (invGroupId != null && notEmpty(cmd.involvementKindIds())) {
-            cmd.involvementKindIds()
+
+            int inserted = summarizeResults(cmd.involvementKindIds()
                     .stream()
                     .map(kindId -> {
                         InvolvementGroupEntryRecord entry = dsl.newRecord(INVOLVEMENT_GROUP_ENTRY);
                         entry.setInvolvementGroupId(invGroupId);
                         entry.setInvolvementKindId(kindId);
                         return entry;
                     })
-                    .collect(Collectors.collectingAndThen(Collectors.toSet(), dsl::batchInsert));
+                    .collect(Collectors.collectingAndThen(Collectors.toSet(), dsl::batchInsert))
+                    .execute());
         }
 
         return invGroupId;