Hibernate锁定模式– OPTIMISTIC_FORCE_INCREMENT锁定模式如何工作

介绍

在我以前的文章中 ,我解释了OPTIMISTIC锁定模式是如何工作的,以及它如何帮助我们同步外部实体状态更改。 在本文中,我们将介绍OPTIMISTIC_FORCE_INCREMENT锁定模式的使用模式。

使用LockModeType.OPTIMISTIC ,将在当前正在运行的事务结束时检查锁定的实体版本,以确保我们不使用陈旧的实体状态。 由于应用程序级验证的性质 ,该策略易受竞争条件的影响,因此需要附加的悲观锁 。

LockModeType.OPTIMISTIC_FORCE_INCREMENT不仅会检查预期的锁定实体版本,还会对其进行递增。 检查和更新都发生在同一UPDATE语句中,因此利用了当前数据库事务隔离级别和关联的物理锁定保证。

值得注意的是,即使当前运行的事务未更改实体状态,锁定的实体版本也会被提高。

集中版本控制用例

作为练习,我们将模拟一个集中化的版本控制系统 ,其建模如下:

存储库提交更改乐观力增量

存储库是我们的系统根实体,每个状态更改都由Commit子实体表示。 每个Commit可能包含一个或多个Change组件,这些组件作为单个原子工作单元传播。

存储库版本随着每个新的Commit而增加。 为简单起见,我们只验证存储库实体版本,尽管更现实的方法肯定会检查每个单独的文件版本(以允许无冲突的提交并发进行)。

测试时间

首先,我们应该检查OPTIMISTIC_FORCE_INCREMENT锁定模式是否符合我们的用例要求:

doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session session) {Repository repository = (Repository) session.get(Repository.class, 1L);session.buildLockRequest(new LockOptions(LockMode.OPTIMISTIC_FORCE_INCREMENT)).lock(repository);Commit commit = new Commit(repository);commit.getChanges().add(new Change("README.txt", "0a1,5..."));commit.getChanges().add(new Change("web.xml", "17c17..."));session.persist(commit);return null;}
});

此代码生成以下输出:

#Alice selects the Repository and locks it using an OPTIMISTIC_FORCE_INCREMENT Lock Mode
Query:{[select lockmodeop0_.id as id1_2_0_, lockmodeop0_.name as name2_2_0_, lockmodeop0_.version as version3_2_0_ from repository lockmodeop0_ where lockmodeop0_.id=?][1]} #Alice makes two changes and inserts a new Commit
Query:{[select lockmodeop0_.id as id1_2_0_, lockmodeop0_.name as name2_2_0_, lockmodeop0_.version as version3_2_0_ from repository lockmodeop0_ where lockmodeop0_.id=?][1]} 
Query:{[insert into commit (id, repository_id) values (default, ?)][1]} 
Query:{[insert into commit_change (commit_id, diff, path) values (?, ?, ?)][1,0a1,5...,README.txt]} 
Query:{[insert into commit_change (commit_id, diff, path) values (?, ?, ?)][1,17c17...,web.xml]} #The Repository version is bumped up
Query:{[update repository set version=? where id=? and version=?][1,1,0]}

我们的用户选择了一个存储库并发布了一个新的Commit 。 在交易结束时, 存储库版本也会增加(因此记录新的存储库状态更改)。

冲突检测

在下一个示例中,我们将有两个用户(爱丽丝和鲍勃)同时提交更改。 为了避免丢失更新 ,两个用户都获得了显式的OPTIMISTIC_FORCE_INCREMENT锁定模式。

在Alice获得提交机会之前,Bob刚刚完成了交易并增加了Repository版本。 Alice事务将回滚,并引发不可恢复的 StaleObjectStateException

显式锁定乐观力增量1

为了模拟冲突检测机制,我们将使用以下测试方案:

doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session session) {Repository repository = (Repository) session.get(Repository.class, 1L);session.buildLockRequest(new LockOptions(LockMode.OPTIMISTIC_FORCE_INCREMENT)).lock(repository);executeAndWait(new Callable<Void>() {@Overridepublic Void call() throws Exception {return doInTransaction(new TransactionCallable<Void>() {@Overridepublic Void execute(Session _session) {Repository _repository = (Repository) _session.get(Repository.class, 1L);_session.buildLockRequest(new LockOptions(LockMode.OPTIMISTIC_FORCE_INCREMENT)).lock(_repository);Commit _commit = new Commit(_repository);_commit.getChanges().add(new Change("index.html", "0a1,2..."));_session.persist(_commit);return null;}});}});Commit commit = new Commit(repository);commit.getChanges().add(new Change("README.txt", "0a1,5..."));commit.getChanges().add(new Change("web.xml", "17c17..."));session.persist(commit);return null;}
});

生成以下输出:

#Alice selects the Repository and locks it using an OPTIMISTIC_FORCE_INCREMENT Lock Mode
Query:{[select lockmodeop0_.id as id1_2_0_, lockmodeop0_.name as name2_2_0_, lockmodeop0_.version as version3_2_0_ from repository lockmodeop0_ where lockmodeop0_.id=?][1]} #Bob selects the Repository and locks it using an OPTIMISTIC_FORCE_INCREMENT Lock Mode
Query:{[select lockmodeop0_.id as id1_2_0_, lockmodeop0_.name as name2_2_0_, lockmodeop0_.version as version3_2_0_ from repository lockmodeop0_ where lockmodeop0_.id=?][1]} #Bob makes a change and inserts a new Commit
Query:{[insert into commit (id, repository_id) values (default, ?)][1]} 
Query:{[insert into commit_change (commit_id, diff, path) values (?, ?, ?)][1,0a1,2...,index.html]} #The Repository version is bumped up to version 1
Query:{[update repository set version=? where id=? and version=?][1,1,0]} #Alice makes two changes and inserts a new Commit
Query:{[insert into commit (id, repository_id) values (default, ?)][1]} 
Query:{[insert into commit_change (commit_id, diff, path) values (?, ?, ?)][2,0a1,5...,README.txt]} 
Query:{[insert into commit_change (commit_id, diff, path) values (?, ?, ?)][2,17c17...,web.xml]} #The Repository version is bumped up to version 1 and a conflict is raised
Query:{[update repository set version=? where id=? and version=?][1,1,0]} 
INFO  [main]: c.v.h.m.l.c.LockModeOptimisticForceIncrementTest - Failure: 
org.hibernate.StaleObjectStateException: Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect) : 
[com.vladmihalcea.hibernate.masterclass.laboratory.concurrency.
LockModeOptimisticForceIncrementTest$Repository#1]

此示例表现出与典型的隐式乐观锁定机制相同的行为。 唯一的区别在于版本更改发起者。 尽管隐式锁定仅适用于修改实体,但显式锁定可以跨任何托管实体使用(不考虑实体状态更改要求)。

结论

因此, OPTIMISTIC_FORCE_INCREMENT对于将子实体状态更改传播到未修改的父实体非常有用。 通过简单地锁定它们的公共父代,此模式可以帮助我们同步各种实体类型。

当子实体状态更改必须触发父实体版本增加时,您可能要遵循显式的OPTIMISTIC_FORCE_INCREMENT锁定模式。

  • 代码可在GitHub上获得 。

翻译自: https://www.javacodegeeks.com/2015/02/hibernate-locking-patterns-optimistic_force_increment-lock-mode-work.html

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

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

相关文章

c语言的输入输出语句有哪些?

c语言的输入输出语句有&#xff1a;“getchar(void);”和“putchar(int c);”、“scanf("格式控制字符串",地址列表);”和“printf("格式控制字符串",输出列表);”、“gets()”和“puts()”等等。一&#xff1a;控制台输入输出(1)字符数据的输入/输出字符输…

primefaces_PrimeFaces:在动态生成的对话框中打开外部页面

primefaces我已经在即将出版的PrimeFaces Cookbook版本2中写过一篇食谱的博客。 在这篇文章中&#xff0c;我想发表第二篇关于一个名为Dialog Framework的小型框架的文章。 我个人喜欢它&#xff0c;因为我记得我为使用Struts框架付出同样的代价。 当您想将外部页面加载到弹出窗…

c语言源文件经过编译后生成文件的后缀是什么?

c语言源文件经过编译后&#xff0c;生成文件的后缀是“.obj”。C语言源文件后缀名是“.c”&#xff0c;编译生成的文件后缀名是“.obj”&#xff0c;连接后可执行文件的后缀名是“.exe”。C语言创建程序的步骤&#xff1a;编辑&#xff1a;就是创建和修改C程序的源代码-我们编写…

java编译器jdk版本_以编程方式确定Java类的JDK编译版本

java编译器jdk版本当需要确定使用哪个JDK版本来编译特定的Java .class文件时&#xff0c; 通常使用的方法是使用javap并在javap输出中查找列出的“主要版本”。 我在我的博客文章Autoboxing&#xff0c;Unboxing和NoSuchMethodError中引用了这种方法&#xff0c;但是在继续以编…

c语言指针用法有哪些

c语言指针用法&#xff1a;一&#xff0c;指针定义&#xff1a;指针变量的取值范围取值0~4G,是一种数据类型&#xff08;无符号整数&#xff0c;代表了内存编号&#xff09;。它可以用来定义变量&#xff08;与int、long一样&#xff09;&#xff0c;与int、long不同的它存储整…

ogm session_带有Hibernate OGM的NoSQL –第一部分:持久化您的第一个实体

ogm sessionHibernate OGM的第一个最终版本已经发布 &#xff0c;团队从发布狂潮中恢复了一些。 因此&#xff0c;他们考虑开设一系列教程风格的博客&#xff0c;使您有机会轻松地从Hibernate OGM重新开始。 感谢Gunnar Morling&#xff08; gunnarmorling &#xff09;创建了本…

c语言volatile关键字的作用是什么?

一.前言1.编译器优化介绍&#xff1a;由于内存访问速度远不及CPU处理速度&#xff0c;为提高机器整体性能&#xff0c;在硬件上引入硬件高速缓存Cache&#xff0c;加速对内存的访问。另外在现代CPU中指令的执行并不一定严格按照顺序执行&#xff0c;没有相关性的指令可以乱序执…

jaxb解析字符串xml_一个JAXB Nuance:字符串与枚举(受限制的XSD字符串)的枚举

jaxb解析字符串xml尽管用于XML绑定的Java体系结构 &#xff08; JAXB &#xff09;在名义情况下&#xff08;尤其是自Java SE 6以来&#xff09; 相当容易使用&#xff0c;但它也存在许多细微差别。 一些常见的细微差别是由于无法将 XML架构定义 &#xff08;XSD&#xff09;类…

php伪静态后不能访问html,php伪静态后html不能访问怎么办

php伪静态后html不能访问的解决办法&#xff1a;首先判断文件是否存在&#xff1b;然后设置存在则不rewirte&#xff0c;不存在且符合规则才rewrite&#xff1b;最后修改htaccess文件即可。推荐&#xff1a;《PHP视频教程》具体问题&#xff1a;PHP伪静态后不能访问纯html文件.…

c语言中,char型数据是以什么形式存储的?

C语言 字符型&#xff08;char&#xff09;简介字符型&#xff08;char&#xff09;用于储存字符&#xff08;character&#xff09;&#xff0c;如英文字母或标点。严格来说&#xff0c;char 其实也是整数类型&#xff08;integer type&#xff09;&#xff0c;因为char 类型储…

声明式编程与函数式编程_实用程序类与函数式编程无关

声明式编程与函数式编程最近&#xff0c;我被指控反对函数式编程&#xff0c;因为我将实用程序类称为反模式 。 绝对是错的&#xff01; 好吧&#xff0c;我确实认为它们是一个糟糕的反模式&#xff0c;但是它们与函数式编程无关。 我相信有两个基本原因。 首先&#xff0c;函数…

C语言中位运算符有哪些

C语言中位运算符有&#xff1a;位操作是程序设计中对位模式按位或二进制数的一元和二元操作。在许多古老的微处理器上&#xff0c; 位运算比加减运算略快&#xff0c; 通常位运算比乘除法运算要快很多。在现代架构中&#xff0c; 情况并非如此&#xff1a;位运算的运算速度通常…

jsf表单验证_JSF:在正确的阶段进行验证(了解生命周期)

jsf表单验证嗨&#xff0c;大家好&#xff01; 尽管标题强调验证一词&#xff0c;但本文实际上是关于JSF生命周期的。 那是因为我相信&#xff0c;真正了解生命周期的最简单方法之一就是通过做出我们一直在做的事情&#xff1a;验证用户输入。 通常&#xff0c;了解所谓的JSF…

java广度优先爬虫示例,【爬虫】广度优先遍历抓取数据概述

这次都是一些纯语言的表达&#xff0c;可能会有点啰嗦&#xff0c;或者有点枯燥&#xff0c;也是对爬虫的一些小小的见解&#xff0c;可能只是一些常见话&#xff0c;哈哈&#xff0c;还是耐心的写完。网络爬虫的整体执行流程&#xff1a;1)确定一个(多个)种子网页2)进行数据内…

if语句的用法是什么

if语句的用法&#xff1a;if语句是指编程语言&#xff08;包括c语言、C#、VB、java、汇编语言等&#xff09;中用来判定所给定的条件是否满足&#xff0c;根据判定的结果&#xff08;真或假&#xff09;决定执行给出的两种操作之一。if语句概述if语句是指编程语言&#xff08;包…

c语言如何实现玫瑰花

c语言实现玫瑰花的方法&#xff1a;#include #include ?#include #include #include #pragma comment(lib,"winmm.lib")//定义全局变量int rosesize 500;int h -250;//定义结构体struct DOT {double x;double y;double z;double r;double g;};bool calc(double a,…

maven 部署nexus_设置本地Nexus存储库并从Maven部署WAR文件

maven 部署nexusMaven Central充当中央存储库管理器&#xff0c;二进制文件由不同的团队/公司/个人上载并与世界其他地方共享。 就像github和其他对源代码控制非常有效的源代码存储库一样&#xff0c;这些存储库管理器还充当您自己生成的二进制工件的部署目标。 设置本地存储库…

c vector用法是什么

在c 中&#xff0c;vector是一个十分有用的容器&#xff0c;c vector用法是&#xff1a;1、基本操作(1)头文件#include.(2)创建vector对象&#xff0c;vector vec;(3)尾部插入数字&#xff1a;vec.push_back(a);(4)使用下标访问元素&#xff0c;cout<<vec[0]<<endl…

c语言for循环如何打印菱形

c语言for循环打印菱形的方法&#xff1a;使用两个for循环&#xff0c;实现条件判断&#xff0c;代码为【int i,j;for(i0; i<2*n-1; i )_(in-i-1&&jc语言for循环打印菱形的方法&#xff1a;方法一&#xff08;以循环为主打印&#xff09;#include void print(int n) …

quasar 异步回调_Java IO基准测试:Quasar与异步ForkJoinPool与ManagedBlock

quasar 异步回调“ Arien看到了我们运行的parallelStreams和ForkJoin基准测试的结果后&#xff0c;在Twitter上与我们联系。 这激起了他的兴趣&#xff0c;因此他进行了一些自己的测试&#xff0c;将Quasar纤维加入了混合物。 这是他的结果和结论。” –塔基皮&#xff08;Taki…