SQL连接泄漏指的是应用程序从数据库连接池获取连接后，没有按照规范释放连接，导致连接长期被占用无法复用，最终耗尽连接池资源的问题。这类问题在并发较高的业务场景中更容易出现，且初期表现不明显，等到连接池耗尽时才会引发大量业务报错。
SQL连接泄漏的典型表现
当应用出现SQL连接泄漏时，通常会有以下明显特征：
- 应用日志中频繁出现获取数据库连接超时的报错，提示连接池已满
- 数据库侧查看活跃连接数持续升高，且很多连接的空闲时间远超正常业务耗时
- 应用响应速度逐渐变慢，重启应用后短时间内恢复正常，过一段时间又复现问题
- 数据库连接池监控指标中，已借出连接数长期接近最大连接数，没有回落趋势
连接未释放的常见原因
1. 代码中没有正确关闭连接
这是最常见的原因，比如在使用Connection对象后，没有执行关闭操作，或者关闭操作放在了可能不执行的代码分支中。
2. 异常场景下连接未释放
如果获取连接后执行SQL的过程中抛出异常，而关闭连接的逻辑没有放在finally块中，就会导致连接泄漏。
3. 连接池配置不合理
比如连接池的最大连接数设置过小，或者连接回收机制配置不当，导致空闲连接没有被及时回收，也会表现为类似连接泄漏的问题。
4. 长事务占用连接
如果一个事务长时间不提交或者回滚，对应的连接会一直被占用，无法回到连接池供其他请求使用。
SQL连接泄漏的排查步骤
第一步：确认是否存在连接泄漏
首先可以通过数据库命令查看当前的连接状态，以MySQL为例，执行以下命令查看活跃连接：
-- 查看当前所有连接的信息，包括执行时间、状态等 SHOW PROCESSLIST;
如果发现有大量连接的Time字段数值很大，且状态为Sleep，基本可以确定存在连接未释放的问题。
第二步：定位泄漏的连接来源
如果是Java应用，可以通过JVM工具获取连接池的详细信息，比如使用jstack导出线程栈，查看哪些线程持有了Connection对象没有释放。另外也可以在连接池配置中开启连接泄漏检测，以HikariCP为例，配置如下：
// HikariCP连接池配置，开启泄漏检测，连接被借出超过10秒未归还则打印日志
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/test_db");
config.setUsername("root");
config.setPassword("test_pwd");
// 设置连接泄漏检测阈值，单位毫秒
config.setLeakDetectionThreshold(10000);
HikariDataSource dataSource = new HikariDataSource(config);
开启后如果连接被借出超过阈值未归还，会在日志中打印对应的线程栈，直接定位到泄漏的代码位置。
第三步：分析代码逻辑修复问题
根据定位到的代码位置，检查连接关闭的逻辑是否符合规范，正确的关闭方式应该如下：
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = dataSource.getConnection();
pstmt = conn.prepareStatement("SELECT * FROM user WHERE id = ?");
pstmt.setInt(1, 1);
rs = pstmt.executeQuery();
// 处理查询结果
} catch (SQLException e) {
// 异常处理逻辑
e.printStackTrace();
} finally {
// 逆序关闭资源，先关闭ResultSet，再关闭PreparedStatement，最后关闭Connection
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (pstmt != null) {
try {
pstmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
如果使用Java 7及以上的版本，也可以使用try-with-resources语法简化资源关闭逻辑，避免遗漏：
// try-with-resources会自动关闭实现了AutoCloseable接口的资源
try (Connection conn = dataSource.getConnection();
PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM user WHERE id = ?");
ResultSet rs = pstmt.executeQuery()) {
pstmt.setInt(1, 1);
// 处理查询结果
} catch (SQLException e) {
e.printStackTrace();
}
连接未释放问题的规避方案
- 统一使用
try-with-resources或者finally块管理连接、语句、结果集的关闭，避免手动关闭遗漏 - 合理设置连接池参数，开启连接泄漏检测机制，及时发现问题
- 避免长事务，尽量缩短事务的执行时间，减少连接占用时长
- 定期监控连接池的活跃连接数、借出连接数等指标，设置告警阈值，提前发现问题
- 代码评审时重点关注数据库资源的使用逻辑，检查是否存在连接未释放的风险