如何在Hibernate中执行MySQL批量更新事务查询？

这个问题我之前也碰到过，Hibernate对单条SQL查询里的多语句支持很严格，而且手动写START TRANSACTION和COMMIT也会和它自身的事务管理机制冲突，这就是你报“Nested Query Not Supported”的原因。下面给你几个可行的解决方案，按推荐程度排序：

方案一：合并为单条UPDATE语句（最推荐） #

把多个分散的UPDATE合并成一条，用CASE WHEN逻辑批量更新，这样既减少数据库交互次数，又符合Hibernate的单语句执行要求。

修改后的SQL语句：

UPDATE home 
SET currentSeq = CASE resId 
    WHEN '6hiuxhqkw4s1bta9a' THEN 2
    WHEN 'hpvihvzk0vainpkgg' THEN 4
    WHEN 'krfswe6wohjtugmtd' THEN 6
    WHEN 'tcybuiuulkju5wjre' THEN 3
    WHEN 'sgs4gr4v6aepuwdgq' THEN 7
END
WHERE resId IN ('6hiuxhqkw4s1bta9a', 'hpvihvzk0vainpkgg', 'krfswe6wohjtugmtd', 'tcybuiuulkju5wjre', 'sgs4gr4v6aepuwdgq')

对应的Hibernate代码：

String batchUpdateSql = "UPDATE home SET currentSeq = CASE resId WHEN '6hiuxhqkw4s1bta9a' THEN 2 WHEN 'hpvihvzk0vainpkgg' THEN 4 WHEN 'krfswe6wohjtugmtd' THEN 6 WHEN 'tcybuiuulkju5wjre' THEN 3 WHEN 'sgs4gr4v6aepuwdgq' THEN 7 END WHERE resId IN ('6hiuxhqkw4s1bta9a', 'hpvihvzk0vainpkgg', 'krfswe6wohjtugmtd', 'tcybuiuulkju5wjre', 'sgs4gr4v6aepuwdgq')";

Query q = sessionFactory.getCurrentSession().createSQLQuery(batchUpdateSql);
q.executeUpdate();

注意：如果你的项目用了Spring，记得给方法加上@Transactional注解，Hibernate会自动帮你管理事务的开启和提交；如果是原生Hibernate，需要手动开启和提交事务（参考方案二的事务代码）。

方案二：利用Hibernate事务批量执行单条UPDATE #

如果不想合并SQL，可以在Hibernate的事务上下文里逐个执行UPDATE语句，让Hibernate来管理事务生命周期，不要手动写START TRANSACTION和COMMIT。

示例代码：

Session session = sessionFactory.getCurrentSession();
Transaction tx = session.beginTransaction();

try {
    // 通用的UPDATE模板
    String updateTemplate = "UPDATE home SET currentSeq = ? WHERE resId = ?";
    
    // 准备所有需要更新的参数对
    List<Object[]> updateParams = Arrays.asList(
        new Object[]{2, "6hiuxhqkw4s1bta9a"},
        new Object[]{4, "hpvihvzk0vainpkgg"},
        new Object[]{6, "krfswe6wohjtugmtd"},
        new Object[]{3, "tcybuiuulkju5wjre"},
        new Object[]{7, "sgs4gr4v6aepuwdgq"}
    );
    
    // 循环执行每个UPDATE
    for (Object[] params : updateParams) {
        Query query = session.createSQLQuery(updateTemplate);
        query.setParameter(0, params[0]);
        query.setParameter(1, params[1]);
        query.executeUpdate();
    }
    
    // 提交事务
    tx.commit();
} catch (Exception e) {
    // 出错回滚
    tx.rollback();
    throw new RuntimeException("批量更新失败", e);
}

方案三：开启JDBC多语句支持（不推荐） #

如果一定要保持原来的多语句格式，需要修改数据库连接URL，开启MySQL的allowMultiQueries参数，同时去掉手动的事务控制语句（交给Hibernate管理）。

1. 修改JDBC连接URL，添加参数：

jdbc:mysql://localhost:3306/your_db?useSSL=false&allowMultiQueries=true

2. 修改Hibernate代码，去掉START TRANSACTION和COMMIT：

String queryToBeUpdate = "UPDATE home SET currentSeq = 2 WHERE resId = '6hiuxhqkw4s1bta9a';\n" +
                         "UPDATE home SET currentSeq = 4 WHERE resId = 'hpvihvzk0vainpkgg';\n" +
                         "UPDATE home SET currentSeq = 6 WHERE resId = 'krfswe6wohjtugmtd';\n" +
                         "UPDATE home SET currentSeq = 3 WHERE resId = 'tcybuiuulkju5wjre';\n" +
                         "UPDATE home SET currentSeq = 7 WHERE resId = 'sgs4gr4v6aepuwdgq';";

Query q = sessionFactory.getCurrentSession().createSQLQuery(queryToBeUpdate);
q.executeUpdate();

注意：这个方案存在SQL注入风险，而且不符合Hibernate的最佳实践，除非特殊情况不建议使用。

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