zhengsl/WholeProcessPlatform
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: 优化了动态数据源识别不到oracle问题

Browse Source
This commit is contained in:
tangwei 2026-09-08 11:51:50 +08:00
parent a472ab2ec7
commit 2598c10cbb
2 changed files with 5 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceController.java
View File

@ -7,7 +7,12 @@ import jakarta.annotation.Resource;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.StatementCallback;
import javax.sql.DataSource; import javax.sql.DataSource;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.*; import java.util.*;
/** /**

19
backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceRegistry.java
View File

@ -55,25 +55,6 @@ public class DynamicDataSourceRegistry {
*/ */
@PostConstruct @PostConstruct
public void init() { public void init() {
try {
List<GenDatasourceConf> configs = loadConfigs();
if (configs.isEmpty()) {
log.info("GEN_DATASOURCE_CONF 表中无已启用的动态数据源配置，跳过注册");
return;
}
int success = 0;
int fail = 0;
for (GenDatasourceConf conf : configs) {
if (tryRegister(conf)) {
success++;
} else {
fail++;
}
}
log.info("动态数据源初始化完成: 成功={}, 失败={}", success, fail);
} catch (Exception e) {
log.error("动态数据源初始化失败（业务主库未就绪，稍后手动刷新即可）: {}", e.getMessage());
}
REGISTRY_EXECUTOR.submit(() -> { REGISTRY_EXECUTOR.submit(() -> {
try { try {
log.info("动态数据源后台初始化开始..."); log.info("动态数据源后台初始化开始...");