Hibernate应用程序级可重复读取

介绍

在我以前的文章中，我描述了应用程序级事务如何为长时间的对话提供合适的并发控制机制。

所有实体都在Hibernate会话的上下文中加载，充当事务后写式缓存。

Hibernate持久性上下文可以包含给定实体的一个引用和一个引用。一级缓存可确保会话级可重复读取。

如果对话跨越多个请求，我们可以进行应用程序级的可重复读取。长时间的对话本质上是有状态的，因此我们可以选择分离的对象或长期的持久性上下文 。但是，应用程序级可重复读取需要应用程序级并发控制策略，例如乐观锁定。

抓住

但是这种行为有时可能被证明是出乎意料的。

如果您的Hibernate会话已经加载了给定的实体，那么任何后续的实体查询（JPQL / HQL）都将返回完全相同的对象引用（不考虑当前加载的数据库快照）：

应用程序级别可重复读取

在此示例中，我们可以看到第一级缓存可防止覆盖已加载的实体。为了证明这种行为，我提出了以下测试案例：

final ExecutorService executorService = Executors.newSingleThreadExecutor();doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session session) {Product product = new Product();product.setId(1L);product.setQuantity(7L);session.persist(product);return null;}
});doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session session) {final Product product = (Product) session.get(Product.class, 1L);try {executorService.submit(new Callable<Void>() {@Overridepublic Void call() throws Exception {return doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session _session) {Product otherThreadProduct = (Product) _session.get(Product.class, 1L);assertNotSame(product, otherThreadProduct);otherThreadProduct.setQuantity(6L);return null;}});}}).get();Product reloadedProduct = (Product) session.createQuery("from Product").uniqueResult();assertEquals(7L, reloadedProduct.getQuantity());assertEquals(6L, ((Number) session.createSQLQuery("select quantity from Product where id = :id").setParameter("id", product.getId()).uniqueResult()).longValue());} catch (Exception e) {fail(e.getMessage());}return null;}
});

该测试案例清楚地说明了实体查询和SQL预测之间的区别。尽管SQL查询投影总是加载最新的数据库状态，但是实体查询结果由第一级缓存管理，以确保会话级可重复读取。