Java中SQL连接的最优使用方案（应对网络波动场景）

我的问题和Stack Overflow上同类问题方向一致，但更具体。我有多个类需要对同一数据库执行查询，但主机偶尔会出现网络连接问题，所以应用得针对这种情况设计。

我没法只创建一次java.sql.Connection，因为连接随时可能中断。执行查询时如果连接中断，我可以接受这个情况。目前最简单的做法是每个查询方法里新建连接，示例代码如下：

public static Profile getProfileBySteamID(long userid) {
    try (Connection connection = DriverManager.getConnection(Globals.dbConnection);
         Statement st = connection.createStatement()) {
        final ResultSet res = st.executeQuery("SELECT " +
                                              "p_id, p_name, p_id_dis, p_uid, " +
                                              "p_lastupd, p_lastservertime, p_roles " +
                                              "FROM profiles WHERE p_uid='" + userid + "'");
        if (!res.next())
            throw new RuntimeException("No such profile");
        long disID = res.getLong("p_id_dis");
        String steamid = res.getString("p_uid");
        return new Profile(steamid, disID);
    } catch (SQLException e) {
        throw new RuntimeException(e);
    }
}

public static Profile getProfileByDisID(long userid) {
    try (Connection connection = DriverManager.getConnection(Globals.dbConnection);
         Statement st = connection.createStatement()) {
        final ResultSet res = st.executeQuery("SELECT " +
                                              "p_id, p_name, p_id_dis, p_uid, " +
                                              "p_lastupd, p_lastservertime, p_roles " +
                                              "FROM profiles WHERE p_id_dis='" + userid + "'");
        if (!res.next())
            throw new RuntimeException("No such profile");
        long disID = res.getLong("p_id_dis");
        String steamid = res.getString("p_uid");
        return new Profile(steamid, disID);
    } catch (SQLException e) {
        throw new RuntimeException(e);
    }
}

// ... 还有大概7个类似的方法

我能接受可能的性能问题（因为查询执行频率不高），但这种重复代码太多，很难提取到私有方法里，代码也不够简洁。

所以我的问题是：如何以最简洁的方式获取java.sql.Statement（或更优的PreparedStatement），尽量避免重复的try-catch语句？是否应该考虑使用ConnectionPool？希望能得到相关解决方案示例，或者ConnectionPool结合PreparedStatement使用的代码示例。

一、先解决重复代码与try-catch冗余问题 #

你当前的核心痛点是重复的连接创建、资源声明和异常处理逻辑，完全可以通过提取通用工具方法来解决，同时必须改用PreparedStatement避免SQL注入（这比Statement更安全，是行业规范）。

1. 通用数据库工具类示例

先写一个封装连接获取、资源管理和异常处理的工具类，把重复逻辑抽出来：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.function.Function;

public class DBUtil {
    // 获取连接的通用方法，统一处理连接异常
    private static Connection getConnection() {
        try {
            return DriverManager.getConnection(Globals.dbConnection);
        } catch (SQLException e) {
            throw new RuntimeException("数据库连接失败", e);
        }
    }

    // 封装查询操作：传入SQL、参数，以及结果集处理逻辑
    public static <T> T executeQuery(String sql, Object[] params, Function<ResultSet, T> resultHandler) {
        try (Connection conn = getConnection();
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            // 设置参数
            if (params != null) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            // 执行查询并处理结果
            try (ResultSet rs = pstmt.executeQuery()) {
                return resultHandler.apply(rs);
            }
        } catch (SQLException e) {
            throw new RuntimeException("查询执行失败", e);
        }
    }
}

2. 改造原有业务方法

用工具类简化后，你的业务方法会变得非常简洁，完全看不到重复的try-catch和连接创建逻辑：

public static Profile getProfileBySteamID(long userid) {
    String sql = "SELECT p_id, p_name, p_id_dis, p_uid, p_lastupd, p_lastservertime, p_roles FROM profiles WHERE p_uid=?";
    return DBUtil.executeQuery(sql, new Object[]{userid}, rs -> {
        if (!rs.next()) {
            throw new RuntimeException("No such profile");
        }
        long disID = rs.getLong("p_id_dis");
        String steamid = rs.getString("p_uid");
        return new Profile(steamid, disID);
    });
}

public static Profile getProfileByDisID(long userid) {
    String sql = "SELECT p_id, p_name, p_id_dis, p_uid, p_lastupd, p_lastservertime, p_roles FROM profiles WHERE p_id_dis=?";
    return DBUtil.executeQuery(sql, new Object[]{userid}, rs -> {
        if (!rs.next()) {
            throw new RuntimeException("No such profile");
        }
        long disID = rs.getLong("p_id_dis");
        String steamid = rs.getString("p_uid");
        return new Profile(steamid, disID);
    });
}

这样所有重复的连接、资源管理、异常处理都被收拢到DBUtil里，业务方法只需要关注SQL和结果转换，代码简洁度直接拉满。

二、关于ConnectionPool的选择 #

虽然你说查询频率不高，但连接池依然是值得考虑的选项：

• 连接池会帮你管理连接的创建、复用和销毁，避免频繁创建物理连接的开销（哪怕频率低，长期来看也更高效）
• 主流连接池（比如HikariCP、Apache Commons DBCP2）都内置了连接有效性检测，会自动剔除失效连接，完美适配你遇到的网络中断场景

HikariCP结合PreparedStatement的示例

1. 先配置HikariCP（可以用代码配置，也可以用properties）：

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

public class DBConfig {
    private static HikariDataSource dataSource;

    static {
        HikariConfig config = new HikariConfig();
        config.setJdbcUrl(Globals.dbConnection);
        // 其他可选配置：用户名、密码、最大连接数、连接超时时间等
        config.setUsername("your_username");
        config.setPassword("your_password");
        config.setMaximumPoolSize(5); // 根据你的并发需求调整
        config.setConnectionTimeout(30000); // 30秒超时
        config.setValidationTimeout(5000); // 连接有效性检测超时
        config.setConnectionTestQuery("SELECT 1"); // 检测连接是否可用的SQL

        dataSource = new HikariDataSource(config);
    }

    public static Connection getConnection() {
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            throw new RuntimeException("获取连接池连接失败", e);
        }
    }
}

2. 修改DBUtil的getConnection方法，改用连接池获取连接：

private static Connection getConnection() {
    return DBConfig.getConnection();
}

之后业务方法不需要任何改动，就能享受到连接池带来的优势：自动复用连接、自动剔除失效连接、更优的性能表现。

总结 #

• 优先通过通用工具类+PreparedStatement解决重复代码和SQL注入问题，这是最直接的优化
• 如果后续查询频率上升，或者想更优雅地处理连接失效问题，直接切换到连接池（比如HikariCP），改动成本极低

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