JavaFX结合JDBC实现MySQL多条件数据过滤查询异常排查

云上老周

2026-9-2

问题说明

开发场景：基于JavaFX框架通过JDBC连接MySQL数据库开发漫画数据管理功能，需要实现多维度数据过滤，除漫画名称外，支持按刊号、变体版本、签名属性、所属出版社、装帧格式、藏品来源、出版年份、编剧、绘师等多个字段筛选数据。
现存问题：代码中编写了10条独立的单条件SQL查询语句，存入数组循环执行时仅第一条语句可正常运行，其余语句执行抛出SQLException，仅单条语句单独执行时可正常工作。
预期目标：实现单条SQL语句覆盖所有过滤条件的筛选逻辑，代码中已留存全条件拼接SQL的注释版本待优化。

问题根因

循环执行多条独立SELECT的逻辑本身不符合多维度筛选需求：多条单条件查询返回的是「满足任意单个条件」的结果并集，而业务需要的是「同时满足所有已填筛选条件」的结果交集，逻辑方向错误。
多语句循环执行报错的核心原因：DBManager类的数据库操作方法大概率复用了单例的Statement/连接资源，执行第一条SQL后未正确释放ResultSet、Statement资源，执行第二条SQL时出现资源占用冲突抛出异常。
注释留存的全条件拼接SQL存在三个硬伤：
- 直接字符串拼接参数存在SQL注入风险
- 未处理空参数场景：如果用户未填写某个筛选项（参数为空），SQL会强制匹配字段值为空的记录，导致查询结果不符合预期
- 存在字段名笔误：SQL中写的nomGuionista、nomDibujante和表实际字段nomGuionistas、nomDibujantes不匹配，执行会报未知列错误
原结果集遍历逻辑存在bug：使用do-while遍历ResultSet时，若查询无匹配结果，会在指针未指向有效行时直接调用rs.getString()抛出异常。

可行解决方案

核心思路：保留单条基础查询SQL，动态拼接非空参数对应的过滤条件，使用PreparedStatement预编译传参，通过try-with-resources自动释放数据库资源，从根源解决上述所有问题。

修正后的可直接运行的代码如下：

public static Comics[] filtadroBBDD(String nombreC, String numeroC, String varianteC, String firmaC,
                                    String nomEditorialC, String formatoC, String procedenciaC, String fechaC, String guionistaC,
                                    String nomDibujanteC) {
    reiniciarBBDD();
    // 基础SQL加1=1恒真条件，后续拼接AND条件时无需额外判断是否为第一个条件
    StringBuilder sqlBuilder = new StringBuilder("SELECT * FROM comicsbbdd WHERE 1=1");
    // 按拼接顺序存储非空的过滤参数值
    List<String> validParams = new ArrayList<>();

    // 逐个判断参数是否有效（非null、非空串），有效则拼接对应查询条件
    if (nombreC != null && !nombreC.trim().isEmpty()) {
        sqlBuilder.append(" AND nomComic = ?");
        validParams.add(nombreC.trim());
    }
    if (numeroC != null && !numeroC.trim().isEmpty()) {
        sqlBuilder.append(" AND numComic = ?");
        validParams.add(numeroC.trim());
    }
    if (varianteC != null && !varianteC.trim().isEmpty()) {
        sqlBuilder.append(" AND nomVariante = ?");
        validParams.add(varianteC.trim());
    }
    if (firmaC != null && !firmaC.trim().isEmpty()) {
        sqlBuilder.append(" AND firma = ?");
        validParams.add(firmaC.trim());
    }
    if (nomEditorialC != null && !nomEditorialC.trim().isEmpty()) {
        sqlBuilder.append(" AND nomEditorial = ?");
        validParams.add(nomEditorialC.trim());
    }
    if (formatoC != null && !formatoC.trim().isEmpty()) {
        sqlBuilder.append(" AND formato = ?");
        validParams.add(formatoC.trim());
    }
    if (procedenciaC != null && !procedenciaC.trim().isEmpty()) {
        sqlBuilder.append(" AND procedencia = ?");
        validParams.add(procedenciaC.trim());
    }
    if (fechaC != null && !fechaC.trim().isEmpty()) {
        sqlBuilder.append(" AND anioPubli = ?");
        validParams.add(fechaC.trim());
    }
    if (guionistaC != null && !guionistaC.trim().isEmpty()) {
        sqlBuilder.append(" AND nomGuionistas = ?");
        validParams.add(guionistaC.trim());
    }
    if (nomDibujanteC != null && !nomDibujanteC.trim().isEmpty()) {
        sqlBuilder.append(" AND nomDibujantes = ?");
        validParams.add(nomDibujanteC.trim());
    }

    // try-with-resources会在代码块执行结束后自动关闭连接、语句、结果集，避免资源泄漏和冲突
    try (Connection conn = DBManager.getConnection();
         PreparedStatement pstmt = conn.prepareStatement(sqlBuilder.toString())) {
        // 按顺序给预编译语句的占位符设置参数值
        for (int i = 0; i < validParams.size(); i++) {
            pstmt.setString(i + 1, validParams.get(i));
        }
        ResultSet rs = pstmt.executeQuery();
        // 先移动指针再读取数据，避免空结果集报错
        while (rs.next()) {
            String nombreCom = rs.getString("nomComic");
            String numeroCom = rs.getString("numComic");
            String varianteCom = rs.getString("nomVariante");
            String firmaCom = rs.getString("firma");
            String editorialCom = rs.getString("nomEditorial");
            String formatoCom = rs.getString("formato");
            String procedenciaCom = rs.getString("procedencia");
            String fechaCom = rs.getString("anioPubli");
            String guionistaCom = rs.getString("nomGuionistas");
            String dibujanteCom = rs.getString("nomDibujantes");

            FiltrolistComics.add(new Comics(nombreCom, numeroCom, varianteCom, firmaCom, editorialCom,
                    formatoCom, procedenciaCom, fechaCom, guionistaCom, dibujanteCom));
        }
    } catch (SQLException ex) {
        System.err.println("漫画数据过滤查询失败：" + ex.getMessage());
        ex.printStackTrace();
    }
    return FiltrolistComics.toArray(new Comics[0]);
}

代码适配前端筛选的交互逻辑：用户填写了哪个筛选项，对应条件就生效，未填写的筛选项不参与过滤，不需要强制所有字段都传值。
废弃了多SQL循环执行的逻辑，仅执行一次数据库查询，性能远高于多次查询，也不会出现资源冲突报错。
使用PreparedStatement预编译传参，彻底避免SQL注入风险。
修复了原代码中字段名笔误、结果集遍历逻辑错误、资源未正确释放的问题。

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