强制刷新集合JPA entityManager

Question

我将Seam与JPA一起使用(实现为SEAM管理的持久上下文)，在我的后台bean中，我将一个实体集合(ArrayList)加载到后台bean中。

如果不同的用户在不同的会话中修改实体之一，我希望这些更改传播到我的会话中的集合，我有一个方法< code>refreshList()并尝试了以下方法...

@Override
public List<ItemStatus> refreshList(){
    itemList = itemStatusDAO.getCurrentStatus();
}

使用以下查询

@SuppressWarnings("unchecked")
@Override
public List<ItemStatus> getCurrentStatus(){
    String s = "SELECT DISTINCT iS FROM ItemStatus iS ";
    s+="ORDER BY iS.dateCreated ASC";
    Query q = this.getEntityManager().createQuery(s);
    return q.getResultList();
}

重新html" target="_blank">执行查询，只返回我已经拥有的相同数据（我假设它使用的是一级缓存，而不是数据库）

@Override
public List<ItemStatus> refreshList(){
    itemStatusDAO.refresh(itemList)
}

调用< code > entitymanager . refresh()时，这应该会从数据库刷新，但是我在使用它时得到了< code > javax . EJB . ejbtransactionrolledbackexception:Entity not managed 异常，通常我会在调用之前使用< code > entitymanager . find byid(Entity . getid)。refresh()以确保它连接到PC，但是当我刷新实体集合时，我不能这样做。

这似乎是一个非常简单的问题，我不相信没有办法强迫JPA/hibernate绕过缓存并访问数据库？！

更新测试用例：

我使用两个不同的浏览器（1和2）加载相同的网页，我在1中进行了修改，更新了其中一个ItemStatus实体中的布尔属性，视图刷新为1以显示更新的属性，我通过PGAdmin检查数据库，行已更新。然后我在浏览器2中按刷新，属性尚未更新

在调用.refresh之前，我尝试使用以下方法合并所有实体，但实体仍未从数据库中更新。

@Override
public void mergeCollectionIntoEntityManager(List<T> entityCollection){
    for(T entity: entityCollection){
        if(!this.getEntityManager().contains(entity)){
            this.getEntityManager().refresh(this.getEntityManager().merge(entity));
        }
    }
}

Answer 1

尝试将其标记为< code>@Transactional

@Override
@org.jboss.seam.annotations.Transactional
public void refreshList(){
    itemList = em.createQuery("...").getResultList();
}

Answer 2

匿名用户

您必须引用由< code > entitymanager . merge()方法返回的实体，类似于:

@Override
public void refreshCollection(List<T> entityCollection){
    for(T entity: entityCollection){
        if(!this.getEntityManager().contains(entity)){
            this.getEntityManager().refresh(this.getEntityManager().merge(entity));
        }
    }
}

通过这种方式，您应该去掉javax.ejb。EJBTransactionRolledbackException:实体未托管异常。

更新

也许退回新收藏更安全：

public List<T> refreshCollection(List<T> entityCollection)
    {
        List<T> result = new ArrayList<T>();
        if (entityCollection != null && !entityCollection.isEmpty()) {
            getEntityManager().getEntityManagerFactory().getCache().evict(entityCollection.get(0).getClass());
            T mergedEntity;
            for (T entity : entityCollection) {
                mergedEntity = entityManager.merge(entity);
                getEntityManager().refresh(mergedEntity);
                result.add(mergedEntity);
            }
        }
        return result;
    }

或者，如果您可以像这样访问实体ID，您可以更有效：

public List<T> refreshCollection(List<T> entityCollection)
    {
        List<T> result = new ArrayList<T>();
        T mergedEntity;
        for (T entity : entityCollection) {
            getEntityManager().getEntityManagerFactory().getCache().evict(entity.getClass(), entity.getId());
            result.add(getEntityManager().find(entity.getClass(), entity.getId()));
        }
        return result;
    }

Answer 3

你有两个不同的问题。让我们先解决简单的问题。

javax.ejb。EJBTransactionRolledbackException:未管理实体

该查询返回的对象的< code >列表本身不是< code >实体，因此您不能< code >。刷新它。事实上，这就是异常所抱怨的。您要求< code>EntityManager对一个不是已知< code >实体的对象做一些事情。

如果你想<代码>。刷新一堆东西，遍历它们并< code >。单独刷新它们。

刷新项目状态列表

你正在与Hibernate的< code >会话级缓存进行交互，从你的问题来看，你并不期望这样。从Hibernate文档中:

对于附加到特定会话的对象（即会话范围内的对象）…数据库标识的JVM标识由Hibernate保证。

这对查询.getResultList（） 的影响是，您不一定能恢复数据库的最新状态。

您运行的< code >查询实际上是获取与该查询匹配的实体id列表。任何已经存在于< code>Session缓存中的id都与已知的实体匹配，而任何没有匹配的id都是基于数据库状态填充的。以前已知的实体根本不会从数据库中刷新。

这意味着，如果在同一事务中的两次Query执行之间，数据库中某个特定已知实体的某些数据发生了变化，那么第二次查询将不会检测到这种变化。然而，它会拾取一个全新的ItemStatus实例（除非您使用的是查询缓存，我认为您没有）。

长话短说：使用Hibernate，无论何时您想在单个事务中加载一个实体，然后从数据库中获取对该实体的其他更改，您都必须显式。刷新（实体）。

您想如何处理这个问题在一定程度上取决于您的用例。我可以立即想到两个选项：

1. Have是将DAO绑定到事务的生命周期，并延迟初始化List

一些附加说明

有关于使用查询提示的讨论。以下是它们不起作用的原因：

org.hibernate.cacheable=false这只有在使用查询缓存时才有意义，只有在非常特殊的情况下才推荐使用查询缓存。即使您正在使用它，它也不会影响您的情况，因为查询缓存包含对象id，而不是数据。

这是对Hibernate的第二级缓存的指令。如果启用了第二级缓存，并且您从不同的事务发出两个查询，那么您将在第二个查询中获得过时的数据，并且此指令将解决问题。但是，如果您在两个查询中的同一会话中，则第二级缓存只会发挥作用，以避免此会话的新实体加载数据库。