summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPeter Wu <peter@lekensteyn.nl>2014-06-11 15:17:02 +0200
committerPeter Wu <peter@lekensteyn.nl>2014-06-11 15:17:02 +0200
commit848fce2c3e6181ed265fe2098d13b54310289d83 (patch)
tree2539d068b478ca34c2f8e9a96c51c29d70265ae4
parent0b45bda64516af36577e6c72e2a0175a2f51701d (diff)
downloadGoldfarmer-master.tar.gz
getBrands: Do not lose uncommitted stuffHEADmaster
-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();
}