Java中如何在单语句中执行多SQL查询（非存储过程方案）

你从Table1的SQLColumn字段中读取到以分号分隔的多条SQL语句（例如包含SET声明、变量定义、查询语句的组合脚本），但常规PreparedStatement仅支持单次执行单条语句，无法直接处理这类多语句场景。以下是两种无需存储过程的解决方案：

方案1：使用Statement执行多语句脚本 #

Statement对象原生支持执行包含多条语句的SQL脚本，并且可以遍历处理所有结果集和更新计数。

代码示例 #

Connection conn = ...; // 已初始化的数据库连接
String multiSql = "set nocount on;select * from table2;"; // 从Table1.SQLColumn读取的完整多语句字符串

try (Statement stmt = conn.createStatement()) {
    boolean hasResult = stmt.execute(multiSql);
    
    // 遍历处理所有结果集和更新操作
    do {
        if (hasResult) {
            // 处理查询结果集
            try (ResultSet rs = stmt.getResultSet()) {
                while (rs.next()) {
                    // 根据业务需求读取列数据，例如：
                    // String value = rs.getString("column_name");
                }
            }
        } else {
            int updateCount = stmt.getUpdateCount();
            if (updateCount != -1) {
                // 处理更新/插入/删除操作的行数，例如记录日志
                // System.out.println("受影响行数：" + updateCount);
            }
        }
        hasResult = stmt.getMoreResults();
    } while (hasResult || stmt.getUpdateCount() != -1);
} catch (SQLException e) {
    // 异常处理逻辑，例如回滚事务、打印错误信息
    e.printStackTrace();
}

方案2：拆分SQL语句后用PreparedStatement逐个执行 #

如果你的场景必须使用PreparedStatement（例如需要参数化查询），可以将多语句字符串按分号拆分后，逐个执行单条语句。注意：此方案仅适用于SQL语句中没有嵌套分号（如字符串常量内的分号）的场景。

代码示例 #

Connection conn = ...;
String multiSql = "declare item nvarchar(10); select item=data from table2;";

// 拆分语句并过滤空串（处理末尾分号导致的空条目）
String[] rawStatements = multiSql.split(";");
List<String> validSqls = new ArrayList<>();
for (String sql : rawStatements) {
    String trimmedSql = sql.trim();
    if (!trimmedSql.isEmpty()) {
        validSqls.add(trimmedSql);
    }
}

// 逐个执行单条SQL语句
for (String sql : validSqls) {
    try (PreparedStatement ps = conn.prepareStatement(sql)) {
        boolean hasResult = ps.execute();
        if (hasResult) {
            try (ResultSet rs = ps.getResultSet()) {
                // 处理当前语句的结果集
            }
        } else {
            int updateCount = ps.getUpdateCount();
            // 处理当前语句的更新计数
        }
    } catch (SQLException e) {
        e.printStackTrace();
        // 可选：是否中断后续语句执行
        // break;
    }
}

注意事项 #

• 数据库兼容性：部分数据库需要额外配置支持多语句，例如MySQL需在连接URL中添加allowMultiQueries=true参数；SQL Server默认支持，但需确保执行用户具备相应权限。
• 事务控制：如果需要保证多条语句的原子性，需手动开启事务，在所有语句执行成功后提交，执行失败则回滚。
• 安全风险：确保SQLColumn中的SQL语句来源可信，避免SQL注入攻击。

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