修改查询语句

2024-09-09 15:46:12 +08:00 · 2024-09-09 15:46:12 +08:00 · 88e670fb69
parent 749f86cec7
commit 88e670fb69
1 changed files with 1 additions and 1 deletions
--- 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
@ -503,7 +503,7 @@ public int addProduct(Long basicId, Long tableId, DataValue[][] listList) {
    AtomicInteger addCount = new AtomicInteger();

    // 分割数据为较小的批次
-    List<DataValue[][]> batches = splitData(listList, 3000);
+    List<DataValue[][]> batches = splitData(listList, 2000);

    try (Connection conn = hikariDataSource.getConnection()) {
        conn.setAutoCommit(false); // 开启事务