JPA CriteriaDelete与子查询：确保数据删除操作正确执行的要点

// 假设 orphan, one_type, other_type, key, givenList 均已正确定义
// Y 为待删除实体类型，T 为关联实体类型
CriteriaDelete<Y> criteriaDelete = criteriaBuilder.createCriteriaDelete(orphan);

Root<Y> deleteRoot = criteriaDelete.from(one_type);
Root<T> queryRoot = criteriaDelete.from(other_type);

// 构建子查询，用于确定要删除的实体
CriteriaQuery<Object> criteriaQuery = criteriaBuilder.createQuery(Object.class);
criteriaQuery.select(queryRoot.get(key)); // 选择作为in表达式条件的字段

// 尝试执行删除操作，但缺少关键步骤
entityManager.createQuery(criteriaDelete
        .where(deleteRoot.in(entityManager.createQuery(criteriaQuery
                .where(queryRoot.get("id").in(givenList))).getResultList())));
// 在此示例中，getResultList()被错误地用于子查询的执行，并且主删除查询未被真正执行。
// 更重要的是，主删除查询对象创建后，没有调用任何执行方法。

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 javax.persistence.criteria.Subquery;
import java.util.List;

/**
 * 演示如何使用JPA CriteriaDelete 和子查询进行批量删除操作。
 *
 * @param <Y> 目标删除实体类型
 * @param <T> 子查询关联实体类型
 * @param <K> 子查询中in条件列表的元素类型
 */
public class JpaCriteriaDeleteTutorial {

    /**
     * 根据子查询条件删除实体。
     * 
     * @param entityManager JPA实体管理器
     * @param criteriaBuilder JPA CriteriaBuilder
     * @param targetEntityType 目标删除实体的Class对象
     * @param associatedEntityType 子查询中关联实体的Class对象
     * @param targetEntityKeyField 目标实体中用于in表达式匹配的字段名
     * @param associatedEntityIdField 关联实体中用于in条件列表匹配的字段名
     * @param givenIdList 关联实体ID的列表，用于子查询的in条件
     * @return 实际被删除的实体数量
     */
    public <Y, T, K> int deleteEntitiesWithSubquery(EntityManager entityManager, CriteriaBuilder criteriaBuilder,
                                                 Class<Y> targetEntityType, Class<T> associatedEntityType,
                                                 String targetEntityKeyField, String associatedEntityIdField,
                                                 List<K> givenIdList) {

        // 1. 构建主删除查询
        CriteriaDelete<Y> criteriaDelete = criteriaBuilder.createCriteriaDelete(targetEntityType);
        Root<Y> deleteRoot = criteriaDelete.from(targetEntityType);

        // 2. 构建子查询，用于确定要删除的实体
        // 子查询选择与目标实体关联的某个键值，这些键值将作为主查询in表达式的条件
        Subquery<Object> subquery = criteriaDelete.subquery(Object.class); // 使用criteriaDelete.subquery创建子查询
        Root<T> subqueryRoot = subquery.from(associatedEntityType); // 子查询的根实体
        subquery.select(subqueryRoot.get(associatedEntityIdField)); // 选择作为in表达式条件的字段，通常是ID或关联键

        // 子查询的where条件：关联实体ID在给定列表中
        subquery.where(subqueryRoot.get(associatedEntityIdField).in(givenIdList));

        // 3. 将子查询结果作为in表达式的条件应用到主删除查询
        // 注意：这里是直接将Subquery对象作为in表达式的参数，JPA会将其转换为SQL子查询。
        // targetEntityKeyField是Y实体（deleteRoot）中与subquery选择的associatedEntityIdField相对应的字段。
        criteriaDelete.where(deleteRoot.get(targetEntityKeyField).in(subquery));

        // 4. 创建并执行删除查询
        // 关键步骤：调用 executeUpdate() 方法
        int affectedRows = entityManager.createQuery(criteriaDelete).executeUpdate();

        return affectedRows;
    }
}