Spring JPA/Hibernate执行@Modifying自定义更新前触发全量更新问题

这个问题的核心原因是Hibernate的一级缓存（Session缓存）机制：如果在执行自定义JPQL更新之前，你的代码已经通过findById、findByBusinessKey等方法加载了对应的Business实体到Session缓存中，那么当事务提交时，Hibernate会对比缓存中实体的状态和数据库的状态，发现不一致后就会自动执行一次全量更新来同步缓存，这就导致了额外的全量更新操作。

下面是几个有效的解决办法：

1. 给@Modifying添加clearAutomatically属性 #

最简单的方式是在@Modifying注解中开启clearAutomatically = true，它会在执行完JPQL更新后自动清空Session缓存，避免Hibernate后续触发缓存同步的全量更新：

public interface BusinessRepository extends JpaRepository<Business, String> {
    @Modifying(clearAutomatically = true)
    @Query("update Business business set business.updateDatetime = :updateDatetime where business.businessKey = :businessKey")
    int setUpdateDatetimeForBusiness(@Param("updateDatetime") String updateDatetime, @Param("businessKey") String businessKey);
}

2. 避免在同一事务中先加载实体再执行更新 #

如果你的业务逻辑允许，尽量直接调用自定义更新方法，不要提前通过查询方法加载目标实体到Session缓存中。比如不要先执行businessRepository.findByBusinessKey(businessKey)，再调用更新方法，这样就能从根源上避免缓存不一致的问题。

3. 手动处理Session缓存 #

如果无法避免在同一事务中加载实体，可以在执行更新后手动清除缓存中对应的实体，或者从数据库重新加载最新状态：

方式一：分离实体（从缓存中移除） #

@Service
public class BusinessService {
    @Autowired
    private BusinessRepository businessRepository;
    @Autowired
    private EntityManager entityManager;

    @Transactional
    public void updateBusinessDatetime(String businessKey, String updateDatetime) {
        // 假设先加载了实体
        Business business = businessRepository.findByBusinessKey(businessKey);
        // 执行自定义更新
        businessRepository.setUpdateDatetimeForBusiness(updateDatetime, businessKey);
        // 从缓存中移除该实体，避免后续同步
        entityManager.detach(business);
    }
}

方式二：刷新实体（从数据库重新加载） #

@Transactional
public void updateBusinessDatetime(String businessKey, String updateDatetime) {
    Business business = businessRepository.findByBusinessKey(businessKey);
    businessRepository.setUpdateDatetimeForBusiness(updateDatetime, businessKey);
    // 从数据库刷新实体状态，保持缓存和数据库一致
    entityManager.refresh(business);
}

4. 使用独立事务执行更新 #

将自定义更新方法放在一个独立的事务中，让它和加载实体的事务隔离，这样两个事务的缓存互不影响：

public interface BusinessRepository extends JpaRepository<Business, String> {
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    @Modifying
    @Query("update Business business set business.updateDatetime = :updateDatetime where business.businessKey = :businessKey")
    int setUpdateDatetimeForBusiness(@Param("updateDatetime") String updateDatetime, @Param("businessKey") String businessKey);
}

需要注意的是，使用REQUIRES_NEW会开启新事务，要根据你的业务场景判断是否合适，避免事务嵌套带来的问题。

内容的提问来源于stack exchange，提问作者Mariano L