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