From 1d4b30336eae8bcc77ede5b3f34f5f3a5b6bc175 Mon Sep 17 00:00:00 2001 From: lwj <3529558005@qq.com> Date: Mon, 9 Sep 2024 16:06:15 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=9F=A5=E8=AF=A2=E8=AF=AD?= =?UTF-8?q?=E5=8F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../etl/service/impl/ProductServiceImpl.java | 21 ++++++++++--------- 1 file changed, 11 insertions(+), 10 deletions(-) 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 8ef6535..e88b428 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 @@ -487,18 +487,19 @@ public int addProduct(Long basicId, Long tableId, DataValue[][] listList) { TableInfo tableInfo = tableInfoService.getById(tableId); String tableName = tableInfo.getTableName(); +// HikariConfig hikariConfig = new HikariConfig(); +// hikariConfig.setPoolName("HikariCP 连接池"); +// hikariConfig.setDriverClassName(dataSources.getDriverName()); +// // hikariConfig.setJdbcUrl(dataSources.getUrl(dataSources) + "&maxAllowedPacket=1G"); +// hikariConfig.setJdbcUrl(dataSources.getUrl()); +// hikariConfig.setUsername(dataSources.getUsername()); +// hikariConfig.setPassword(dataSources.getPassword()); +// hikariConfig.setMinimumIdle(2); +// hikariConfig.setMaximumPoolSize(10); +// + HikariConfig hikariConfig = new HikariConfig(); - hikariConfig.setPoolName("HikariCP 连接池"); - hikariConfig.setDriverClassName(dataSources.getDriverName()); - // hikariConfig.setJdbcUrl(dataSources.getUrl(dataSources) + "&maxAllowedPacket=1G"); - hikariConfig.setJdbcUrl(dataSources.getUrl()); - hikariConfig.setUsername(dataSources.getUsername()); - hikariConfig.setPassword(dataSources.getPassword()); - hikariConfig.setMinimumIdle(2); - hikariConfig.setMaximumPoolSize(10); - HikariDataSource hikariDataSource = new HikariDataSource(hikariConfig); - ExecutorService executorService = Executors.newFixedThreadPool(8); AtomicInteger addCount = new AtomicInteger();