如何简化项目中重复32次的JDBC代码？求通用优化方案

看到你这段JDBC代码重复了32次，确实太折磨人了！我们可以通过封装通用工具类和参数化业务逻辑来彻底解决这个问题，同时还能修复原代码里的资源泄漏隐患。

第一步：先解决资源泄漏的核心问题 #

原代码里没有关闭Connection、PreparedStatement和ResultSet，这会导致数据库连接泄漏，严重的话会拖垮你的应用。Java 7+的try-with-resources语法可以自动帮我们关闭这些资源，必须用上。

第二步：封装通用JDBC工具类 #

把重复的连接获取、单值查询、结果集处理逻辑抽成工具类，以后所有JDBC操作都可以复用：

import java.sql.*;
import java.util.function.Consumer;

public class JdbcUtils {
    private static final String DATABASE_URL = "你的数据库URL";
    private static final String USERNAME = "你的用户名";
    private static final String PASSWORD = "你的密码";

    // 获取数据库连接
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(DATABASE_URL, USERNAME, PASSWORD);
    }

    // 通用单值查询（比如SUM类的聚合结果）
    public static int querySingleInt(String sql, Object... params) throws SQLException {
        try (Connection conn = getConnection();
             PreparedStatement stmt = conn.prepareStatement(sql)) {
            // 自动填充SQL参数
            for (int i = 0; i < params.length; i++) {
                stmt.setObject(i + 1, params[i]);
            }
            try (ResultSet rs = stmt.executeQuery()) {
                return rs.next() ? rs.getInt(1) : 0; // 无结果时返回默认值，可根据业务调整
            }
        }
    }

    // 通用结果集遍历处理
    public static void processResultSet(String sql, Consumer<ResultSet> processor, Object... params) throws SQLException {
        try (Connection conn = getConnection();
             PreparedStatement stmt = conn.prepareStatement(sql)) {
            for (int i = 0; i < params.length; i++) {
                stmt.setObject(i + 1, params[i]);
            }
            try (ResultSet rs = stmt.executeQuery()) {
                while (rs.next()) {
                    processor.accept(rs);
                }
            }
        }
    }
}

第三步：封装业务逻辑方法 #

把你这段代码里的业务逻辑（查询球队数据、计算四个SUM值）抽成参数化方法，这样32次重复调用只需要传入不同的表名和列名即可：

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

public class TeamStatsService {
    // 传入表名、列名，统一处理球队数据
    public void processTeamStats(String tableName, 
                                 String teamAColumn, 
                                 String teamBColumn, 
                                 String flagColumn,
                                 List<Integer> pointsH) throws SQLException {
        // 1. 遍历结果集，执行你的业务方法
        String selectSql = String.format("SELECT * FROM %s", tableName);
        JdbcUtils.processResultSet(selectSql, rs -> {
            try {
                int teamA = rs.getInt(teamAColumn);
                int teamB = rs.getInt(teamBColumn);
                boolean ID = rs.getBoolean(flagColumn);
                placement(); // 保留你的原业务方法
                place();     // 保留你的原业务方法
            } catch (SQLException e) {
                throw new RuntimeException("处理球队数据失败", e);
            }
        });

        // 2. 批量查询四个SUM值
        String sumSqlTemplate = "SELECT SUM(%s) FROM %s WHERE %s = ?";
        
        int SUMPointsAH = JdbcUtils.querySingleInt(
            String.format(sumSqlTemplate, teamAColumn, tableName, flagColumn),
            true
        );
        int SUMPointsAA = JdbcUtils.querySingleInt(
            String.format(sumSqlTemplate, teamAColumn, tableName, flagColumn),
            false
        );
        int SUMPointsBH = JdbcUtils.querySingleInt(
            String.format(sumSqlTemplate, teamBColumn, tableName, flagColumn),
            true
        );
        int SUMPointsBA = JdbcUtils.querySingleInt(
            String.format(sumSqlTemplate, teamBColumn, tableName, flagColumn),
            false
        );

        // 3. 把结果加入列表
        pointsH.add(SUMPointsAA);
    }

    // 你的原业务方法，保留逻辑即可
    private void placement() {
        // 原业务代码
    }

    private void place() {
        // 原业务代码
    }
}

第四步：调用简化后的代码 #

现在原来的32次重复代码，只需要变成32次简洁的方法调用：

List<Integer> pointsH = new ArrayList<>();
TeamStatsService service = new TeamStatsService();

// 处理明尼苏达队的数据
service.processTeamStats("nfl.minnesota", "MinnvsAt", "AtvsMinn", "MinnvsAtP", pointsH);

// 处理绿湾队的数据
service.processTeamStats("nfl.greenbay", "GreenvsAt", "AtvsGreen", "GreenvsAtP", pointsH);

// ... 剩下30个队的调用，只需要修改参数即可

额外优化建议 #

• 避免SQL注入风险：用String.format拼接表名/列名时，要确保这些参数来自内部配置，不是用户输入的内容。
• 改用连接池：如果项目还没用到连接池，强烈建议用HikariCP这类高性能连接池，比直接用DriverManager更高效、更可靠。
• 统一异常处理：上面的代码把SQLException转为RuntimeException，你可以根据项目的异常处理规范调整，比如自定义业务异常。

内容的提问来源于stack exchange，提问作者Daniel Jantulík