目录
①. 分页插件
②. xml自定义分页
③. 乐观锁
①. 分页插件
-
①. MyBatis Plus自带分页插件,只要简单的配置即可实现分页功能
-
②. 添加配置类
@Configuration
public class MybatisPlusConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){
MybatisPlusInterceptor interceptor=new MybatisPlusInterceptor();
//添加分页插件
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
return interceptor;
}
}
③. 测试类测试
@Test
public void testPage(){
// SELECT id,name,age,email,is_deleted FROM user WHERE is_deleted=0 LIMIT ?
Page<User> page=new Page<>(1,3);
userMapper.selectPage(page, null);
//获取当前页的数据
System.out.println("当前页的数据："+page.getRecords());
//获取当前页页码
System.out.println("当前页的页码："+page.getCurrent());
//获取当前页数据的个数
System.out.println("当前页的数据数："+page.getSize());
//获取总记录数
System.out.println("数据库总数据数："+page.getTotal());
//是否有下一页
System.out.println("是否有下一页："+page.hasNext());
//是否有上一页
System.out.println("是否有上一页："+page.hasPrevious());
System.out.println("一共有"+page.getPages()+"页");
}②. xml自定义分页
- ①. UserMapper中定义接口方法
@Mapper
public interface UserMapper extends BaseMapper<User> {
//根据年龄查询数据并进行分页,page:mybatis-plus所提供的分页对象，必须位于第一个参数位置
Page<User> selectPageVo(@Param("page")Page<User> page,@Param("age") Integer age);
}- ②. 在UserMapper.xml中编写sql语句
<mapper namespace="com.songqiao.mapper.UserMapper">
<!--namespace根据自己需要创建的的mapper的路径和名称填写-->
<select id="selectPageVo" resultType="com.songqiao.pojo.User">
select id,name,age,email from t_user where is_deleted = 0 and age > #{age}
</select>
</mapper>- ③. 在测试类中进行测试
@DisplayName("根据自定义的sql语句来获取分页信息")
@Test
public void testPageByMySql(){
Page<User> page=new Page<>(1,3);
userMapper.selectPageVo(page,20);
//获取当前页的数据
System.out.println("当前页的数据："+page.getRecords());
//获取当前页页码
System.out.println("当前页的页码："+page.getCurrent());
//获取当前页数据的个数
System.out.println("当前页的数据数："+page.getSize());
//获取总记录数
System.out.println("数据库总数据数："+page.getTotal());
//是否有下一页
System.out.println("是否有下一页："+page.hasNext());
//是否有上一页
System.out.println("是否有上一页："+page.hasPrevious());
System.out.println("一共有"+page.getPages()+"页");
}
③. 乐观锁
- ①. 场景
一件商品，成本价是80元，售价是100元。老板先是通知小李，说你去把商品价格增加50元。小李正在玩游戏，耽搁了一个小时。正好一个小时后，老板觉得商品价格增加到150元，价格太
高，可能会影响销量。又通知小王，你把商品价格降低30元。
此时，小李和小王同时操作商品后台系统。小李操作的时候，系统先取出商品价格100元；小王也在操作，取出的商品价格也是100元。小李将价格加了50元，并将100+50=150元存入了数据
库；小王将商品减了30元，并将100-30=70元存入了数据库。是的，如果没有锁，小李的操作就
完全被小王的覆盖了。
现在商品价格是70元，比成本价低10元。几分钟后，这个商品很快出售了1千多件商品，老板亏1万多。
- ②. 乐观锁与悲观锁
- 乐观锁，小王保存价格前，会检查下价格是否被人修改过了。如果被修改过了，则重新取出的被修改后的价格，150元，这样他会将120元存入数据库。
- 悲观锁，小李取出数据后，小王只能等小李操作完之后，才能对价格进行操作，也会保证最终的价格是120元。
- ③. 代码模拟上述修改冲突
数据库中增加表
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);添加实体类与接口
@Data
public class Product {
private Long id;
private String name;
private Integer price;
}@Mapper
public interface ProductMapper extends BaseMapper<Product> {
}测试
@Test
public 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);
//价格覆盖，最后的结果：70
System.out.println("最后的结果：" + p3.getPrice());
}- ④. 乐观锁实现流程
- 数据库中添加version字段
- 取出记录时，获取当前version
- 更新时，version + 1，如果where语句中的version版本不对，则更新失败
--查询的语句，同时查出版本
SELECT id,`name`,price,`version` FROM product WHERE id=1
--修改语句，修改时检查版本并在修改完成后更新版本信息
UPDATE product SET price=price+50, `version`=`version` + 1 WHERE id=1 AND
`version`=1- ⑤. MyBatis-Plus实现乐观锁
- 在实体类添加版本字段并添加@Version注解
- 在配置类中添加MyBatis-Plus版本控制
- 优化修改代码
@Data
public class Product {
private Long id;
private String name;
private Integer price;
@Version //表示乐观锁版本号字段
private Integer version;
}@Configuration
public class MybatisPlusConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){
MybatisPlusInterceptor interceptor=new MybatisPlusInterceptor();
//添加分页插件
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
//添加乐观锁插件
interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
return interceptor;
}
} @DisplayName("模拟数据更新冲突与乐观锁的实现")
@Test
public void testProduct01(){
//小李查询商品价格，版本号0
Product productLi = productMapper.selectById(1);
System.out.println("小李查询的商品价格:"+productLi.getPrice());
//小王查询商品价格，版本号0
Product productWang = productMapper.selectById(1);
System.out.println("小李查询的商品价格:"+productWang.getPrice());
//小李将商品价格+50元，版本号1
productLi.setPrice(productLi.getPrice()+50);
productMapper.updateById(productLi);
//小王将商品价格-30元，版本号是0所以不能更新成功
productWang.setPrice(productWang.getPrice()-30);
int i = productMapper.updateById(productWang);
if (i==0){
//i=0说明操作失败，也就是版本号不是最新版，重新获取数据并进行更新
Product productNew = productMapper.selectById(1);
productNew.setPrice(productNew.getPrice()-30);
productMapper.updateById(productNew);
}
//老板查询商品价格
System.out.println("老板查询的商品价格："+productMapper.selectById(1).getPrice());
}
