diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java index 5a9e87f..5a048e1 100644 --- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java +++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java @@ -179,6 +179,7 @@ public class ProductServiceImpl implements ProductService { HikariDataSource hikariDataSource = HikariPool.getHikariDataSource(dataSources); ExecutorService executorService = Executors.newFixedThreadPool(8); + AtomicInteger addCount = new AtomicInteger(); // 分割数据为3000个批次 @@ -189,6 +190,7 @@ public class ProductServiceImpl implements ProductService { for (DataValue[][] batch : batches) { log.info("数量batch{}", batch.length); + executorService.submit(() -> { try (Statement stmt = conn.createStatement()) { @@ -226,6 +228,8 @@ public class ProductServiceImpl implements ProductService { } private String buildBatchInsertSQL(String tableName, DataValue[][] batch) { + + log.info("陈思豪是傻逼"+tableName); StringBuilder columns = new StringBuilder("("); StringBuilder values = new StringBuilder("VALUES "); // 构建字段名