From edd37e38a1926d0322e9b6bf1b0d18884e1090d5 Mon Sep 17 00:00:00 2001
From: lwj <3529558005@qq.com>
Date: Mon, 9 Sep 2024 16:10:20 +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

---
 .../com/muyu/cloud/etl/service/impl/ProductServiceImpl.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 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 e88b428..678a713 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
@@ -1,5 +1,6 @@
 package com.muyu.cloud.etl.service.impl;
 
+import com.muyu.Hikari.HikariPool;
 import com.muyu.cloud.etl.service.ProductService;
 import com.muyu.cloud.etl.service.SourceService;
 import com.muyu.cloud.etl.service.TableInfoService;
@@ -7,7 +8,6 @@ import com.muyu.domain.DataValue;
 import com.muyu.domain.Source;
 import com.muyu.domain.TableInfo;
 import com.muyu.domain.enums.DataType;
-import com.zaxxer.hikari.HikariConfig;
 import com.zaxxer.hikari.HikariDataSource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -498,8 +498,7 @@ public int addProduct(Long basicId, Long tableId, DataValue[][] listList) {
 //    hikariConfig.setMaximumPoolSize(10);
 //
 
-    HikariConfig hikariConfig = new HikariConfig();
-    HikariDataSource hikariDataSource = new HikariDataSource(hikariConfig);
+    HikariDataSource hikariDataSource = HikariPool.getHikariDataSource(dataSources);
     ExecutorService executorService = Executors.newFixedThreadPool(8);
     AtomicInteger addCount = new AtomicInteger();