java Hibernate Envers“InvalidDataAccessApiUsageException:关联的实体管理器已关闭”
我有一个服务(控制器),其中包含一个逻辑,并为底层DAO对象创建事务
在其中一种方法中,我从数据库中读取实体,然后尝试使用Hibernate Envers查找它的历史版本
@Named
@Transactional
public class DocCtrl {
...
public synchronized List<DocCreateRespDTO> getUnapprovedVersions() {
List<Task> unapprovedTasks = taskDAO.getForApproval();
List<DocCreateRespDTO> unapprovedDocDTOS = new ArrayList<>(unapprovedTasks.size());
for (Task u : unapprovedTasks) {
...
rp.setManipulationCtx(dto.document, active.getId());
unapprovedDocDTOS.add(dto);
}
return unapprovedDocDTOS;
}
}
rp
被注入RevisionProvider
的实例:
@Repository
public class RevisionProvider {
@PersistenceContext(name = Vedantas.PU_NAME, type = PersistenceContextType.TRANSACTION)
private EntityManager entityManager;
private AuditReader auditReader;
@PostConstruct
void init() {
auditReader = AuditReaderFactory.get(entityManager);
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public OperationCtx getCreationRevisionFor(Class aClass, long id) {
final Object[] array = (Object[]) auditReader.createQuery()
.forRevisionsOfEntity(aClass, false, false)
.add(AuditEntity.revisionType().eq(RevisionType.ADD))
.add(AuditEntity.id().eq(id))
.setMaxResults(1)
.getSingleResult();
return ((OperationCtx) array[1]);
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public OperationCtx getLastRevisionFor(Class aClass, long id) {
final Object[] array = (Object[]) auditReader.createQuery()
.forRevisionsOfEntity(aClass, false, false)
.add(AuditEntity.id().eq(id))
.add(AuditEntity.revisionNumber().maximize()
.computeAggregationInInstanceContext()
)
.addOrder(AuditEntity.revisionNumber().desc())
.setMaxResults(1)
.getSingleResult();
OperationCtx lastchg = (OperationCtx) array[1];
OperationCtx creation = getCreationRevisionFor(aClass, id);
if (creation.getId() == lastchg.getId())
return new OperationCtx();
return lastchg;
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public List getHistoryFor(Class aClass, String pk, String val) {
List res = auditReader.createQuery()
.forRevisionsOfEntity(aClass, false, false)
.add(AuditEntity.property(pk).eq(val))
.getResultList();
return res;
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void setManipulationCtx(FindDTO dto, long id) {
OperationCtx cctx = getCreationRevisionFor(DocVersion.class, id);
OperationCtx lctx = getLastRevisionFor(Metadata.class, dto.metadata.getId());
dto.createCtx = ModelCopyHelper.copyOperCtx(cctx);
dto.lastChangeCtx = ModelCopyHelper.copyOperCtx(lctx);
}
}
现在,当执行器点击auditReader.createQuery()
时会发生什么
^正在抛出{
如您所见,我试图将每个方法注释为事务性的,以使spring注入/启动事务并打开实体管理器,但仍然引发了异常
您能否建议如何正确地在此处插入实体管理器
正在使用的框架版本: 冬眠:5.2.9。最终的 环境:5.2.12。决赛
# 1 楼答案
我将假设您在这个上下文中使用Spring及其默认bean定义;因此,您不能创建一个有状态bean,并将其缓存为无状态bean中的实例变量,然后以这种方式跨状态边界重用它。这就是为什么会出现错误
您需要做的是延迟
AuditReader
的构造,直到您需要它为止。这保证了底层EntityManager
对该执行线程是开放的简而言之,您需要这样做: