SpringBoot中使用IBM DB2ConnectionPoolDataSource后如何关闭连接池

问题根源分析 #

1. 原代码错误：每次获取连接时新建DB2ConnectionPoolDataSource，完全未利用连接池的复用机制；手动new PooledConnection的方式错误，导致每次都是新的物理连接且无法归还，连接数持续增长。
2. 连接关闭时机错误：在getConnection方法内提前关闭连接，导致业务代码拿到的是已关闭的连接，抛出SQLException。
3. 新配置空指针原因：手动new PooledConnection未关联数据源，调用getDb2Connection()返回null，后续执行close()时触发空指针。

正确实现步骤 #

1. 配置DB2连接池Bean #

使用Spring配置类正确初始化DB2ConnectionPoolDataSource，注入必要连接参数并设置连接池核心参数：

@Configuration
public class DB2DataSourceConfig {

    @Value("${db2.driver-type}")
    private int driverType;

    @Value("${db2.server-name}")
    private String serverName;

    @Value("${db2.port}")
    private int port;

    @Value("${db2.database-name}")
    private String databaseName;

    @Value("${db2.user}")
    private String user;

    @Value("${db2.password}")
    private String password;

    @Bean
    public DB2ConnectionPoolDataSource db2ConnectionPoolDataSource() {
        DB2ConnectionPoolDataSource dataSource = new DB2ConnectionPoolDataSource();
        // 基础连接参数
        dataSource.setDriverType(driverType);
        dataSource.setServerName(serverName);
        dataSource.setPortNumber(port);
        dataSource.setDatabaseName(databaseName);
        dataSource.setUser(user);
        dataSource.setPassword(password);
        // 连接池参数配置
        dataSource.setMaxPoolSize(20); // 最大连接数
        dataSource.setMinPoolSize(5);  // 最小空闲连接数
        dataSource.setIdleTimeout(300); // 空闲连接超时时间（秒）
        return dataSource;
    }
}

2. 正确获取连接的工具类 #

通过数据源获取池化连接，禁止手动new PooledConnection：

@Component
public class DB2ConnectionManager {

    private final DB2ConnectionPoolDataSource dataSource;

    // 构造注入（替代@Autowired，更符合Spring规范）
    public DB2ConnectionManager(DB2ConnectionPoolDataSource dataSource) {
        this.dataSource = dataSource;
    }

    public Connection getConnection() throws SQLException {
        // 从连接池获取池化连接，再拿到可用的Connection实例
        PooledConnection pooledConnection = dataSource.getPooledConnection();
        return pooledConnection.getConnection();
    }
}

3. 业务代码中正确使用连接 #

使用try-with-resources语法，确保所有查询执行完成后自动归还连接到池（注意：这里的close()不是关闭物理连接，而是归还到连接池）：

@Service
public class BusinessService {

    private final DB2ConnectionManager connectionManager;

    public BusinessService(DB2ConnectionManager connectionManager) {
        this.connectionManager = connectionManager;
    }

    public void executeMultiQueries() throws SQLException {
        // try-with-resources自动管理连接生命周期，执行完毕后自动归还
        try (Connection conn = connectionManager.getConnection()) {
            // 执行第一个查询
            try (PreparedStatement stmt1 = conn.prepareStatement("SELECT * FROM table1")) {
                try (ResultSet rs1 = stmt1.executeQuery()) {
                    // 处理查询结果
                    while (rs1.next()) {
                        // 读取数据逻辑
                    }
                }
            }

            // 执行第二个查询
            try (PreparedStatement stmt2 = conn.prepareStatement("SELECT * FROM table2")) {
                try (ResultSet rs2 = stmt2.executeQuery()) {
                    // 处理查询结果
                }
            }

            // 所有查询完成后，try-with-resources自动调用conn.close()，将连接归还到池
        }
    }
}

关键注意事项 #

• 连接池核心逻辑：DB2ConnectionPoolDataSource维护的连接池会自动复用连接，调用Connection.close()只是将连接归还到池，而非关闭物理连接。
• 禁止提前关闭连接：绝对不能在getConnection方法内关闭连接，必须在业务代码用完连接后再归还。
• 强制使用try-with-resources：确保异常场景下连接也能被归还，彻底解决连接泄漏导致的连接数持续增长问题。

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