From a4802c09cd2e36ce40ff0e9ce483ff5d5ee883e0 Mon Sep 17 00:00:00 2001
From: lwj <3529558005@qq.com>
Date: Sun, 8 Sep 2024 23:44:18 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B7=BB=E5=8A=A0,=E7=AC=AC?=
 =?UTF-8?q?=E4=B8=80=E7=A7=8D=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cloud/etl/service/impl/ProductServiceImpl.java | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 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 fcb345b..20f0beb 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,12 +1,12 @@
 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;
 import com.muyu.domain.DataValue;
 import com.muyu.domain.Source;
 import com.muyu.domain.TableInfo;
+import com.zaxxer.hikari.HikariConfig;
 import com.zaxxer.hikari.HikariDataSource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -39,7 +39,17 @@ public class ProductServiceImpl implements ProductService {
 
 //        HikariDataSource hikariDataSource = getHikariDataSource(dataSources);
 
-        HikariDataSource hikariDataSource = HikariPool.getHikariDataSource(dataSources);
+//        HikariDataSource hikariDataSource = HikariPool.getHikariDataSource(dataSources);
+
+                    HikariConfig hikariConfig = new HikariConfig();
+            hikariConfig.setPoolName("HikariCP 连接池");
+            hikariConfig.setDriverClassName(dataSources.getDriverName());
+            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();