JPA CriteriaDelete 结合子查询删除操作的正确执行姿势

CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder();
CriteriaDelete<Y> criteriaDelete = criteriaBuilder.createCriteriaDelete(Y.class); // Y是待删除的实体

Root<Y> deleteRoot = criteriaDelete.from(Y.class);

// 假设我们有一个子查询，用于获取一个ID列表
CriteriaQuery<String> subCriteriaQuery = criteriaBuilder.createQuery(String.class);
Root<T> queryRoot = subCriteriaQuery.from(T.class); // T是用于子查询的关联实体

// 子查询逻辑：从T实体中选择某个key，其中T的id在givenList中
subCriteriaQuery.select(queryRoot.get("keyFieldInT"))
                .where(queryRoot.get("id").in(givenList));

// 将子查询结果应用于主删除查询的in表达式
// 错误示范：仅创建查询对象，未执行DML操作
entityManager.createQuery(criteriaDelete
        .where(deleteRoot.get("matchingFieldInY").in(subCriteriaQuery)));

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;

// 假设我们有Product和Category两个实体
// Product: id, name, categoryId
// Category: id, name, status (e.g., "inactive")

// 示例实体类（实际应用中应是JPA实体）
class Product {
    private Long id;
    private String name;
    private Long categoryId; // 关联Category的ID
    // ... getters and setters
}

class Category {
    private Long id;
    private String name;
    private String status; // 例如："active", "inactive"
    // ... getters and setters
}

public class JpaCriteriaDeleteTutorial {

    private EntityManager entityManager; // 假设已通过依赖注入或工厂获取

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

    /**
     * 删除所有属于“非活跃”类别的产品。
     * @param inactiveCategoryStatuses 非活跃类别的状态列表，例如 ["inactive", "archived"]
     * @return 被删除的产品数量
     */
    public int deleteProductsInInactiveCategories(List<String> inactiveCategoryStatuses) {
        CriteriaBuilder cb = entityManager.getCriteriaBuilder();

        // 1. 创建 CriteriaDelete 查询，目标是 Product 实体
        CriteriaDelete<Product> deleteProduct = cb.createCriteriaDelete(Product.class);
        Root<Product> productRoot = deleteProduct.from(Product.class);

        // 2. 创建子查询，以查找所有“非活跃”类别的ID
        CriteriaQuery<Long> subquery = cb.createQuery(Long.class); // 子查询选择Category的ID
        Root<Category> categoryRoot = subquery.from(Category.class); // 从Category实体中查询

        subquery.select(categoryRoot.get("id")) // 选择Category的ID
                .where(categoryRoot.get("status").in(inactiveCategoryStatuses)); // 筛选状态为非活跃的Category

        // 3. 将子查询结果应用于主删除查询的WHERE子句
        // 删除 Product 实体，其中 Product 的 categoryId 存在于子查询返回的非活跃类别ID列表中
        deleteProduct.where(productRoot.get("categoryId").in(subquery));

        // 4. 执行删除操作并获取受影响的行数
        // 关键一步：调用 executeUpdate()
        int deletedCount = 0;
        try {
            entityManager.getTransaction().begin(); // DML操作通常需要事务
            deletedCount = entityManager.createQuery(deleteProduct).executeUpdate();
            entityManager.getTransaction().commit();
        } catch (Exception e) {
            if (entityManager.getTransaction().isActive()) {
                entityManager.getTransaction().rollback();
            }
            System.err.println("Error deleting products: " + e.getMessage());
            throw new RuntimeException("Failed to delete products", e);
        }

        return deletedCount;
    }

    // ... 其他方法或主函数
}