MyBatisPlus ---- 插件
- 1. 分页插件
- a>添加配置类
- b>测试
- 2. xml自定义分页
- a>UserMapper中定义接口方法
- b>UserMapper.xml中编写SQL
- c>配置文件
- d>测试
- 3. 乐观锁
- a>场景
- b>乐观锁与悲观锁
- c>模拟修改冲突
- d>乐观锁实现流程
- e>MyBatis-Plus实现乐观锁
1. 分页插件
MyBatis-Plus 自带分页插件，只要简单的配置即可实现分页功能
a>添加配置类
package com.fickler.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.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @author dell
* @version 1.0
*/
@Configuration
@MapperScan("com.fickler.mybatisplus.mapper")
public class MyBatisPlusConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){
MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
return mybatisPlusInterceptor;
}
}
b>测试
@Test
public void testPage(){
//设置分页参数
Page<User> page = new Page<>(1, 5);
userMapper.selectPage(page, null);
//获取分页数据
List<User> records = page.getRecords();
records.forEach(record -> System.out.println(record));
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());
}
2. xml自定义分页
a>UserMapper中定义接口方法
package com.fickler.mybatisplus.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fickler.mybatisplus.pojo.User;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
/**
* @author dell
* @version 1.0
*/
@Repository
public interface UserMapper extends BaseMapper<User> {
/**
* 根据年龄查询用户列表，分页显示
* @param page 分页对象，xml中可以从里面进行取值，传递参数 Page 即自动分页，必须放在第一位
* @param age 年龄
* @return
*/
Page<User> selectPageVo(@Param("page") Page<User> page, @Param("age") Integer age);
}
b>UserMapper.xml中编写SQL
<?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.fickler.mybatisplus.mapper.UserMapper">
<!--Page<User> selectPageVo(@Param("page") Page<User> page, @Param("age") Integer age);-->
<select id="selectPageVo" resultType="user">
select uid, user_name, age, email from t_user where age > #{age}
</select>
</mapper>
c>配置文件
# 配置类型别名所对应的包
type-aliases-package: com.fickler.mybatisplus.pojo
d>测试
@Test
public void testSelectPageVo(){
//设置分页参数
Page<User> page = new Page<>(1, 5);
userMapper.selectPageVo(page, 20);
//获取分页数据
List<User> records = page.getRecords();
records.forEach(record -> System.out.println(record));
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());
}
3. 乐观锁
a>场景
一件商品，成本价是 80 元，售价是 100 元。老板先是通知小李，说你去把商品价格增加 50 元。小李正在玩游戏，耽搁了一个小时。正好一个小时后，老板觉得商品价格增加到 150 元，价格太高，可能会影响销量。又通知小王，你把商品价格降低 30 元。
此时，小李和小王同时操作商品后台系统。小李操作的时候，系统先取出商品价格 100 元；小王也在操作，取出商品价格也是 100 元。小李将价格加了 50 元，并将 100 + 50 = 150 元存入了数据库；小王将商品减了 30 元，并将 100 - 30 = 70 元存入了数据库。是的，如果没有锁，小李的操作就完全被小王的覆盖了。
现在商品价格是 70 元，比成本价低 10 元。几分钟后，这个商品很快就出售了 1 千多件商品，老板亏 1 万多。
b>乐观锁与悲观锁
上面的故事，如果是乐观锁，小王保存价格前，会检查下价格是否被人修改过了。如果被修改过了，则重新取出的被修改后的价格，150 元，这样他会将 120 元存入数据库。
如果是悲观锁，小李取出数据后，小王只能等小李操作完之后，才能对价格进行操作，也会保证最终的价格是 120 元。
c>模拟修改冲突
数据库中增加商品表
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.fickler.mybatisplus.pojo;
import lombok.Data;
/**
* @author dell
* @version 1.0
*/
@Data
public class Product {
private Long id;
private String name;
private Integer price;
private Integer version;
}
添加mapper
package com.fickler.mybatisplus.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.fickler.mybatisplus.pojo.Product;
/**
* @author dell
* @version 1.0
*/
public interface ProductMapper extends BaseMapper<Product> {
}
测试
@Test
public void testConcurrentUpdate(){
//1.小李
Product product1 = productMapper.selectById(1L);
System.out.println("小李取出的价格：" + product1.getPrice());
//2.小王
Product product2 = productMapper.selectById(1L);
System.out.println("小王取出的价格：" + product2.getPrice());
//3.小李将价格加了50元，存入了数据库
product1.setPrice(product1.getPrice() + 50);
int result1 = productMapper.updateById(product1);
System.out.println("小李修改的结果：" + result1);
//4.小王将商品减了30元，存入了数据库
product2.setPrice(product2.getPrice() - 30);
int result2 = productMapper.updateById(product2);
System.out.println("小王修改的结果：" + result2);
//最后的结果
Product product = productMapper.selectById(1L);
System.out.println("最后的结果：" + product.getPrice());
}
d>乐观锁实现流程
数据库中添加 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
e>MyBatis-Plus实现乐观锁
修改实体类
package com.fickler.mybatisplus.pojo;
import com.baomidou.mybatisplus.annotation.Version;
import lombok.Data;
/**
* @author dell
* @version 1.0
*/
@Data
public class Product {
private Long id;
private String name;
private Integer price;
@Version
private Integer version;
}
添加乐观锁插件配置
package com.fickler.mybatisplus.config;
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @author dell
* @version 1.0
*/
@Configuration
@MapperScan("com.fickler.mybatisplus.mapper")
public class MyBatisPlusConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){
MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
//添加分页插件
mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
//添加乐观锁插件
mybatisPlusInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
return mybatisPlusInterceptor;
}
}
测试修改冲突
小李查询商品信息：
SELECT id,name,price,version FROM t_product WHERE id=?
小王查询商品信息：
SELECT id,name,price,version FROM t_product WHERE id=?
小李修改商品价格，自动将version+1
UPDATE t_product SET name=?, price=?, version=? WHERE id=? AND version=?
Parameters: 外星人笔记本(String), 150(Integer), 1(Integer), 1(Long), 0(Integer)
小王修改商品价格，此时version已更新，条件不成立，修改失败
UPDATE t_product SET name=?, price=?, version=? WHERE id=? AND version=?
Parameters: 外星人笔记本(String), 70(Integer), 1(Integer), 1(Long), 0(Integer)
最终，小王修改失败，查询价格：150
SELECT id,name,price,version FROM t_product WHERE id=?
