summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/database/BrandAnalyzerInserter.java1
-rw-r--r--src/main/Analyzor.java1
2 files changed, 2 insertions, 0 deletions
diff --git a/src/database/BrandAnalyzerInserter.java b/src/database/BrandAnalyzerInserter.java
index d42dac2..aa6a3c6 100644
--- a/src/database/BrandAnalyzerInserter.java
+++ b/src/database/BrandAnalyzerInserter.java
@@ -35,6 +35,7 @@ public class BrandAnalyzerInserter implements Callable<Integer>,
try {
runInserter();
} finally {
+ connection.commit();
connection.close();
}
return count;
diff --git a/src/main/Analyzor.java b/src/main/Analyzor.java
index 128b078..d74d62a 100644
--- a/src/main/Analyzor.java
+++ b/src/main/Analyzor.java
@@ -348,6 +348,7 @@ public class Analyzor {
try {
while (true) {
try {
+ // wait for all consumers to complete
for (Future<Integer> consumerTask : consumerTasks) {
consumerTask.get();
}