jpa mysql乐观锁_【快学springboot】8.JPA乐观锁OptimisticLocking

介绍

当涉及到企业应用程序时,正确地管理对数据库的并发访问是至关重要的。为此,我们可以使用Java Persistence API提供的乐观锁定机制。它导致在同一时间对同一数据进行多次更新不会相互干扰。为了使用OptimisticLocking,我们需要一个实体(Entity),其中包含一个带有@Version注释的属性。在使用它时,每个读取数据的事务都持有version属性的值。在事务想要进行更新之前,它将再次检查version属性。如果值在此期间发生了更改,则抛出ObjectOptimisticLockingFailureException。否则,事务提交update并递增version的值。这种机制适用于读操作比更新或删除操作多得多的应用程序。

新建一个UserEntity.java

@Entity

@Table(name = "user")

@Data

@OptimisticLocking

public class User {

@Id

@GeneratedValue(strategy = GenerationType.SEQUENCE)

private Integer id;

@Column(name = "username", unique = true, nullable = true, length = 50)

private String username;

private String password;

@Version

private Integer version;

@PrePersist

public void prePersist() {

version = 0;

}

}

spring data jpa在上一篇文章已经做过一些讲解了【快学springboot】7.使用Spring Boot Jpa。感兴趣的朋友可以看看。这里定义了一个version字段,使用了Version注解标识。PrePersist这个注解表示在新增数据之前执行。

新建UserRepo接口

public interface UserRepo extends PagingAndSortingRepository, JpaSpecificationExecutor {

}

新建一个UserTest类,继承SpringbootApplicationTests

public class UserTest extends SpringbootApplicationTests {

}

SpringbootApplicationTests这个类是使用Spring initialize新建项目的时候自动生成的用来做单元测试的类。在UserTest上注入UserRepo,并且写一个新增user的单测。

ae46e558066e9080f8a1271a44c3b0bc.png

执行之后查看数据库。

d28a61d4a9626f98429d45b24245d095.png

该记录已经被创建出来了。

测试update该记录

5e58364e695e00b094108687f24f2e0e.png

执行后查看数据库:

ba72cf49143589450bb24bec5fcaa5bd.png

可以看到version字段自增了1。

测试JPA乐观锁

新建一个方法,如下

ad1597f3a7966fc90bd99c07997a3234.png

这里查询了两次id为1的记录,然后分别更新了这条记录。根据前面的描述,这里会抛出一个ObjectOptimisticLockingFailureException异常。启动测试,结果如下:

767859737d24abcdc719021ce693519e.png

这是符合预期的。看下数据库的version,在这种情况下,我们的预期结果是version变为2。

5520bd42897ee5e89977da1e25c15db5.png

通过数据库的值查看,测试都是符合预期的。

去掉User的OptimisticLocking注解

我们把User实体的OptimisticLocking注解去掉,然后再次执行上面的方法。

f005aade4ce2b0d5db1e18bbe40d74c2.png

这一次程序顺利执行了,然后查看下数据库的记录:

预期应该是version会变为3,然后username变为happyjava-new2。

61714cb126509c64197926f225fa684c.png

通过结果来看,这是符合预期的。

总结

spring data jpa通过OptimisticLocking实现了乐观锁,该乐观锁不是通过数据库自身去实现的,它是通过version字段(需要Version注解标识)去实现的。如果update的数据时候,发现数据库的version大于等于当前的version,则会抛出ObjectOptimisticLockingFailureException,错误信息是

Row was updated or deleted by another transaction

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

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

相关文章

UE4 连接自定义服务器

UE4 dedicated server是一个很好的游戏服务器,但是对于大厅和聊天服务器来说,我们要自行开发,通过UE4的socket组建很方便的和其他服务器建立连接 创建Socket FSocket* Socket ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateSocket(NAME_Stream, TEXT("de…

学习笔记-java编程-交通灯管理器设计流程。

先抛出需求: 异步随机生成按照各个路线行驶的车辆。例如: 由南向而来去往北向的车辆 ---- 直行车辆 由西向而来去往南向的车辆 ---- 右转车辆 由东向而来去往南向的车辆 ---- 左转车辆 。。。 信号灯忽略黄灯,只考虑红灯和绿灯。应考虑左转车…

php mysql 库存变负数_php解决秒杀并发入库导致的库存负数

我们知道数据库处理sql是一条条处理的,假设购买商品的流程是这样的:sql1:查询商品库存1 if(库存数量 > 0)2 {3 //生成订单4 //库存-15 >当没有并发时,上面的流程看起来是如此完美,假设同时两个人下单,而库存只有…

Codeforces Testing Round #10 A. Forgotten Episode

水题&#xff0c;注意数据范围 #include <iostream> using namespace std;int main(){long long n,a;cin >> n;long long sum (n*(n1))>>1;for(int i 0 ; i < n-1 ; i){cin >>a;sum -a;}cout<<sum<<endl; } 转载于:https://www.cnblo…

UE4--多线程的实现方式

首先查阅了WIKI中能找到Rama大神的两篇文章&#xff0c;讲了两个开线程的方式&#xff1a; https://wiki.unrealengine.com/Multi-Threading:_Task_Graph_System https://wiki.unrealengine.com/Multi-Threading:_How_to_Create_Threads_in_UE4 TaskGraph与FRunnable的比较 一…

python if else格式_Python if else条件语句详解

我们看到的代码都是顺序执行的&#xff0c;也就是先执行第1条语句&#xff0c;然后是第2条、第3条……一直到最后一条语句&#xff0c;这称为顺序结构。但是对于很多情况&#xff0c;顺序结构的代码是远远不够的&#xff0c;比如一个程序限制了只能成年人使用&#xff0c;儿童因…

UE4 HTC VIVE - 番外篇 - 局域网联机(一)

--------------------引擎环境配置文件修改与项目在线模式启动修改--------------------1&#xff09;我们就直接用默认名创建一个第三人称项目Paste_Image.png2&#xff09;右键资源栏&#xff0c;创建一个新的C类创建一个C类选择不继承任何UE提供的基类3&#xff09;打开【解…

UIImageView 圆角

UIImageView *image [[UIImageView alloc]init]; image.layer.cornerRadius 10.0;//如果想变圆形&#xff0c;设置这个值为宽度的一半 image.layer.masksToBounds YES;转载于:https://www.cnblogs.com/qianyindichang/p/3779823.html

java 参数 string_java(String和StringBuffer分别作为参数传递)

package com.day8.StringBuffer;public class Demo7StringBuffer {/***常见对象(String和StringBuffer分别作为参数传递)* A:形式参数问题* String作为参数传递* StringBuffer作为参数传递* B:案例演示* String和StringBuffer分别作为参数传递问题*( 基本数据类型的值传递&…

UE4 HTC VIVE - 番外篇 - 局域网联机(二)

开始之前先说一下网游中服务器与客户端的大致关系&#xff1a;网络游戏中各段关系图客户端职责&#xff1a;1&#xff09;接收玩家的输入翻译得到【玩家指令】上传服务器&#xff1b;2&#xff09;接收服务器下发的【游戏指令】并将其实现服务器职责&#xff1a;1&#xff09;接…

启动文件、简单的消息框

C中打开文件的方法。 1.system&#xff08;&#xff09;; 函数原型&#xff1a; int system(char *command); 作用&#xff1a;发出一个DOS命令。 特点&#xff1a;该函数是同步的&#xff0c;不灵活。只是能够改为system("start XXX"); 2.WinExec&#xff08;&#…

UE4 HTC VIVE - 番外篇 - 局域网联机三

环境设置和检测1.打开引擎下的在线调试引擎在线模式开启2.打开项目的在线调试项目在线模式开启3.检查机器网段我们需要对每台要加入局域网的机器都进行网段检测&#xff0c;这是能客户端能找到主机广播的前提&#xff0c;否则无法搜到主机Windows键R键输入CMD输入ipconfig检查I…

java异常判断_Java异常退出条件的判断示例代码

无论是功能性代码还是算法性代码&#xff0c;程序都是一系列流程的合集既然是流程就分为&#xff1a;一般流程和异常流程&#xff1b;一般流程保证了基本功能&#xff1b;异常流程则是对程序稳定性的保证&#xff0c;不能因为一些非法输入&#xff0c;项目就挂了&#xff1b;注…

POJ 3225 - 区间

待整理。 转载于:https://www.cnblogs.com/e0e1e/p/poj_3225.html

UE4 HTC VIVE 多人联机

1. editor的VR模式不支持网络&#xff0c;所以在VR模式下没法调试多人联机程序 2. editor的standalone模式&#xff0c;引擎的源码里面把VR模式关闭了&#xff0c;所以需要修改引擎源码 3.可以在命令行下打开VR模式

关于64位Linux配置android开发环境出现 No such file or directory

前几天在64位系统上部署android开发环境的时候出现了这种问题 /aapt: No such file or directory 通过谷老师&#xff0c;知道原理android SDK里面的程序全是32位的&#xff0c;没有64位的。不知道为啥要写个x64&#xff0c; 我们仅仅要安装一下32位的执行库即可了&#xff0c;…

java读取txt文件内容_Java读取TXT文件内容的方法

Java读取txt文件内容。可以作如下理解&#xff1a;首先获得一个文件句柄。File file new File(); file即为文件句柄。两人之间连通电话网络了。接下来可以开始打电话了。通过这条线路读取甲方的信息&#xff1a;new FileInputStream(file) 目前这个信息已经读进来内存当中了。…

UE4 远程调用函数

1. Multicast 如果在服务器端调用&#xff0c;则先在服务器执行此函数&#xff0c;然后自动依次在所有客户端执行此函数。 如果在客户端调用&#xff0c;则只在此客户端执行&#xff0c;服务器和其它客户端都不执行。 2. RunOnServer 不管是服务器端还是客户端&#xff0c;都可…

python有监督神经网络程序实例_学习编程|监督学习是什么?怎么用?Python机器学习基础笔记二...

一、机器学习基础概念1.机器学习分类机器学习分为&#xff1a;监督学习、无监督学习、半监督学习等几类。(1)监督学习&#xff1a;从给定的训练数据集中学习出一个函数&#xff0c;当新的数据到来时&#xff0c;可以根据这个函数预测结果。监督学习的训练集要求是包括输入和输出…

.net开发微信公众平台

一、说明&#xff1a;公众平台信息接口为开发者提供了一种新的消息处理方式&#xff0c;只有申请成为开发者后&#xff0c;你才能使用公众平台的开发功能&#xff0c;在这里你需要填写一个URL和一个Token&#xff0c;这两项信息也需要你拥有自己的服务器&#xff08;外网服务器…