JPA CriteriaDelete与in子查询：确保数据操作正确执行

本文旨在解决jpa `criteriadelete`结合`in`表达式和子查询时，数据删除操作不生效的问题。核心原因在于执行dml操作（如删除）后，必须显式调用`javax.persistence.query`对象的`executeupdate()`方法，而非仅创建查询。文章将通过详细解析和示例代码，指导开发者正确执行此类批量删除操作，并强调相关的注意事项。

JPA CriteriaDelete操作不生效的常见原因

在使用JPA的Criteria API进行批量删除（CriteriaDelete）时，开发者可能会遇到一个常见的问题：即使构建了正确的查询逻辑，数据却未被删除。这尤其容易发生在涉及in表达式和子查询的复杂场景中。

例如，以下代码片段展示了尝试使用CriteriaDelete结合in表达式和子查询来删除实体Y的常见尝试：

// 假设 orphan, one_type, other_type, key, givenList 已定义
CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder();
CriteriaDelete criteriaDelete = criteriaBuilder.createCriteriaDelete(orphan);

Root deleteRoot = criteriaDelete.from(one_type); // 主查询的根实体

// 构建子查询，用于in表达式
CriteriaQuery criteriaQuery = criteriaBuilder.createQuery(other_type); // 子查询的返回类型
Root queryRoot = criteriaQuery.from(other_type); // 子查询的根实体
criteriaQuery.select(queryRoot.get(key)); // 子查询选择的字段
criteriaQuery.where(queryRoot.get("id").in(givenList)); // 子查询的过滤条件

// 将子查询的结果列表用于主删除查询的in表达式
entityManager.createQuery(criteriaDelete
        .where(deleteRoot.in(entityManager.createQuery(criteriaQuery).getResultList())));

尽管上述代码成功构建了一个Query对象，但当这段代码执行后，数据库中的数据并不会受到任何影响。这是因为，仅仅创建Query对象并不能触发实际的数据库操作。

解决方案：显式调用 executeUpdate()

JPA规范明确指出，对于数据操作语言（DML）操作，如批量删除（CriteriaDelete）或批量更新（CriteriaUpdate），在创建javax.persistence.Query对象后，必须显式调用其executeUpdate()方法来执行实际的数据库操作。

entityManager.createQuery(...)方法返回的是一个Query接口的实例，它代表了我们定义的数据库操作。但这个操作本身是惰性执行的，只有当我们明确告诉JPA去执行它时，它才会真正与数据库进行交互。对于查询操作（SELECT），我们通常调用getResultList()或getSingleResult()来获取结果，这些方法会触发查询执行。但对于DELETE或UPDATE操作，我们需要调用executeUpdate()。

LangChain

一个开源框架，用于构建基于大型语言模型（LLM）的应用程序。

下载

正确执行 CriteriaDelete 的步骤：

1. 构建 CriteriaDelete 对象： 定义要删除的实体类型和删除条件。
2. 构建子查询（如果需要）： 创建独立的CriteriaQuery来获取in表达式所需的值列表。
3. 执行子查询并获取结果： 使用entityManager.createQuery(subCriteriaQuery).getResultList()获取子查询的结果列表。
4. 将结果应用于主 CriteriaDelete 的 where 子句： 使用deleteRoot.get("someField").in(resultList)构建删除条件。
5. 创建主 Query 对象： 使用entityManager.createQuery(criteriaDelete)。
6. 调用 executeUpdate()： 在创建的Query对象上调用executeUpdate()方法，触发数据库删除操作。

修正后的示例代码：

为了更清晰地说明，我们假设：

• Y.class 是要删除的实体类型。
• T.class 是用于子查询的实体类型。
• Y 实体中有一个名为 "matchingFieldInY" 的字段，其值需要与T实体中名为"key"的字段匹配。
• T 实体中有一个名为"id"的字段，用于子查询的过滤。
• givenList 是一个包含T实体id的列表。

import javax.persistence.EntityManager;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaDelete;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Root;
import java.util.List;

// 假设 Y 和 T 是 JPA 实体
// class Y { private Object matchingFieldInY; ... }
// class T { private Object id; private Object key; ... }

public class JpaCriteriaDeleteExecutor {

    private EntityManager entityManager; // 假设 entityManager 已注入或获取

    public JpaCriteriaDeleteExecutor(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    public int deleteEntitiesWithSubquery(List