diff --git a/common/src/main/java/infrastructure/DBIStore.java b/common/src/main/java/infrastructure/DBIStore.java index 236145fe..50e208a1 100644 --- 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 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(); })); SqlExecuteThreadPool.execute(p);