使用 EntityManager 取消 JPA 一级缓存

JPA 默认开启一级缓存(底层实现是在 EntityManager 层)。

当不同的查询结果映射到同样的 entity 时,一级缓存可能会导致返回数据不符合预期(只查询了一次,后续查询直接返回第一次查询的结果)。

一个例子

一个展示系统的后台,需要分别查询不同指标的月度趋势,查询结果复用同一个 Entity。

@Entity
public class MonthlyTrendEntity implements Serializable {

    private long id; // @Id

    private Integer year;
    private Integer month;

    private Integer value;
    
    // ...
}

某数据接口中,先后查询了两个不同数据指标的月度趋势。

// ...

// 流动资产趋势
            List<MonthlyTrendEntity> assetLiquidTrend = financialService.selectAssetLiquidTrend();
// 固定资产趋势
            List<MonthlyTrendEntity> assetFixedTrend = financialService.selectAssetFixedTrend;
            
// ...

调用该接口,查看接口返回结果,发现固定资产趋势的数值和流动资产数值相同。但数据库中的数值并不相同。

问题原因是 JPA 默认开启一级缓存(并且一级缓存无法直接通过配置关闭)。两次不同查询返回的月度趋势,如果恰好 Entity 的主键相同,第二次查询会直接利用第一次查询的结果,而非再次查询数据库。

解决方案:使用 EntityManager 消除缓存

1 自定义 Repository 接口类

public interface FinancialTrendRepository {

    List<MonthlyTrendEntity> selectAssetLiquidTrend();
    List<MonthlyTrendEntity> selectAssetFixedTrend();
    
}

2 自定义 Repository 实现类

@Repository
public class FinancialTrendRepositoryImpl implements FinancialTrendRepository {

    @PersistenceContext
    private EntityManager em;

    @Override
    public List<MonthlyTrendEntity> selectAssetLiquidTrend() {
        String sql = "select id, year, month, value from ..."; // 这里省略具体的查询逻辑

        Query query = em.createNativeQuery(sql, MonthlyTrendEntity.class); // 创建自定义查询,并将查询结果映射到 MonthlyTrendEntity
        em.clear(); // 清除缓存
        query.unwrap(NativeQueryImpl.class);
        return query.getResultList();
    }
    
    @Override
    public List<MonthlyTrendEntity> selectAssetFixedTrend() {
        String sql = "select id, year, month, value from ..."; // 这里省略具体的查询逻辑

        Query query = em.createNativeQuery(sql, MonthlyTrendEntity.class); // 创建自定义查询,并将查询结果映射到 MonthlyTrendEntity
        em.clear(); // 清除缓存
        query.unwrap(NativeQueryImpl.class);
        return query.getResultList();
    }
}

上述代码通过 em.clear();,在每次查询前清除 JPA 缓存,可解决后续查询直接返回第一次查询数据的问题。