Hibernate MultipleBagFetchException规避方案：Criteria API加载多级关联实体

错误原因 #

Hibernate抛出MultipleBagFetchException是因为你同时抓取了多个Bag类型的集合——默认情况下，List在Hibernate中被视为Bag，即无顺序、无唯一约束的集合。多层Bag关联的JOIN会产生大量笛卡尔积，Hibernate无法正确处理这种场景下的结果映射，因此触发异常。

解决方案 #

1. 将集合类型从List改为Set #

直接修改实体类中的集合定义，把List<BEntity>、List<CEntity>、List<DEntity>替换为Set<BEntity>、Set<CEntity>、Set<DEntity>。Set属于有唯一约束的集合，Hibernate可以正确处理多个Set的关联抓取，避免笛卡尔积导致的映射问题。

修改后你的Criteria API代码无需大幅调整，保持原有链式fetch即可：

CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder();
CriteriaQuery<AEntity> query = criteriaBuilder.createQuery(AEntity.class);
Root<AEntity> root = query.from(AEntity.class);

// 链式抓取关联集合
root.fetch(AEntity_.bEntityList, JoinType.LEFT)
    .fetch(BEntity_.cEntityList, JoinType.LEFT)
    .fetch(CEntity_.dEntityList, JoinType.LEFT);

Predicate idPredicate = criteriaBuilder.equal(root.get(AEntity_.id), id);
query.where(idPredicate);

return entityManager.createQuery(query).getSingleResult();

注意：修改集合类型后，需要确保实体对应的数据库关联关系兼容，同时正确实现equals()和hashCode()方法（Set依赖这两个方法判断元素唯一性）。

2. 使用@Fetch(FetchMode.SUBSELECT)注解 #

如果不想修改集合类型，可以在实体的集合字段上添加@Fetch(FetchMode.SUBSELECT)注解，让Hibernate通过子查询而非JOIN的方式加载关联集合，从而避免笛卡尔积问题。

示例：

@Entity
public class AEntity {
    // ...其他字段
    @OneToMany(mappedBy = "a", fetch = FetchType.LAZY)
    @Fetch(FetchMode.SUBSELECT)
    private List<BEntity> bEntityList;
}

@Entity
public class BEntity {
    // ...其他字段
    @OneToMany(mappedBy = "b", fetch = FetchType.LAZY)
    @Fetch(FetchMode.SUBSELECT)
    private List<CEntity> cEntityList;
}

@Entity
public class CEntity {
    // ...其他字段
    @OneToMany(mappedBy = "c", fetch = FetchType.LAZY)
    @Fetch(FetchMode.SUBSELECT)
    private List<DEntity> dEntityList;
}

添加注解后，原有的Criteria API代码可直接使用，Hibernate会自动通过子查询加载所有关联集合，既解决N+1问题，又避免异常。

3. 分阶段抓取（多查询加载） #

如果上述两种方式都不适用，可以分两次查询加载关联数据，利用Hibernate的会话缓存（一级缓存）避免N+1：

1. 第一次查询加载AEntity并抓取BEntity集合；
2. 第二次查询加载所有关联的CEntity和DEntity集合，Hibernate会自动将这些数据关联到会话中的BEntity实例上。

代码示例：

// 第一步：加载A并抓取B
CriteriaBuilder cb = entityManager.getCriteriaBuilder();
CriteriaQuery<AEntity> aQuery = cb.createQuery(AEntity.class);
Root<AEntity> aRoot = aQuery.from(AEntity.class);
aRoot.fetch(AEntity_.bEntityList, JoinType.LEFT);
aQuery.where(cb.equal(aRoot.get(AEntity_.id), id));
AEntity a = entityManager.createQuery(aQuery).getSingleResult();

// 第二步：加载所有关联的C和D，利用会话缓存自动关联
CriteriaQuery<CEntity> cQuery = cb.createQuery(CEntity.class);
Root<CEntity> cRoot = cQuery.from(CEntity.class);
cRoot.fetch(CEntity_.dEntityList, JoinType.LEFT);
// 筛选属于当前A的B对应的C
cQuery.where(cRoot.get(CEntity_.bEntity).get(BEntity_.aEntity).get(AEntity_.id).in(id));
entityManager.createQuery(cQuery).getResultList();

return a;

这种方式不需要修改实体，也能避免异常，但需要编写额外的查询。

问题解答 #

• 是否可行？完全可行，上述三种方法都能实现通过Criteria API加载B、C、D的所有关联记录，同时解决N+1和MultipleBagFetchException问题。
• 是否需要单独编写查询？不一定：修改集合类型或使用SUBSELECT注解无需额外查询；分阶段抓取则需要编写多个查询。

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