TreeData
/
cloud-etl-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改添加连接池

master
lwj 2024-09-10 02:23:37 +08:00
parent 82896751fb
commit 5024b02322
3 changed files with 33 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
cloud-etl-client/pom.xml
View File

@ -16,5 +16,30 @@
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.0</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-etl</artifactId>
<version>1.0.0</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-remote</artifactId>
<version>1.0.0</version>
<scope>compile</scope>
</dependency>
</dependencies>
</project>

12
cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java → cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java
View File

@ -1,8 +1,7 @@
package com.muyu.cloud.etl.mysql;
package com.muyu.mysql;
import com.muyu.cloud.etl.service.SourceService;
import com.muyu.common.core.utils.SpringUtils;
import com.muyu.basic.SourceConfig;
import com.muyu.data.base.BaseDataAbsSource;
import com.muyu.domain.DataValue;
import com.muyu.domain.Source;
@ -10,6 +9,7 @@ import com.muyu.domain.enums.DataType;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.sql.*;
@ -21,7 +21,9 @@ import java.util.concurrent.ConcurrentHashMap;
public class MySqlDataSource extends BaseDataAbsSource {
SourceService sourceService = SpringUtils.getBean(SourceService.class);
@Autowired
private SourceConfig sourceRemote;
// SourceService sourceService = SpringUtils.getBean(SourceService.class);
@Override
@ -357,7 +359,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
Long dataSourceId = query.getDataSourceId();
ConcurrentHashMap<Integer, DataValue> map = new ConcurrentHashMap<>();
Source dataSources = sourceService.getById(dataSourceId);
Source dataSources = sourceRemote.queryById(dataSourceId);
HikariConfig hikariConfig = new HikariConfig();
hikariConfig.setPoolName("HikariCP 连接池");

2
cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlQuery.java → cloud-etl-client/src/main/java/com/muyu/mysql/MySqlQuery.java
View File

@ -1,4 +1,4 @@
package com.muyu.cloud.etl.mysql;
package com.muyu.mysql;
import com.muyu.data.base.BaseQuery;
import lombok.AllArgsConstructor;