Spring Boot中@Transactional与持久化上下文疑问：为何复用同一上下文？

你遇到的问题核心在于Spring事务的默认传播机制（REQUIRED），而非JPA持久化上下文的策略本身。

具体原因分析 #

1. 当调用entityRepository.save()时，由于当前线程没有活跃事务，Spring会创建一个新事务，并将对应的持久化上下文绑定到当前线程。
2. 随后调用entityRepository.findOne()时，Spring会检查当前线程是否存在活跃事务。因为默认的事务传播行为是REQUIRED，它会直接加入已有的事务，而不是创建新事务。
3. JPA的一级缓存（EntityManager缓存）与持久化上下文绑定，同一个事务对应同一个持久化上下文，所以findOne会直接从缓存读取数据，不会发送新的SQL查询。

解决方案 #

方案1：修改Repository方法的事务传播行为 #

将Repository类上的@Transactional注解改为强制新建事务的传播策略REQUIRES_NEW，让每个方法启动独立事务，对应独立的持久化上下文：

@Repository
@Transactional(propagation = Propagation.REQUIRES_NEW)
public class EntityRepository {
    private final EntityManager em;
    private final Class<Entity> entityClass = Entity.class; // 补充你代码中遗漏的entityClass定义

    public EntityRepository(EntityManager em) {
        this.em = em;
    }

    public Entity save(Entity entity) {
        em.persist(entity);
        return entity;
    }

    public Optional<Entity> findOne(Long id) {
        return Optional.ofNullable(em.find(entityClass, id));
    }
}

方案2：在Service层拆分独立事务方法 #

如果不想修改Repository的事务策略，可以在Service层将操作拆分为独立方法，为每个方法指定REQUIRES_NEW传播行为：

@Service
@RequiredArgsConstructor
public class EntityService {

    private final EntityRepository entityRepository;

    public Entity postEntity(Integer userId, EntityCreateRequest entityRequest) {
        var result = saveNewEntity(entityRequest);
        
        // ...其他代码

        var getEntity = fetchEntityById(result.getId());

        return getEntity.orElseThrow(() -> new RuntimeException("Entity not found"));
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private Entity saveNewEntity(EntityCreateRequest entityRequest) {
        return entityRepository.save(EntityMapper.INSTANCE.toEntity(entityRequest));
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private Optional<Entity> fetchEntityById(Long id) {
        return entityRepository.findOne(id);
    }
}

方案3：绕过一级缓存（无需新事务） #

如果仅需强制查询数据库而非必须开启新事务，可以通过以下方式绕过一级缓存：

• 使用EntityManager.refresh()（需实体处于被管理状态）
• 使用JPQL查询并设置刷新提示：

public Optional<Entity> findOne(Long id) {
    try {
        Entity entity = em.createQuery("SELECT e FROM Entity e WHERE e.id = :id", Entity.class)
                .setParameter("id", id)
                .setHint("javax.persistence.cache.storeMode", CacheStoreMode.REFRESH)
                .getSingleResult();
        return Optional.ofNullable(entity);
    } catch (NoResultException e) {
        return Optional.empty();
    }
}

补充说明 #

Spring的@Transactional默认传播行为REQUIRED的设计初衷是让多个操作共享同一个事务，保证原子性。只有当你明确需要独立事务时，才需要指定REQUIRES_NEW或其他传播策略。

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