From 2598c10cbb11c6aaeabf6d9759d8be11136ebbf6 Mon Sep 17 00:00:00 2001 From: tangwei Date: Tue, 8 Sep 2026 11:51:50 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E4=BA=86=E5=8A=A8?= =?UTF-8?q?=E6=80=81=E6=95=B0=E6=8D=AE=E6=BA=90=E8=AF=86=E5=88=AB=E4=B8=8D?= =?UTF-8?q?=E5=88=B0oracle=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../DynamicDataSourceController.java | 5 +++++ .../datasource/DynamicDataSourceRegistry.java | 19 ------------------- 2 files changed, 5 insertions(+), 19 deletions(-) diff --git a/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceController.java b/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceController.java index 43ae5b35..4b68eb40 100644 --- a/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceController.java +++ b/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceController.java @@ -7,7 +7,12 @@ import jakarta.annotation.Resource; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.jdbc.core.StatementCallback; + import javax.sql.DataSource; +import java.sql.ResultSet; +import java.sql.ResultSetMetaData; import java.util.*; /** diff --git a/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceRegistry.java b/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceRegistry.java index fbfcaab5..d39ccce2 100644 --- a/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceRegistry.java +++ b/backend/src/main/java/com/yfd/platform/datasource/DynamicDataSourceRegistry.java @@ -55,25 +55,6 @@ public class DynamicDataSourceRegistry { */ @PostConstruct public void init() { - try { - List 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(() -> { try { log.info("动态数据源后台初始化开始...");