MyBatis-Plus（Ⅵ）插件

目录

一、分页插件

1.添加配置类

2.在测试类测试

结果

二、xml实现分页的自定义

1.UserMapper中定义接口方法

2.创建UserMapper.xml文件

 3.在测试类测试

结果

 三、乐观锁

1.场景

2.乐观锁与悲观锁

 3.模拟修改冲突

数据库中添加商品表

添加数据

添加实体类

添加mapper

测试

结果

 乐观锁实现流程

4.Mybatis-Plus实现乐观锁

首先修改实体类

 添加乐观锁插件配置

测试 

结果

一、分页插件

MyBatis Plus自带分页插件，只要简单的配置即可实现分页功能。

1.添加配置类

package com.example.mybatisplus.config;import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 此配置类的作用是向 Spring 容器注册一个 MybatisPlusInterceptor 拦截器，* 该拦截器会在执行 SQL 时拦截分页查询语句，* 并自动处理分页逻辑，包含计算总记录数、总页数等。* */
@Configuration
public class MyBatisPlusConfig {@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));return interceptor;}
}

2.在测试类测试

package com.example.mybatisplus;import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.example.mybatisplus.entity.User;
import com.example.mybatisplus.mapper.UserMapper;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import java.util.*;@SpringBootTest
public class Test4{@AutowiredUserMapper userMapper;@Testpublic void testPage(){//设置分页参数Page<User> page = new Page<>(1, 5);userMapper.selectPage(page, null);//获取分页数据List<User> list = page.getRecords();list.forEach(System.out::println);System.out.println("当前页："+page.getCurrent());System.out.println("每页显示的条数："+page.getSize());System.out.println("总记录数："+page.getTotal());System.out.println("总页数："+page.getPages());System.out.println("是否有上一页："+page.hasPrevious());System.out.println("是否有下一页："+page.hasNext());}
}
结果

二、xml实现分页的自定义

1.UserMapper中定义接口方法

/*** 根据年龄查询用户列表，分页显示* @param page 分页对象 ,xml中可以从里面进行取值 ,传递参数 Page 即自动分页 ,必须放在第一位* @param age 年龄* @return */Page<User> selectPageVo(@Param("page") Page<User> page, @Param("age") Integer age);

 即：

2.创建UserMapper.xml文件

在这里面能配置分页的条件：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.example.mybatisplus.mapper.UserMapper"><!--SQL片段，记录基础字段--><sql id="BaseColumns">id,name,age,email</sql><!--IPage<User> selectPageVo(Page<User> page, Integer age);--><select id="selectPageVo" resultType="com.example.mybatisplus.entity.User">SELECT <include refid="BaseColumns"></include> FROM t_user WHERE age > #{age}</select></mapper>

 3.在测试类测试

  @Testpublic void testSelectPageVo(){//设置分页参数Page<User> page = new Page<>(1, 5);userMapper.selectPageVo(page, 20);//获取分页数据List<User> list = page.getRecords();list.forEach(System.out::println);System.out.println("当前页："+page.getCurrent());System.out.println("每页显示的条数："+page.getSize());System.out.println("总记录数："+page.getTotal());System.out.println("总页数："+page.getPages());System.out.println("是否有上一页："+page.hasPrevious());System.out.println("是否有下一页："+page.hasNext());}
结果

因为加了age的限制，所以这里查询出来去分页的数据就变少了

 三、乐观锁

1.场景

一件商品，成本价是80元，售价是100元。老板先是通知小李，说你去把商品价格增加50元。小 李正在玩游戏，耽搁了一个小时。正好一个小时后，老板觉得商品价格增加到150元，价格太

高，可能会影响销量。又通知小王，你把商品价格降低30元。

此时，小李和小王同时操作商品后台系统。小李操作的时候，系统先取出商品价格100元；小王  也在操作，取出的商品价格也是100元。小李将价格加了50元，并将100+50=150元存入了数据  库；小王将商品减了30元，并将100-30=70元存入了数据库。是的，如果没有锁，小李的操作就 完全被小王的覆盖了。

那么现在商品价格是70元，比成本价低10元。几分钟后，这个商品很快出售了1千多件商品，老板亏1 万多。

2.乐观锁与悲观锁

上面的故事，如果是乐观锁，小王保存价格前，会检查下价格是否被人修改过了。如果被修改过了，则重新取出的被修改后的价格，150元，这样他会将120元存入数据库。

如果是悲观锁，小李取出数据后，小王只能等小李操作完之后，才能对价格进行操作，也会保证最终的价格是120元。

特性悲观锁乐观锁
锁定时机读取数据时锁定更新数据时检查
冲突预防通过锁定数据来预防冲突通过检测数据变更来处理冲突
性能通常性能较低，因为涉及到锁的获取和释放通常性能较高，因为没有锁的开销
适用场景高冲突环境，写操作频繁低冲突环境，读操作频繁
实现方式数据库锁机制，如行锁、表锁版本号或时间戳等机制
用户体验用户可能感知到锁的存在，如长时间等待用户通常感知不到锁的存在
数据一致性强一致性保证最终一致性，依赖于冲突检测和处理

 3.模拟修改冲突

数据库中添加商品表

CREATE TABLE t_product
(
id BIGINT(20) NOT NULL COMMENT '主键ID',
NAME VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名称 ',
price INT(11) DEFAULT 0 COMMENT '价格 ',
VERSION INT(11) DEFAULT 0 COMMENT '乐观锁版本号 ',
PRIMARY KEY (id)
);

添加数据

INSERT INTO t_product (id, NAME, price) VALUES (1, '外星人笔记本 ', 100);

添加实体类

package com.example.mybatisplus.entity;import lombok.*;@Data //lombok注解
@AllArgsConstructor
@NoArgsConstructor
@Getter
@Setter
@ToString
public class Product {private Long id;private String name;private Integer price;private Integer version;
}

添加mapper

package com.example.mybatisplus.mapper;import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.mybatisplus.entity.Product;@Repository
public interface ProductMapper extends BaseMapper<Product> {}

测试

package com.example.mybatisplus;import com.example.mybatisplus.entity.Product;
import com.example.mybatisplus.mapper.ProductMapper;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest
public class Test5 {@AutowiredProductMapper productMapper;@Testpublic void testConcurrentUpdate() {//1、小李Product p1 = productMapper.selectById(1L);System.out.println("小李取出的价格：" + p1.getPrice());//2、小王Product p2 = productMapper.selectById(1L);System.out.println("小王取出的价格：" + p2.getPrice());//3、小李将价格加了50元，存入了数据库p1.setPrice(p1.getPrice() + 50);int result1 = productMapper.updateById(p1);System.out.println("小李修改结果：" + result1);//4、小王将商品减了30元，存入了数据库p2.setPrice(p2.getPrice() - 30);int result2 = productMapper.updateById(p2);System.out.println("小王修改结果：" + result2);//最后的结果Product p3 = productMapper.selectById(1L);//价格覆盖，最后的结果：70System.out.println("最后的结果：" + p3.getPrice());}}
结果

这里为了查看方便，我先将配置文件中的日志关闭了。

关一下日志

可以清晰看出变化结果： 

没有锁的情况下

 乐观锁实现流程

数据库中添加version字段（当然这个咱们在创建时已经创了）

取出记录时，获取当前version

SELECT id,`name`,price,`version` FROM product WHERE id=1

更新时， version + 1，如果where语句中的version版本不对，则更新失败

UPDATE product SET price=price+50, `version`=`version` + 1 WHERE id=1 AND `version`=1

4.Mybatis-Plus实现乐观锁

首先修改实体类

为version字段添加@Version注解

 添加乐观锁插件配置

在方才的分页配置这里加一条：

//添加乐观锁插件
interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
不用令写，加一条就行

测试 

当然在测试之前，先将数据调回100：

然后再进行测试： 

/***乐观锁版本* */@Testpublic void testConcurrentVersionUpdate() {//小李取数据Product p1 = productMapper.selectById(1L);//小王取数据Product p2 = productMapper.selectById(1L);//小李修改 + 50p1.setPrice(p1.getPrice() + 50);int result1 = productMapper.updateById(p1);System.out.println("小李修改的结果：" + result1);//小王修改 - 30p2.setPrice(p2.getPrice() - 30);int result2 = productMapper.updateById(p2);System.out.println("小王修改的结果：" + result2);if(result2 == 0){//失败重试，重新获取version并更新p2 = productMapper.selectById(1L);p2.setPrice(p2.getPrice() - 30);result2 = productMapper.updateById(p2);}System.out.println("小王修改重试的结果：" + result2);//老板看价格Product p3 = productMapper.selectById(1L);System.out.println("老板看价格：" + p3.getPrice());}
结果
达成了预想结果

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

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

相关文章

火山引擎云上实战： DeepSeek R1 大模型（全尺寸）

火山引擎云上实战： DeepSeek R1 大模型（全尺寸）

本文将介绍两种在火山引擎云上部署 DeepSeek-R1 全尺寸模型服务的方案&#xff0c;涵盖大模型推理服务的 Terraform 一键部署、容器化部署、资源弹性伸缩和模型可观测。 来源 | 火山引擎云基础 在 AI 大模型日新月异的当下&#xff0c;企业在使用大模型时往往面临着数据隐私保…
阅读更多...
vue遗漏的知识点(动态组件.)

vue遗漏的知识点(动态组件.)

----动态组件&#xff08;vue2vue3通用&#xff09; <component :is"..."> 的作用 <component> 是 Vue 的内置组件&#xff0c;用于动态渲染其他组件。:is 属性 用于指定要渲染的组件。它的值可以是&#xff1a; 组件的名称&#xff08;字符串&#xf…
阅读更多...
工作流引擎Flowable介绍及SpringBoot整合使用实例

工作流引擎Flowable介绍及SpringBoot整合使用实例

Flowable简介 Flowable 是一个轻量级的业务流程管理&#xff08;BPM&#xff09;和工作流引擎&#xff0c;基于 Activiti 项目发展而来&#xff0c;专注于提供高性能、可扩展的工作流解决方案。它主要用于企业级应用中的流程自动化、任务管理和审批流等场景。 Flowable 的核心…
阅读更多...
【uni-app】引用公共组件

【uni-app】引用公共组件

目录 一、建立公共组件 1.1新建vue文件 1.2编写公共文件代码 1.3使用 注意事项 一、建立公共组件 1.1新建vue文件 在公共组件文件目录下新建所需要的功能文件 1.2编写公共文件代码 按需求写对应功能的代码 1.3使用 在需要使用的文件下引用公共组件 注意事项 想要使用s…
阅读更多...
STL中vector模拟实现

STL中vector模拟实现

vector各个接口函数 //构造函数 vector() vector(size_t n,const T& valT()) vector(int n,const T& val T()) //拷贝构造函数 vector(const vector<T>& v) //迭代器版本的 vector(inputiterator first, inputiterator end) //赋值运算符重载 vector<T&…
阅读更多...
DML 数据操纵语言学习笔记

DML 数据操纵语言学习笔记

一、DML 核心概念体系 1.1 语言定位与边界 DML&#xff08;Data Manipulation Language&#xff09;作为 SQL 三大核心语言之一&#xff0c;专注于数据行级操作&#xff0c;区别于 DDL&#xff08;结构定义&#xff09;和 DCL&#xff08;权限控制&#xff09;。其核心指令包…
阅读更多...
springboot的跨域是什么？遇到跨域问题如何解决？

springboot的跨域是什么？遇到跨域问题如何解决？

在Spring Boot中&#xff0c;跨域是指当浏览器中的前端应用&#xff08;如运行在某个域名和端口下的前端页面&#xff09;请求后端接口时&#xff0c;如果后端接口所在的域名、端口或协议与前端应用不一致&#xff0c;浏览器会阻止这种跨域请求。这是由于浏览器的同源策略&…
阅读更多...
啸叫抑制（AFS）从算法仿真到工程源码实现-第八节-系统搭建

啸叫抑制（AFS）从算法仿真到工程源码实现-第八节-系统搭建

一、概述 系统分为录音模块、数据处理模块、播音模块。录音模块和播音模块使用alsa库进行读写数据。各模块为独立进程处理&#xff0c;模块之间使用命名管道进行数据的传输。数据处理模块我们使用基于频域的自适应滤波去啸叫算法。 二、工程实现 2.1 系统流程图 2.2 录音模块…
阅读更多...
HTML——什么是块级元素，什么是内联元素，有何区别

HTML——什么是块级元素，什么是内联元素，有何区别

在 HTML 中&#xff0c;块级元素&#xff08;Block-level element&#xff09;和内联元素&#xff08;Inline element&#xff09;是两种不同类型元素&#xff0c;它们在页面布局和样式应用方面有不同的行为和特性。 块级元素&#xff08;Block-level element&#xff09; 块级…
阅读更多...
01 设计模式和设计原则

01 设计模式和设计原则

类设计原则&#xff1a; 单一职责原则&#xff08;Single Responsibility Principle&#xff0c;SRP&#xff09;&#xff1a;实现类要职责单一开闭原则&#xff08;Open Close Principle&#xff0c;OCP&#xff09;&#xff1a;对扩展开放&#xff0c;对修改关闭里氏替换原则…
阅读更多...
【踩坑日记】springboot 打包后实现类无法找到

【踩坑日记】springboot 打包后实现类无法找到

试过了所有改什么目录 依赖 clean都以失败告终 最后将实现类的文件名从Impl改成impl宣布成功 记得使用idea自带的重构
阅读更多...
项目-苍穹外卖（十五) WebSocket+语音播报功能实现（来订单+催单）

项目-苍穹外卖（十五) WebSocket+语音播报功能实现（来订单+催单）

一、介绍 二、入门案例 配置类&#xff1a; package com.sky.config;import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.server.standard.ServerEndpointExporter;/…
阅读更多...
【Spring篇】Spring的生命周期

【Spring篇】Spring的生命周期

一、Bean 生命周期的核心阶段 1. 实例化&#xff08;Instantiation&#xff09; • 触发时机&#xff1a;容器启动时&#xff08;单例 Bean&#xff09;或请求时&#xff08;原型 Bean&#xff09;。 • 实现方式&#xff1a; 通过反射&#xff08;Class.newInstance() 或构造…
阅读更多...
Redis、Memcached应用场景对比

Redis、Memcached应用场景对比

环境 Redis官方网站&#xff1a; Redis - The Real-time Data Platform Redis社区版本下载地址&#xff1a;Install Redis | Docs Memcached官方网站&#xff1a;memcached - a distributed memory object caching system Memcached下载地址&#xff1a;memcached - a dis…
阅读更多...
kettle插件-mysql8数据库插件

kettle插件-mysql8数据库插件

场景&#xff1a;群里有小伙伴反馈kettle 7.x版本不能自动连接mysql8&#xff0c;安排&#xff01;&#xff01;&#xff01; 1、将mysql8的驱动包mysql-connector-java-8.0.20.jar丢到kettle的lib目录下&#xff0c;重启spoon。 2、配置数据库连接&#xff0c;提示驱动类不对…
阅读更多...
【软件测试】：软件测试实战

【软件测试】：软件测试实战

1. ⾃动化实施步骤 1.1 编写web测试⽤例 1.2 ⾃动化测试脚本开发 common public class AutotestUtils {public static EdgeDriver driver;// 创建驱动对象public static EdgeDriver createDriver(){// 驱动对象已经创建好了 / 没有创建if( driver null){driver new EdgeDr…
阅读更多...
深度学习入门1 基于Python的理论与实现

深度学习入门1 基于Python的理论与实现

torch.unsqueeze()将一维数据变为二维数据&#xff0c;torch只能处理二维数据 tensor不能反向&#xff0c;variable可以反向。variable.data.numpy()转换为numpy 第3章 神经网络 实现softmax函数时的注意事项&#xff1a;为防止e的指数运算造成溢出 矩阵的第 0 维是列方向,第…
阅读更多...
解决 Pentaho Kettle 插件集成中的 NoSuchMethodError: ContextFactory.enterContext() 错误

解决 Pentaho Kettle 插件集成中的 NoSuchMethodError: ContextFactory.enterContext() 错误

解决 Pentaho Kettle 插件集成中的 NoSuchMethodError: ContextFactory.enterContext() 错误 在使用 Pentaho Data Integration&#xff08;也称为 Kettle&#xff09;进行数据集成和ETL开发时&#xff0c;开发者可能会遇到各种依赖冲突和技术挑战。本文将详细介绍一个常见的错…
阅读更多...
第 五 章:优化算法_《C++性能优化指南》_notes

第 五 章:优化算法_《C++性能优化指南》_notes

优化算法 第五章重难点详解与代码实战编译与测试说明第五章核心知识点整理重难点梳理 第一部分&#xff1a;多选题&#xff08;10道&#xff09;第二部分&#xff1a;设计题&#xff08;5道&#xff09;答案与详解多选题答案&#xff1a; 设计题参考实现&#xff08;以题目2为例…
阅读更多...
多版本PHP开发环境配置教程：WAMPServer下MySQL/Apache/MariaDB版本安装与切换

多版本PHP开发环境配置教程：WAMPServer下MySQL/Apache/MariaDB版本安装与切换

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、版本切换指南总结 前言 由于有几个项目分别使用到PHP7.0 和7.4以及8.0版本&#xff0c;设置mysql也会根据PHP版本使用不同的版本&#xff0c;于是开始研究…
阅读更多...
最新文章

Copyright @ 2022~2023