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

添加数据时修改

master
lwj 2024-09-08 19:30:19 +08:00
parent a4cc218bef
commit 2bdc188fc9
2 changed files with 33 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
cloud-etl-common/src/main/java/com/muyu/domain/Source.java
View File

@ -6,7 +6,6 @@ import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.annotation.Excel; import com.muyu.common.core.annotation.Excel;
import com.muyu.common.core.web.domain.BaseEntity; import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.domain.mysql.BaseConfig; import com.muyu.domain.mysql.BaseConfig;
import com.muyu.domain.mysql.config.MysqlPoolConfig;
import jakarta.validation.constraints.NotBlank; import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull; import jakarta.validation.constraints.NotNull;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@ -89,19 +88,19 @@ public class Source extends BaseEntity {
@Excel(name = "驱动 ") @Excel(name = "驱动 ")
private String driverName; private String driverName;
public static MysqlPoolConfig getMysqlPoolConfig(Source source) { // public static getMysqlPoolConfig(Source source) {
return MysqlPoolConfig.builder() // return MysqlPoolConfig.builder()
.id(source.getId()) // .id(source.getId())
.dataResourceName(source.getDataResourceName()) // .dataResourceName(source.getDataResourceName())
.dataSourcesSystemName(source.getDataSourcesSystemName()) // .dataSourcesSystemName(source.getDataSourcesSystemName())
.host(source.getHost()) // .host(source.getHost())
.port(source.getPort()) // .port(source.getPort())
.databaseType(source.getDatabaseType()) // .databaseType(source.getDatabaseType())
.databaseName(source.getDatabaseName()) // .databaseName(source.getDatabaseName())
.initLinkNum(source.getInitLinkNum()) // .initLinkNum(source.getInitLinkNum())
.maxLinkNum(source.getMaxLinkNum()) // .maxLinkNum(source.getMaxLinkNum())
.build(); // .build();
} // }
public String getUrl(){ public String getUrl(){

24
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java
View File

@ -1,6 +1,5 @@
package com.muyu.cloud.etl.service.impl; 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.ProductService;
import com.muyu.cloud.etl.service.SourceService; import com.muyu.cloud.etl.service.SourceService;
import com.muyu.cloud.etl.service.TableInfoService; import com.muyu.cloud.etl.service.TableInfoService;
@ -8,6 +7,7 @@ import com.muyu.domain.DataValue;
import com.muyu.domain.Source; import com.muyu.domain.Source;
import com.muyu.domain.TableInfo; import com.muyu.domain.TableInfo;
import com.muyu.domain.enums.DataType; import com.muyu.domain.enums.DataType;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource; import com.zaxxer.hikari.HikariDataSource;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -173,6 +173,22 @@ public class ProductServiceImpl implements ProductService {
@Override @Override
public int addProduct(Long basicId, Long tableId, DataValue[][] listList) { public int addProduct(Long basicId, Long tableId, DataValue[][] listList) {
Source dataSources = sourceService.getById(basicId);
TableInfo tableInfo = tableInfoService.getById(tableId);
String tableName = tableInfo.getTableName();
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);
log.info("数据源ID的basicId{}值"+basicId); log.info("数据源ID的basicId{}值"+basicId);
log.info("表的主键{}值"+tableId); log.info("表的主键{}值"+tableId);
for (DataValue[] dataValues : listList) { for (DataValue[] dataValues : listList) {
@ -180,10 +196,8 @@ public class ProductServiceImpl implements ProductService {
log.info("里面的所有的值"+dataValue); log.info("里面的所有的值"+dataValue);
} }
} }
Source dataSources = sourceService.getById(basicId);
TableInfo tableInfo = tableInfoService.getById(tableId); // HikariDataSource hikariDataSource = HikariPool.getHikariDataSource(dataSources);
String tableName = tableInfo.getTableName();
HikariDataSource hikariDataSource = HikariPool.getHikariDataSource(dataSources);
ExecutorService executorService = Executors.newFixedThreadPool(8); ExecutorService executorService = Executors.newFixedThreadPool(8);