13、Mybatis-Plus之插件介绍

1、分页插件

MyBatis Plus自带分页插件，只要简单的配置即可实现分页功能，优先推荐1

1、添加配置类

@Configuration
@MapperScan("com.test.mybatisplus.mapper") //可以将主类中的注解移到此处 
public class MybatisPlusConfig {
 
  @Bean
  public MybatisPlusInterceptor mybatisPlusInterceptor() {
    MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
    return interceptor;
    } 
}

2、测试

@Test
public 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());
}

1
2

测试结果:
User(id=1, name=Jone, age=18, email=test1@baomidou.com, isDeleted=0) User(id=2, name=Jack, age=20, email=test2@baomidou.com, isDeleted=0) User(id=3, name=Tom, age=28, email=test3@baomidou.com, isDeleted=0) User(id=4, name=Sandy, age=21, email=test4@baomidou.com, isDeleted=0) User(id=5, name=Billie, age=24, email=test5@ba omidou.com, isDeleted=0) 当前页:1 每页显示的条数:5 总记录数:17 总页数:4 是否有上一 页:false 是否有下一页:true

2、xml自定义分页

1、UserMapper中定义接口方法

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

2、UserMapper.xml中编写SQL

<!--SQL片段，记录基础字段-->
<sql id="BaseColumns">id,username,age,email</sql>
<!--IPage<User> selectPageVo(Page<User> page, Integer age);-->
<select id="selectPageVo" resultType="User">
    SELECT <include refid="BaseColumns"></include> FROM t_user WHERE age > #{age}
</select>

3、测试

@Test
public 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());
}

3、乐观锁

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)
);

添加数据

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

添加实体

package com.test.mybatisplus.entity;
import lombok.Data;
@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;
    private Integer version;
}

添加mapper

1 2	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());
}

4、乐观锁实现流程

数据库中添加version字段

取出记录时，获取当前version
1
SELECT id,`name`,price,`version` FROM product WHERE id=1
更新时，version + 1，如果where语句中的version版本不对，则更新失败
1
2
>UPDATE product SET price=price+50, `version`=`version` + 1 WHERE id=1 AND
`version`=1

5、Mybatis-Plus实现乐观锁

修改实体类

package com.test.mybatisplus.entity;
import com.baomidou.mybatisplus.annotation.Version;
import lombok.Data;
@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;
    @Version
    private Integer version;
}

添加乐观锁插件配置

@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){ 
  MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); 
  //添加分页插件
	interceptor.addInnerInterceptor(new
	PaginationInnerInterceptor(DbType.MYSQL)); 
  //添加乐观锁插件
  interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
  return interceptor;
}

测试修改冲突

小李查询商品信息:

SELECT id,name,price,version FROM t_product WHERE id=?

小王查询商品信息:

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=?

优化流程

@Test
public void testConcurrentVersionUpdate() { 
  //小李取数据
	Product p1 = productMapper.selectById(1L); 
  //小王取数据
  Product p2 = productMapper.selectById(1L);
	//小李修改 + 50
	p1.setPrice(p1.getPrice() + 50);
	int result1 = productMapper.updateById(p1); 
  System.out.println("小李修改的结果:" + result1);
	//小王修改 - 30
	p2.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());
}

4、自动填充字段插件

当有些字段，比如创建时间、更新时间、创建者等这些都可以让我们避免去更新这些字段，达到自动填充到数据库里面去

package com.jw.cloud.mybatisplus.config;

import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
import java.util.Date;

/**
 * 统一作为配置 字段自动插入值
 *
 * @author JoyWu
 */
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    /**
     *  新增时 插值
     * @param metaObject
     */
    @Override
    public void insertFill(MetaObject metaObject) {
        this.fillStrategy(metaObject, "deleted", 0);
        this.fillStrategy(metaObject, "createTime", new Date());
    }
    /**
     * 修改时插值
     * @param metaObject
     */
    @Override
    public void updateFill(MetaObject metaObject) {
    }
}

实体类：

package com.jw.cloud.mybatisplus.entity;

import com.baomidou.mybatisplus.annotation.*;

import java.io.Serializable;
import java.util.Date;


import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
import com.jw.cloud.mybatisplus.enums.JobEnum;
import com.jw.cloud.mybatisplus.enums.SexEnum;
import lombok.Data;


/**
 * 
 * @author JoyWu
 * @TableName t_user
 */
@TableName(value ="t_user",autoResultMap = true)
@Data
public class UserEntity implements Serializable {
    /**
     * 主键id
     */
    @TableId(type = IdType.AUTO)
    private Integer id;

    /**
     * 姓名
     */
    private String name;

    /**
     * 身份证号码
     */
//    @FieldEncrypt
    private String idCard;

    /**
     * 性别
     */
    private SexEnum sex;

    /**
     * 工作，IEnum接口的枚举处理
     * 数据库字段：job INT(3)
     */
    private JobEnum job;

    /**
     * 用户昵称
     */
    private String userName;

    /**
     * 登入密码
     */
    private String userPassword;

    /**
     * 版本信息
     */
    @Version
    private int version;
    /**
     * 逻辑删除字段 1 已删除
     *            0 未删除
     *            已删除的数据是不会被查询出来的
     */
    @TableLogic
    @TableField(fill = FieldFill.INSERT)
    private Integer deleted;
    /**
     * 创建时间
     */
    @TableField(fill = FieldFill.INSERT)
    private Date createTime;

    @TableField(typeHandler = JacksonTypeHandler.class)
    private JobEntity jobEntity;
    /**
     * 压力测试  测试乐观锁
     */
    private int num;
    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}

需要在实体类加上注解 @TableField(fill = FieldFill.INSERT) 模式当这个是新增的时候去默认插入这条记录