feat: add catch for duplicated key issue

archguard · Mar 20, 2022 · f343f7c · f343f7c
1 parent d8de8a1
commit f343f7c
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/common/src/main/java/infrastructure/DBIStore.java b/common/src/main/java/infrastructure/DBIStore.java
@@ -6,12 +6,16 @@
 import io.netty.util.internal.StringUtil;
 import org.jdbi.v3.core.Jdbi;
 import org.jdbi.v3.core.statement.Batch;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.Phaser;
 
 public class DBIStore {
+    private static final Logger logger = LoggerFactory.getLogger(DefaultBatchImpl.class);
 
     private static final String JDBC_URL = System.getProperty("dburl");
     private static final DBIStore INSTANCE = new DBIStore(JDBC_URL);
@@ -58,7 +62,13 @@ private void doSave(List<String> sqls, String file, Phaser phaser) {
                     for (String sql : sqls) {
                         batch.add(sql);
                     }
-                    return batch.execute();
+
+                    try {
+                        batch.execute();
+                    } catch (Exception e) {
+                        logger.info(String.valueOf(e));
+                    }
+                    return new ArrayList<Integer>();
                 }));
 
         SqlExecuteThreadPool.execute(p);