Quarkus生产环境运行时动态修改JDBC数据源URL方案咨询

核心需求 #

• 必须通过编程方式实现，禁止手动停服修改配置后重启
• 切换连接时允许短暂断开连接
• 不适用多租户方案：同一时间仅需连接一个数据库，其余10-20种连接组合仅在运行时知晓
• 方案需适配生产环境，不能依赖dev/test配置的热重载特性

当前配置与尝试进展 #

现有application.properties配置（生产环境） #

...
%prod.quarkus.datasource.jdbc.driver=com.microsoft.sqlserver.jdbc.SQLServerDriver
%prod.quarkus.datasource.jdbc.url=jdbc:sqlserver://${SQL_DB_URL:localhost}:${SQL_DB_PORT:1433};databaseName=${SQL_DB_NAME:db};encrypt=${SQL_DB_ENCRYPT:false};
%prod.quarkus.datasource.jdbc.additional-jdbc-properties.authenticationScheme=${SQL_AUTHENTICATIONSCHEME:NTLM}
%prod.quarkus.datasource.jdbc.additional-jdbc-properties.trustservercertificate=${SQL_DB_TRUST_SERVER_CERT:true}
%prod.quarkus.datasource.jdbc.additional-jdbc-properties.integratedsecurity=${SQL_DB_INTEGRATED_SECURITY:true}
...

尝试过的无效方案 #

1. 修改@ConfigProperty注入的变量
   代码中修改注入的配置变量后，打印的新连接字符串正确，但应用仍连接旧数据库。原因是@ConfigProperty注入的是初始化时的配置快照，修改变量不会影响已初始化的数据源实例。

   @ApplicationScoped
   public class ConnectionString {  
       @ConfigProperty(name = "quarkus.datasource.jdbc.url")
       public String quarkusDataSourceString;
       @ConfigProperty(name = "SQL_DB_URL", defaultValue = "localhost")
       String dbUrlEnvVar;
       // 其他配置变量...
   
       public void SetNewConnectionString() {
           // 构建新连接字符串并修改变量，但无效果
           dbUrlEnvVar = newServ;
           quarkusDataSourceString = newString;
       }
   }
   

2. 直接修改HikariDataSource的JdbcUrl
   尝试获取数据源实例修改连接地址，但未刷新连接池，旧连接仍在使用：

   DataSource dataSource = Arc.container().instance(DataSource.class).get();
   String newJdbcUrl = "jdbc:sqlserver://localhost:1433;databaseName=db2;encrypt:false;"
   dataSource.setJdbcUrl(newJdbcUrl);
   

3. 尝试覆盖默认EntityManager连接信息：未成功。

可行解决方案 #

方案1：操作HikariDataSource并强制刷新连接池 #

Quarkus默认使用HikariCP作为连接池，直接操作其实例，关闭旧连接池后重新初始化新配置：

import com.zaxxer.hikari.HikariDataSource;
import io.quarkus.arc.Arc;
import jakarta.enterprise.context.ApplicationScoped;

@ApplicationScoped
public class DataSourceSwitcher {

    public void switchToNewDatabase(String newJdbcUrl) {
        // 获取默认Hikari数据源实例
        HikariDataSource dataSource = Arc.container().instance(HikariDataSource.class).get();
        
        // 关闭当前连接池（销毁所有旧连接）
        dataSource.close();
        
        // 重新配置核心参数
        dataSource.setJdbcUrl(newJdbcUrl);
        // 同步更新其他JDBC属性（根据实际需求调整）
        dataSource.addDataSourceProperty("authenticationScheme", "NTLM");
        dataSource.addDataSourceProperty("trustservercertificate", "true");
        dataSource.addDataSourceProperty("integratedsecurity", "true");
        
        // 重新初始化连接池
        try {
            dataSource.initialize();
        } catch (Exception e) {
            throw new RuntimeException("切换数据源失败", e);
        }
    }
}

说明：切换过程会短暂断开连接，需确保此时无未完成的数据库操作；初始化失败需添加告警或回滚逻辑。

方案2：自定义动态数据源Bean #

完全掌控数据源生命周期，切换时创建全新连接池：

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.enterprise.inject.Produces;
import jakarta.inject.Singleton;
import javax.sql.DataSource;

@ApplicationScoped
public class DynamicDataSourceProvider {

    private HikariDataSource currentDataSource;

    @Produces
    @Singleton
    public DataSource getDataSource() {
        if (currentDataSource == null) {
            // 初始化默认数据源（从配置读取参数）
            HikariConfig config = new HikariConfig();
            config.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
            config.setJdbcUrl("jdbc:sqlserver://localhost:1433;databaseName=db;encrypt=false;");
            config.addDataSourceProperty("authenticationScheme", "NTLM");
            config.addDataSourceProperty("trustservercertificate", "true");
            config.addDataSourceProperty("integratedsecurity", "true");
            // 配置连接池参数（可从@ConfigProperty注入）
            config.setMaximumPoolSize(10);
            config.setMinimumIdle(2);
            currentDataSource = new HikariDataSource(config);
        }
        return currentDataSource;
    }

    public void switchDataSource(String newJdbcUrl, String newDbName) {
        // 关闭旧数据源
        if (currentDataSource != null) {
            currentDataSource.close();
        }
        // 构建新数据源配置
        HikariConfig newConfig = new HikariConfig();
        newConfig.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
        newConfig.setJdbcUrl(newJdbcUrl);
        newConfig.addDataSourceProperty("databaseName", newDbName);
        newConfig.addDataSourceProperty("encrypt", "false");
        newConfig.addDataSourceProperty("authenticationScheme", "NTLM");
        newConfig.addDataSourceProperty("trustservercertificate", "true");
        newConfig.addDataSourceProperty("integratedsecurity", "true");
        // 复用原有连接池参数
        newConfig.setMaximumPoolSize(currentDataSource.getMaximumPoolSize());
        newConfig.setMinimumIdle(currentDataSource.getMinimumIdle());
        
        currentDataSource = new HikariDataSource(newConfig);
    }
}

说明：需确保所有依赖DataSource的组件（如EntityManager）都使用该自定义Bean；切换后旧连接池会被销毁，新连接池立即生效。

配套注意事项 #

• 事务与一致性：切换前需确保无正在执行的数据库事务，或做好事务回滚处理。
• JPA/Hibernate适配：使用JPA时，切换数据源后需刷新EntityManagerFactory：

  import jakarta.persistence.EntityManagerFactory;
  import io.quarkus.arc.Arc;
  
  // 切换数据源后调用
  EntityManagerFactory emf = Arc.container().instance(EntityManagerFactory.class).get();
  emf.close();
  // Quarkus会自动重新创建EntityManagerFactory，绑定新数据源
  

• 生产监控：添加数据源连通性检查、切换告警，确保切换过程可观测。

内容的提问来源于stack exchange，提问作者ABDev