hibernate工厂模式_Hibernate锁定模式–乐观锁定模式如何工作

hibernate工厂模式

显式乐观锁定

在上一篇文章中 ,我介绍了Java持久性锁定的基本概念。

隐式锁定机制可防止丢失更新 ,它适用于我们可以主动修改的实体。 尽管隐式乐观锁定是一种广泛使用的技术,但很少有人了解显式乐观锁定模式的内部工作原理。

当锁定的实体始终由某些外部机制修改时,显式乐观锁定可以防止数据完整性异常。

产品订购用例

假设我们有以下域模型:

productorderlineoptimisticlockmode1

我们的用户爱丽丝想订购产品。 购买过程如下:

隐式锁定lockmodenone1

  • 爱丽丝加载产品实体
  • 因为价格方便,她决定订购产品
  • 价格引擎批处理作业更改了产品价格(考虑了货币更改,税项更改和市场营销活动)
  • 爱丽丝发出订单而没有注意到价格变动

隐式锁定的缺点

首先,我们将测试隐式锁定机制是否可以防止此类异常。 我们的测试用例如下所示:

doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session session) {final Product product = (Product) session.get(Product.class, 1L);try {executeAndWait(new Callable<Void>() {@Overridepublic Void call() throws Exception {return doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session _session) {Product _product = (Product) _session.get(Product.class, 1L);assertNotSame(product, _product);_product.setPrice(BigDecimal.valueOf(14.49));return null;}});}});} catch (Exception e) {fail(e.getMessage());}OrderLine orderLine = new OrderLine(product);session.persist(orderLine);return null;}
});

测试生成以下输出:

#Alice selects a Product
Query:{[select abstractlo0_.id as id1_1_0_, abstractlo0_.description as descript2_1_0_, abstractlo0_.price as price3_1_0_, abstractlo0_.version as version4_1_0_ from product abstractlo0_ where abstractlo0_.id=?][1]} #The price engine selects the Product as well
Query:{[select abstractlo0_.id as id1_1_0_, abstractlo0_.description as descript2_1_0_, abstractlo0_.price as price3_1_0_, abstractlo0_.version as version4_1_0_ from product abstractlo0_ where abstractlo0_.id=?][1]} 
#The price engine changes the Product price
Query:{[update product set description=?, price=?, version=? where id=? and version=?][USB Flash Drive,14.49,1,1,0]}
#The price engine transaction is committed
DEBUG [pool-2-thread-1]: o.h.e.t.i.j.JdbcTransaction - committed JDBC Connection#Alice inserts an OrderLine without realizing the Product price change
Query:{[insert into order_line (id, product_id, unitPrice, version) values (default, ?, ?, ?)][1,12.99,0]}
#Alice transaction is committed unaware of the Product state change
DEBUG [main]: o.h.e.t.i.j.JdbcTransaction - committed JDBC Connection

隐式的乐观锁定机制无法检测到外部更改,除非实体也被当前的持久性上下文更改。 为了防止发出过时的Product状态订单,我们需要在Product实体上应用显式锁。

明确锁定救援

Java Persistence LockModeType.OPTIMISTIC是此类情况的合适候选者,因此我们将对其进行测试。

Hibernate带有LockModeConverter实用程序,该实用程序能够将任何Java Persistence LockModeType映射到与其关联的Hibernate LockMode 。

为简单起见,我们将使用特定于Hibernate的LockMode.OPTIMISTIC ,该方法实际上与其Java持久性对应项相同。

根据Hibernate文档,显式的OPTIMISTIC锁定模式将:

假设交易不会对实体产生竞争。 实体版本将在交易结束时进行验证。

我将调整测试用例,改为使用显式OPTIMISTIC锁定:

try {doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session session) {final Product product = (Product) session.get(Product.class, 1L, new LockOptions(LockMode.OPTIMISTIC));executeAndWait(new Callable<Void>() {@Overridepublic Void call() throws Exception {return doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session _session) {Product _product = (Product) _session.get(Product.class, 1L);assertNotSame(product, _product);_product.setPrice(BigDecimal.valueOf(14.49));return null;}});}});OrderLine orderLine = new OrderLine(product);session.persist(orderLine);return null;}});fail("It should have thrown OptimisticEntityLockException!");
} catch (OptimisticEntityLockException expected) {LOGGER.info("Failure: ", expected);
}

新的测试版本生成以下输出:

#Alice selects a Product
Query:{[select abstractlo0_.id as id1_1_0_, abstractlo0_.description as descript2_1_0_, abstractlo0_.price as price3_1_0_, abstractlo0_.version as version4_1_0_ from product abstractlo0_ where abstractlo0_.id=?][1]} #The price engine selects the Product as well
Query:{[select abstractlo0_.id as id1_1_0_, abstractlo0_.description as descript2_1_0_, abstractlo0_.price as price3_1_0_, abstractlo0_.version as version4_1_0_ from product abstractlo0_ where abstractlo0_.id=?][1]} 
#The price engine changes the Product price
Query:{[update product set description=?, price=?, version=? where id=? and version=?][USB Flash Drive,14.49,1,1,0]} 
#The price engine transaction is committed
DEBUG [pool-1-thread-1]: o.h.e.t.i.j.JdbcTransaction - committed JDBC Connection#Alice inserts an OrderLine
Query:{[insert into order_line (id, product_id, unitPrice, version) values (default, ?, ?, ?)][1,12.99,0]} 
#Alice transaction verifies the Product version
Query:{[select version from product where id =?][1]} 
#Alice transaction is rolled back due to Product version mismatch
INFO  [main]: c.v.h.m.l.c.LockModeOptimisticTest - Failure: 
org.hibernate.OptimisticLockException: Newer version [1] of entity [[com.vladmihalcea.hibernate.masterclass.laboratory.concurrency.
AbstractLockModeOptimisticTest$Product#1]] found in database

操作流程如下:

显式锁定锁模式乐观1

在交易结束时检查产品版本。 任何版本不匹配都会触发异常和事务回滚。

比赛条件风险

不幸的是,应用程序级别的版本检查和事务提交不是原子操作。 该检查发生在EntityVerifyVersionProcess中 ,在交易之前提交阶段:

public class EntityVerifyVersionProcess implements BeforeTransactionCompletionProcess {private final Object object;private final EntityEntry entry;/*** Constructs an EntityVerifyVersionProcess** @param object The entity instance* @param entry The entity's referenced EntityEntry*/public EntityVerifyVersionProcess(Object object, EntityEntry entry) {this.object = object;this.entry = entry;}@Overridepublic void doBeforeTransactionCompletion(SessionImplementor session) {final EntityPersister persister = entry.getPersister();final Object latestVersion = persister.getCurrentVersion( entry.getId(), session );if ( !entry.getVersion().equals( latestVersion ) ) {throw new OptimisticLockException(object,"Newer version [" + latestVersion +"] of entity [" + MessageHelper.infoString( entry.getEntityName(), entry.getId() ) +"] found in database");}}
}

调用AbstractTransactionImpl.commit()方法,将执行before-transaction-commit阶段,然后提交实际事务:

@Override
public void commit() throws HibernateException {if ( localStatus != LocalStatus.ACTIVE ) {throw new TransactionException( "Transaction not successfully started" );}LOG.debug( "committing" );beforeTransactionCommit();try {doCommit();localStatus = LocalStatus.COMMITTED;afterTransactionCompletion( Status.STATUS_COMMITTED );}catch (Exception e) {localStatus = LocalStatus.FAILED_COMMIT;afterTransactionCompletion( Status.STATUS_UNKNOWN );throw new TransactionException( "commit failed", e );}finally {invalidate();afterAfterCompletion();}
}

在支票和实际交易提交之间,其他交易在很短的时间内默默地提交产品价格变化。

结论

显式的OPTIMISTIC锁定策略为过时的状态异常提供了有限的保护。 此竞争条件是“检查时间”到“使用时间数据完整性异常”的典型情况。

在下一篇文章中,我将解释如何使用explicit lock upgrade技术保存该示例。

  • 代码可在GitHub上获得 。

翻译自: https://www.javacodegeeks.com/2015/01/hibernate-locking-patterns-how-does-optimistic-lock-mode-work.html

hibernate工厂模式

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/338225.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

php hash pbkdf2,PHP hash_pbkdf2 哈希(Hash)函数

PHP hash_pbkdf2 哈希(Hash)函数发布时间&#xff1a;2020-08-06 09:09:47来源&#xff1a;51CTO阅读&#xff1a;270作者&#xff1a;web全栈定义和用法hash_pbkdf2 - 生成所提供密码的 PBKDF2 密钥导出版本支持PHP4PHP5PHP7不支持V5.5.0支持支持7.2.0 不再支持非加密的哈希函…

using用法是什么?

using用法是&#xff1a;1、命名空间using namespace 命名空间;//这样每次使用命名空间中的变量时就不用指定命名空间了注意&#xff1a;头文件中不应有using命名空间的声明2、类型别名&#xff08;C 11&#xff09;using aa double;//等价于typedef double aatypedef double …

netflix测试能不能看_Netflix监管者测试–引入知事,准官员

netflix测试能不能看考虑一个典型的Netflix Governator junit测试。 public class SampleWithGovernatorJunitSupportTest {Rulepublic LifecycleTester tester new LifecycleTester();Testpublic void testExampleBeanInjection() throws Exception {tester.start();Injecto…

java中vector容器,vector向量容器(常用的使用方法总结)

关于STL中vector容器的学习&#xff0c;编译运行后边看代码&#xff0c;边看执行结果效果更佳&#xff0c;还是想说看别人的代码一百遍&#xff0c;不如自己动手写一遍。vector向量容器不但能像数组一样对元素进行随机访问&#xff0c;还能随时在尾部插入元素&#xff0c;简单而…

学习C ,常见的误解

学习C 你是否会有以下几点误解&#xff1f;1. “要理解C &#xff0c;你必须先学习C”2. “C 是一门面向对象的语言”3. “为了软件可靠性&#xff0c;你需要垃圾回收”4. “为了效率&#xff0c;你必须编写底层代码”5. “C 只适用于大型、复杂的程序”如果你中*了&#xff0c…

openshift使用_OpenShift DIY:使用Gradle构建Spring Boot / Undertow应用程序

openshift使用由于此错误&#xff0c; Gradle 1.6是在OpenShift上运行的最后一个受支持的Gradle版本。 但是从Gradle 2.2开始&#xff0c;这不再是问题&#xff0c;因此&#xff0c;使用自己动手做墨盒&#xff0c;在OpenShift上运行最新的Gradle不再是问题。 DIY盒带是一种实验…

php管理智能dns,负载均衡之DNS轮询

域名注册商都支持对统一主机添加多条A记录&#xff0c;这就是DNS轮询&#xff0c;DNS服务器将解析请求按照A记录的顺序&#xff0c;随机分配到不同的IP上&#xff0c;这样就完成了简单的负载均衡。下图的例子是&#xff1a;有3台联通服务器、3台电信服务器&#xff0c;要实现“…

java ee jsp_EE JSP:使用自定义标签库生成动态内容

java ee jsp在Web应用程序中开发View层时&#xff0c;您希望尽量不要重复JSP文件中的内容。 JSP spec API允许您通过使用标记库来减少这种重复。 定制JSP标记是用户定义的xml标记元素&#xff0c;您可以将其插入JSP文件以替换为某些动态内容。 这是一个使用自定义JSP标记的简单…

php怎么把时间戳转成日期格式,php怎么把时间格式转换为时间戳?,时间戳转为日期...

php怎么把时间格式转换为时间戳&#xff1f;PHP怎么把时间格式转换成时间戳&#xff1f;&#xff0c;php时间格式转换为时间戳的方法&#xff1a;1。使用mktime()将时间转换为时间戳&#xff0c;语法为“mktime(小时、分钟、秒、月、日、年)”&#xff1b;2.使用strtime()将字符…

C语言的标识符由什么组成

C语言的标识符由字母、数字、下划线组成&#xff0c;并且第一个字符必须是字母或下划线&#xff0c;不能是数字。在标识符中&#xff0c;字母的大小写是有区别的&#xff0c;例如BOOK与book是两个不同的标识符。定义变量时&#xff0c;我们使用了诸如 a、abc、mn123 这样的名字…

jdk8读取文件_JDK 7和JDK 8中大行读取速度较慢的原因

jdk8读取文件我早些时候发布了博客文章Reading Large Lines Slower in JDK 7和JDK 8&#xff0c;并且在描述该问题的文章上有一些有用的评论 。 这篇文章提供了更多解释&#xff0c;说明为何该文章中演示的文件读取&#xff08;并由Ant的LineContainsRegExp使用 &#xff09;在…

oracle_sod,oracle geometry几何关系sdo_Geom.Relate介绍,

oracle geometry几何关系sdo_Geom.Relate介绍&#xff0c;sdo_Geom.Relate(sdo_Geometry1, ‘MASK’, sod_Geometry2, tolerance )&#xff1a;用于判断一个几何体与另一个几何体的关系&#xff0c;我们用于判断当前点是否在某一个面(省份面、县市面、乡镇面)上。参数说明&…

C 11 实现的 100行 线程池

C 线程池一直都是各位程序员们造轮子的首选项目之一。今天&#xff0c;小编带大家一起来看看这个轻量的线程池&#xff0c;本线程池是header-only的&#xff0c;并且整个文件只有100行&#xff0c;其中C 的高级用法有很多&#xff0c;很值得我们学习&#xff0c;一起来看看吧。…

oracle把多行合并成字符串,怎样将Oracle多行转换成字符串?

在做一些比较复杂的DB数据导出时&#xff0c;有时会要求“将不固定的多行数据组合成一个字符串返回”。例子&#xff1a;ISV Portal中就遇到了类似的情况&#xff0c;要求对于每一个APP&#xff0c;返回其所属的所有类目名称&#xff0c;类目名称之间用[,]隔开。本文就用此例子…

openshift使用_OpenShift v3:使用WildFly和MySQL的Java EE 7入门

openshift使用OpenShift是Red Hat的开源PaaS平台。 OpenShift v3 &#xff08;将于今年发布&#xff09;将提供使用Docker和Kubernetes运行微服务的整体体验。 以经典的Red Hat方式&#xff0c;所有工作都在OpenShift Origin的开源中完成。 这也将推动OpenShift Online和OpenSh…

c程序的基本组成单位是什么?

C程序是由函数构成的。函数是C程序的基本组成单位。一个C源程序中仅有一个main()函数,除main函数之外可以有若干个其它的函数。每个函数实现某一特定的操作。因此&#xff0c;函数是C程序的基本单位。一个函数由两部分组成&#xff1a;函数的说明部分。包括函数名、函数类型、函…

java多线程 异常处理_Java8多线程ForkJoinPool:处理异常

java多线程 异常处理引入Java8 lambda背后的主要动机之一是能够尽可能轻松地使用多核的能力&#xff08;请参阅精通Lambdas&#xff1a;多核世界中的Java编程 &#xff09;。 只需将代码从collection.stream()...更改为collection.parallelStream()...您就可以使用即时多线程&a…

C语言头文件 “ 细节 ”

很多事不深入以为自己懂了&#xff0c;但真正用到项目上&#xff0c;才发现了问题。曾以为自己写C语言已经轻车熟路了&#xff0c;特别是对软件文件的工程管理上&#xff0c;因为心里对自己的代码编写风格还是有自信的。(毕竟刚毕业时老大对我最初的训练就是编码格式的规范化处…

订阅号微信公众号历史文章爬虫php,一步步教你怎么打造微信公众号历史文章爬虫...

原标题&#xff1a;一步步教你怎么打造微信公众号历史文章爬虫开篇语&#xff1a;邓爷爷曾说过&#xff1a;不管黑猫白猫&#xff0c;逮到耗子就是好猫。不管我是凑的还是笨办法堆出来的&#xff0c;确实把批量导出微信公众号所有历史文章的这个功能给做出来了&#xff0c;而且…

oracle中悲观锁定_如何使用悲观锁定修复乐观锁定竞争条件

oracle中悲观锁定回顾 在我以前的文章中 &#xff0c;我解释了使用显式乐观锁定的好处。 然后我们发现&#xff0c;在很短的时间范围内&#xff0c;并发交易仍可以在我们当前交易被提交之前立即提交产品价格更改。 此问题可以描述如下&#xff1a; 爱丽丝拿产品 然后&#…