Spring Boot获取数据库中Persona对象实时值问题求助

问题核心是Spring Data JPA的findById会优先从**一级缓存（持久化上下文）**中返回对象，而非直接查询数据库。当你在update方法中已经修改了缓存里的Persona对象时，后续的findById都会返回这个修改后的实例，导致和传入的changedPersona对比失效。

以下是几种可靠的解决方案：

方案1：使用原生SQL查询绕过缓存 #

在PersonaRepository中添加原生SQL查询方法，直接从数据库获取实时值：

public interface PersonaRepository extends JpaRepository<Persona, Long> {
    // 原生SQL查询，绕过JPA缓存直接查库
    @Query(value = "SELECT * FROM persona WHERE id = :id", nativeQuery = true)
    Persona findRealTimeValueById(@Param("id") Long id);
}

修改checkChanges方法调用这个新方法：

private void checkChanges(Persona changedPersona){
    Persona personaBefore = this.personaRepository.findRealTimeValueById(changedPersona.getId());
    // 可根据实际需求对比特定字段，而非直接用equals
    if(!changedPersona.getTargetField().equals(personaBefore.getTargetField())){
        // 执行你的校验操作
    }
}

优点：简单直接，不依赖JPA实现特性，兼容性强；原生SQL直接查询数据库，返回全新对象实例，完全不受当前缓存影响。

方案2：开启新事务查询 #

通过事务传播特性，让校验逻辑在独立的新事务中执行，每个事务拥有独立的一级缓存，因此查询到的是数据库实时值。

1. 把校验逻辑提取到单独的Service类（避免Spring AOP代理不生效）：

@Service
public class PersonaCheckService {
    private final PersonaRepository personaRepository;

    public PersonaCheckService(PersonaRepository personaRepository) {
        this.personaRepository = personaRepository;
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void checkChanges(Persona changedPersona){
        Persona personaBefore = personaRepository.findById(changedPersona.getId())
                .orElseThrow(() -> new RuntimeException("Persona不存在"));
        if(!changedPersona.equals(personaBefore)){
            // 执行校验操作
        }
    }
}

2. 在原Service中注入新Service并调用：

@Service
public class PersonaService {
    private final PersonaRepository personaRepository;
    private final PersonaCheckService personaCheckService;

    public PersonaService(PersonaRepository personaRepository, PersonaCheckService personaCheckService) {
        this.personaRepository = personaRepository;
        this.personaCheckService = personaCheckService;
    }

    @Override
    @Transactional
    public void update(Persona changedPersona){
        Persona personaBefore = this.personaRepository.findById(changedPersona.getId())
                .orElseThrow(() -> new RuntimeException("Persona不存在"));
        copyAttributesOfObjectAToObjectB(changedPersona, personaBefore);
        // 其他校验逻辑...
        
        personaCheckService.checkChanges(changedPersona);
        
        this.personaRepository.save(changedPersona);
    }
}

优点：完全隔离当前事务的缓存状态，适合复杂场景；注意：private方法上的@Transactional不会生效，必须通过Spring代理的public方法调用。

方案3：手动移除缓存中的对象 #

通过EntityManager将当前修改的对象从持久化上下文中移除，后续findById会重新查询数据库：

@Service
public class PersonaService {
    private final PersonaRepository personaRepository;
    private final EntityManager entityManager;

    public PersonaService(PersonaRepository personaRepository, EntityManager entityManager) {
        this.personaRepository = personaRepository;
        this.entityManager = entityManager;
    }

    private void checkChanges(Persona changedPersona){
        // 将对象从持久化上下文移除，清除缓存
        entityManager.detach(changedPersona);
        // 此时findById会重新查询数据库
        Persona personaBefore = this.personaRepository.findById(changedPersona.getId())
                .orElseThrow(() -> new RuntimeException("Persona不存在"));
        
        if(!changedPersona.equals(personaBefore)){
            // 执行校验操作
        }
        
        // 可选：后续需操作changedPersona时，重新加入上下文
        entityManager.merge(changedPersona);
    }
}

优点：无需新增方法或类；注意：detach后对象变为游离态，后续save会自动执行merge操作，多数场景无需手动处理。

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