Spring Boot 如何在保留主数据库连接的同时连接外部数据库

第一步：引入必要依赖 #

首先在项目pom.xml（Maven项目）或build.gradle（Gradle项目）中引入JDBC核心依赖，以及常用数据库驱动（提前覆盖外部对接可能用到的数据库类型）：

<!-- Spring Boot JDBC 核心依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!-- MySQL驱动，根据需要引入其他数据库驱动如PostgreSQL、Oracle等 -->
<dependency>
    <groupId>com.mysql</groupId>
    <artifactId>mysql-connector-j</artifactId>
    <scope>runtime</scope>
</dependency>

第二步：封装动态数据源构建逻辑 #

我们不需要将外部数据库配置写死在项目配置文件中，直接通过存储的凭证动态构造数据源即可，推荐使用Hikari连接池管理连接，避免频繁创建销毁连接浪费资源：

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import javax.sql.DataSource;

public class DynamicDataSourceUtil {
    public static DataSource createDataSource(String url, String username, String password, String driverClassName) throws ClassNotFoundException {
        // 加载指定数据库驱动
        Class.forName(driverClassName);
        HikariConfig config = new HikariConfig();
        config.setJdbcUrl(url);
        config.setUsername(username);
        config.setPassword(password);
        config.setDriverClassName(driverClassName);
        // 连接池优化配置，避免占满外部数据库的连接资源
        config.setMinimumIdle(1);
        config.setMaximumPoolSize(3);
        config.setConnectionTimeout(3000);
        return new HikariDataSource(config);
    }
}

第三步：执行动态删除逻辑 #

通过JdbcTemplate执行删除操作，不需要关心表的其他字段，仅需要传入待清理的表名、日期字段名、过期阈值即可：

import org.springframework.jdbc.core.JdbcTemplate;
import javax.sql.DataSource;
import java.time.LocalDateTime;

public class ExternalDbCleanService {
    public int cleanExpiredRecords(String tableName, String dateColumn, LocalDateTime expireThreshold, DataSource externalDataSource) {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(externalDataSource);
        // 表名和字段名无法通过参数绑定，使用前务必做合法性校验，避免SQL注入
        String deleteSql = String.format("DELETE FROM %s WHERE %s < ?", tableName, dateColumn);
        // 执行删除，返回被删除的行数
        return jdbcTemplate.update(deleteSql, expireThreshold);
    }
}

注意事项 #

• 若待删除数据量较大，建议分批删除（比如每次删除1000条，循环执行直到无符合条件的记录），避免长时间锁表影响外部服务的正常业务
• 执行删除前可以先执行SELECT COUNT(*) FROM 表名 WHERE 日期字段 < 阈值确认待删除行数，避免误操作
• 若后续不需要再连接该外部数据库，可以手动关闭连接池释放资源：将DataSource强转为HikariDataSource后调用close()方法即可
• 做好异常捕获，连接失败、SQL执行出错等场景要保留日志方便排查问题

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