Add a flush

DiSSCo · Jan 29, 2024 · bb473b7 · bb473b7
1 parent d73389f
commit bb473b7
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main/java/eu/dissco/core/translator/repository/BatchInserter.java b/src/main/java/eu/dissco/core/translator/repository/BatchInserter.java
@@ -47,8 +47,8 @@ public void batchCopy(String tableName, List<Pair<String, JsonNode>> dbRecords)
       for (var dbRecord : dbRecords) {
         bos.write(getCsvRow(dbRecord));
       }
-      try (ByteArrayInputStream bais =
-          new ByteArrayInputStream(baos.toByteArray())) {
+      bos.flush();
+      try (var bais = new ByteArrayInputStream(baos.toByteArray())) {
         copyManager.copyIn("COPY " + tableName
             + " FROM stdin DELIMITER ','", bais);
       }
@@ -59,5 +59,4 @@ public void batchCopy(String tableName, List<Pair<String, JsonNode>> dbRecords)
     }
   }
 
-
 }