Hibernate批处理更新-不更新实体

Question

我有一个批处理过程，它正在为一组实体重新计算数据。通过Hibernate从DB获取实体列表：

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void recalculateUserData(Long userId){
    List<Entity> data = repository.getAllPendingRecalculation(userId);

    List<Entity> recalculated = new LinkedList();

    for (Entity entity : data){
        recalculateEntity(entity, recalculated);
        recalculated.add(entity);
        flushIfNeeded(recalculated); //every 10 records
    }
}

private void recalculateEntity(Entity entity, List<Entity> recalculated){
    //do logic
}

private void flush(){
    getSession().flush();
    getSession().clear();
}

private void flushIfNeeded(List<Entity> data) {
    int flushSize = 10
    if (data.size() % flushSize == 0){
        flush();
    }
}

当流程运行时，某些实体似乎正在分离，导致两种症状：

1. 当尝试获取惰性数据时，我得到一个异常：org。冬眠LazyInitializationException-无法初始化代理-无会话

在我的第一次尝试中，我试图通过调用session#refresh（entity）insiderecreacteentity（…） -这解决了延迟初始化问题，但#2中的问题仍然存在：

private void recalculateEntity(Entity entity){
    getSession().refresh(entity);
    //do logic
}

因为这还没有解决问题，所以我考虑使用附加（实体）而不是刷新（实体）：

private void recalculateEntity(Entity entity){
    getSession().attach(entity);
    //do logic
}

这似乎奏效了，但我的问题是：为什么这些实体一开始就分离了？

（我正在使用Hibernate 3.6.10）

正如@galovics所解释的：

问题是您正在清除包含所有托管实体的整个会话，从而使它们分离。

Hibernate批次处理作业留档指示应该使用Scrollable结果（解决了这些问题）执行批次更新，但是在这种情况下，我必须在处理它之前获取所有数据，因为实体计算可能依赖于已经计算过的实体。例如，计算实体#3可能需要为实体#1计算的数据

对于这样的情况，使用会话#附加（实体）（如代码所示），使用会话#flush（）而不使用会话#Clear（）会更好吗？或者有更好的解决方案吗？




Answer 1

问题是您正在清除包含所有托管实体的整个会话，从而使它们分离。

如果只处理部分数据，请确保只提取它们，然后可以轻松地清除整个会话，提取下一批数据并执行相同的计算。

关于LazyInitializationException的文章只是为了澄清一下。