Spring Boot Data JPA-修改更新查询-刷新持久性上下文

Question

当使用修改查询时，我有一个问题，EntityManager在查询执行后包含过时的实体。

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();

}

假设我们在DB中有电子邮件[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

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();

}

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(flushAutomatically = true, clearAutomatically = true)

Answer 1

我知道这不是直接回答您的问题，因为您已经构建了一个修复程序，并在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);
}