我正在使用 Spring Boot 1.3.0.M4 和 MySQL 数据库。
我在使用修改查询时遇到问题,EntityManager 在查询执行后包含过时的实体。
原始 JPA 存储库:
public interface EmailRepository extends JpaRepository<Email, Long> {
@Transactional
@Modifying
@Query("update Email e set e.active = false where e.active = true and e.expire <= NOW()")
Integer deactivateByExpired();
}
假设我们在数据库中有电子邮件 [id=1, active=true, expire=2015/01/01]。
执行后:
emailRepository.save(email);
emailRepository.deactivateByExpired();
System.out.println(emailRepository.findOne(1L).isActive()); // prints true!! it should print false
解决问题的第一种方法:添加clearAutomatically = true
public interface EmailRepository extends JpaRepository<Email, Long> {
@Transactional
@Modifying(clearAutomatically = true)
@Query("update Email e set e.active = false where e.active = true and e.expire <= NOW()")
Integer deactivateByExpired();
}
此方法清除持久性上下文以不包含过时的值,但它会丢弃所有仍在 EntityManager 中挂起的未刷新更改。因为我只使用 save()
方法而不是 saveAndFlush()
其他实体会丢失一些更改:(
解决问题的第二种方法:存储库的自定义实现
public interface EmailRepository extends JpaRepository<Email, Long>, EmailRepositoryCustom {
}
public interface EmailRepositoryCustom {
Integer deactivateByExpired();
}
public class EmailRepositoryImpl implements EmailRepositoryCustom {
@PersistenceContext
private EntityManager entityManager;
@Transactional
@Override
public Integer deactivateByExpired() {
String hsql = "update Email e set e.active = false where e.active = true and e.expire <= NOW()";
Query query = entityManager.createQuery(hsql);
entityManager.flush();
Integer result = query.executeUpdate();
entityManager.clear();
return result;
}
}
这种方法的工作方式类似于 @Modifying(clearAutomatically = true)
,但它首先强制 EntityManager 在执行更新之前将所有更改刷新到 DB,然后清除持久性上下文。这样就不会出现过时的实体,所有更改都将保存在数据库中。
我想知道是否有更好的方法在 JPA 中执行更新语句,而不会出现过时实体的问题,也无需手动刷新到数据库。也许禁用二级缓存?我如何在 Spring Boot 中做到这一点?
2018 年更新
Spring Data JPA 批准了我的 PR,现在 @Modifying()
中有一个 flushAutomatically
选项。
@Modifying(flushAutomatically = true, clearAutomatically = true)
最佳答案
我知道这不是您问题的直接答案,因为您已经构建了一个修复程序并在 Github 上发起了拉取请求。谢谢你!
但我想解释一下您可以采用的 JPA 方式。因此,您希望更改与特定条件匹配的所有实体并更新每个实体的值。正常的方法是加载所有需要的实体:
@Query("SELECT * FROM Email e where e.active = true and e.expire <= NOW()")
List<Email> findExpired();
然后遍历它们并更新值:
for (Email email : findExpired()) {
email.setActive(false);
}
现在,hibernate 知道所有更改,如果事务完成或您手动调用 EntityManager.flush()
,会将它们写入数据库。我知道如果您有大量数据条目,这将无法正常工作,因为您将所有实体都加载到内存中。但这是保持 hibernate 实体缓存、二级缓存和数据库同步的最佳方式。
这个答案是不是说“`@Modifying´ 注释没用”?不!如果您确保修改后的实体不在本地缓存中,例如只写应用程序,这种方法就是要走的路。
仅作记录:您的存储库方法不需要 @Transactional
。
仅用于记录 v2:active
列看起来直接依赖于 expire
。那么为什么不完全删除 active
并在每个查询中只查看 expire
呢?
关于Spring Boot Data JPA - 修改更新查询 - 刷新持久性上下文,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32258857/