【Spring Boot 快速入门】十八、Spring Boot 集成Mybatis_Plus的乐观锁

简介: 【Spring Boot 快速入门】十八、Spring Boot 集成Mybatis_Plus的乐观锁

前言


  在操作关系数据库管理系统里,经常会遇到锁的问题,在数据库中有行锁、页锁和表锁。在Java的开发过程中,经常会遇到悲观锁和乐观锁。乐观锁和悲观锁对于理解Java多线程、并发和数据库来说至关重要。下面和大家已起聊聊关于Mybatis_Plus乐观锁。


数据库锁


  锁是数据库中的一个重要的概念,在大数据高并发的情况下,如果同一条数据被多个线程读取,可能会出现幻读、脏读、误读的情况。所以引入了锁。在程序员操作方面,可以根据锁的使用分类悲观锁和乐观锁。

  悲观锁总是认为最坏的情况会出现,当前的数据可能被修改,从而在读取数据的时候就会把资源或者数据进行锁定,其他线程使用这个数据或者资源的时候就会阻塞等待,直到悲观锁将锁释放之后,其他资源才可以使用。

  乐观锁与悲观锁正好相反,乐观锁总是认为资源和数据不会被修改,在读取数据和资源时不会进行加锁。但是乐观锁是在写入操作的时候会判断当前数据和资源是否修改过。乐观锁的实现方案一般来说有两种: 版本号机制 和 CAS实现 。

  在我们的项目中,使用Mybatis_Plus敏捷开发,近期学习了一下基于Mybatis_Plus的乐观锁,下面快速开始熟悉吧。


快速开始


版本介绍


  本次将基于Spring Boot 搭建一个学习Mybatis_Plus的乐观锁的Demo。开发环境如下:


JDK1.8
SpringBoot 2.3.0.RELEASE
mybatis-plus 3.3.0

  

Mybatis_Plus的乐观锁的实现原理是基于版本号机制进行控制的。当在取出一条数据后,将对该条数据进行更新修改操作,会获取当前数据的version版本号,在更新时带上version版本号信息,执行更新时,会判断当前的version版本号与数据库中的版本号是否一致,一致则更新成功version版本号+1,如果version版本号信息不一致,则证明数据被修改过,更新数据失败。了解了原理,下面快速开始。


引入依赖


本次学习使用的依赖包如下:


<dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.3.0</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-generator</artifactId>
            <version>3.3.0</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-extension</artifactId>
            <version>3.4.0</version>
        </dependency>


配置乐观锁


在项目中配置乐观锁的拦截器信息如下:


@Component
public class MybatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }
}


指定版本号


  在我们数据库的实体对象中指定一个版本号字段,并用注解@Version注释该字段。@Version注释的字段类型支持:int,Integer,long,Long,Date,Timestamp,LocalDateTime,在整数类型下newVersion = oldVersion + 1会自动递增版本号,需要注意的是仅支持updateById()和update(entity, wrapper)方法。 本次建立一个User对象。

@ApiModel(value = "com-example-demo-module-User")
@TableName("user")
public class User {
    @TableId(value = "id", type = IdType.INPUT)
    private Integer id;
    @TableField(value = "name")
    private String name;
    @TableField(value = "age")
    private int age;
    @Version
    private int version;
}


单元测试


编写完如上基本配置之后,就可以进行简单的单元测试了。首先我们创建一个用户信息。

@Test
    void TestUser(){
        User user = new User();
        user.setName("测试1");
        user.setAge(12);
        userMapper.insert(user);
    }


可以看到用户“测试1”已经新增成功,当前的用户id是19。


image.png

编写单元测试二,本次更新2次id为19的用户信息。


@Test
    void TestUser(){
        User user = userService.getById(19);
        System.out.println(user);
        //开始更新一次
        userService.updateByTest(user);
        user.setName("测试32222");
        userService.updateById(user);
        User user1 = userService.getById(user.getId());
        System.out.println("第二个更新的方法:" +user1);
    }


运行结果如下,可以看到版本号已经进行了自动更新:

image.png

User{id=19, name='测试32222', age=12, version=0}
第一个更新的方法:User{id=19, name='123456', age=12, version=1}
第二个更新的方法:User{id=19, name='测试32222', age=12, version=2}


结语


  好了,以上就是Spring Boot 集成Mybatis_Plus的乐观锁


目录
相关文章
|
13天前
|
Java 关系型数据库 MySQL
SpringBoot 通过集成 Flink CDC 来实时追踪 MySql 数据变动
通过详细的步骤和示例代码,您可以在 SpringBoot 项目中成功集成 Flink CDC,并实时追踪 MySQL 数据库的变动。
106 43
|
18天前
|
SQL Java 数据库连接
对Spring、SpringMVC、MyBatis框架的介绍与解释
Spring 框架提供了全面的基础设施支持,Spring MVC 专注于 Web 层的开发,而 MyBatis 则是一个高效的持久层框架。这三个框架结合使用,可以显著提升 Java 企业级应用的开发效率和质量。通过理解它们的核心特性和使用方法,开发者可以更好地构建和维护复杂的应用程序。
107 29
|
15天前
|
监控 前端开发 Java
SpringBoot集成Tomcat、DispatcherServlet
通过这些配置,您可以充分利用 Spring Boot 内置的功能,快速构建和优化您的 Web 应用。
47 21
|
1月前
|
监控 Java Nacos
使用Spring Boot集成Nacos
通过上述步骤,Spring Boot应用可以成功集成Nacos,利用Nacos的服务发现和配置管理功能来提升微服务架构的灵活性和可维护性。通过这种集成,开发者可以更高效地管理和部署微服务。
196 17
|
1月前
|
XML JavaScript Java
SpringBoot集成Shiro权限+Jwt认证
本文主要描述如何快速基于SpringBoot 2.5.X版本集成Shiro+JWT框架,让大家快速实现无状态登陆和接口权限认证主体框架,具体业务细节未实现,大家按照实际项目补充。
80 11
|
29天前
|
前端开发 Java 数据库连接
Java后端开发-使用springboot进行Mybatis连接数据库步骤
本文介绍了使用Java和IDEA进行数据库操作的详细步骤,涵盖从数据库准备到测试类编写及运行的全过程。主要内容包括: 1. **数据库准备**:创建数据库和表。 2. **查询数据库**:验证数据库是否可用。 3. **IDEA代码配置**:构建实体类并配置数据库连接。 4. **测试类编写**:编写并运行测试类以确保一切正常。
52 2
|
4月前
|
Java Maven Docker
gitlab-ci 集成 k3s 部署spring boot 应用
gitlab-ci 集成 k3s 部署spring boot 应用
|
3月前
|
消息中间件 监控 Java
您是否已集成 Spring Boot 与 ActiveMQ?
您是否已集成 Spring Boot 与 ActiveMQ?
77 0
|
7月前
|
监控 druid Java
spring boot 集成配置阿里 Druid监控配置
spring boot 集成配置阿里 Druid监控配置
350 6
|
7月前
|
Java 关系型数据库 MySQL
如何实现Springboot+camunda+mysql的集成
【7月更文挑战第2天】集成Spring Boot、Camunda和MySQL的简要步骤: 1. 初始化Spring Boot项目,添加Camunda和MySQL驱动依赖。 2. 配置`application.properties`,包括数据库URL、用户名和密码。 3. 设置Camunda引擎属性,指定数据源。 4. 引入流程定义文件(如`.bpmn`)。 5. 创建服务处理流程操作,创建控制器接收请求。 6. Camunda自动在数据库创建表结构。 7. 启动应用,测试流程启动,如通过服务和控制器开始流程实例。 示例代码包括服务类启动流程实例及控制器接口。实际集成需按业务需求调整。
510 4