MybatisPlus——插件(MybatisPlus学习该专栏就够啦)

2年前 (2022) 程序员胖胖胖虎阿
247 0 0

插件

  • 一、分页插件
    • ①添加配置类
    • ②测试
  • 二、XML自定义分页接口方法
    • ①UserMapper中定义接口方法
    • ②UserMapper.xml中编写SQL
    • ③测试
  • 三、乐观锁
        • 场景
      • 乐观锁与悲观锁
      • 模拟修改冲突
      • 乐观锁实现流程

🌹🌹作者:Philosophy7
🚩🚩内容:这一章节介绍了MybatisPlus中的常用插件以及通用枚举
相信这一篇也能给小伙伴带来一定的收获
三连走起来!!! ⭐⭐⭐
MybatisPlus——插件(MybatisPlus学习该专栏就够啦)

一、分页插件

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

①添加配置类

@Configuration
//扫描mapper所在的包
@MapperScan("com.atguigu.mybatisplus.mapper")
public class MybatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        return interceptor;
    }

}

②测试

@SpringBootTest
public class MybatisPlusPageTest {
    @Autowired
    private UserMapper userMapper;

    @Test
    public void testPage(){
        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.getPages()); // 获取总页数
        System.out.println(page.getTotal()); //获取总记录数
        System.out.println(page.hasNext()); //是否有下一页数据
        System.out.println(page.hasPrevious()); //是否有上一页数据
    }

二、XML自定义分页接口方法

①UserMapper中定义接口方法

/**
 * 通过年龄来查询用户信息并分页
 * @param page
 * @param age
 * @return
 */
Page<User> selectPageVo(@Param("page") Page<User> page, @Param("age") Integer age);

②UserMapper.xml中编写SQL

<select id="selectPageVo" resultType="user">
    select uid,user_name,age,email from t_user where age > #{age}
</select>

③测试

@Test
public void testPageVo(){
    //select uid,user_name,age,email from t_user where age > ? LIMIT ?
    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.getPages()); // 获取总页数
    System.out.println(page.getTotal()); //获取总记录数
    System.out.println(page.hasNext()); //是否有下一页数据
    System.out.println(page.hasPrevious()); //是否有上一页数据
}

三、乐观锁

场景

一件商品,成本价是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;
    private Integer version;
}

添加Mapper

public interface ProductMapper extends BaseMapper<Product> {
}

乐观锁实现流程

数据库中添加version字段

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

修改实体类

@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;
    }

测试修改后的冲突

小李查询商品信息: 100

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

小李将价格上涨50元 此时version = 1

UPDATE t_product SET name=?, price=?, version=? WHERE id=? AND version=?

小王查询商品信息 100

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

此时 小王修改商品价格 version已更新 条件不成立 修改失败

最终结果 查询价格:150

优化流程

测试之前将数据库中数据修改回来 version = 0 price=100

@Test
public void test2(){
    //小李取数据
    Product product_Li = productMapper.selectById(1L);

    //小王取数据
    Product product_Wang = productMapper.selectById(1L);

    //小李修改数据 + 50
    product_Li.setPrice(product_Li.getPrice() + 50);
    int result = productMapper.updateById(product_Li);
    System.out.println("小李的修改结果:" + result);

    //小王修改数据 - 30
    product_Wang.setPrice(product_Wang.getPrice() - 30);
    int result2 = productMapper.updateById(product_Wang);
    System.out.println("result:" + result2);
    if (result2 == 0){
        //修改失败 重新获取version并更新
        product_Wang = productMapper.selectById(1L);
        product_Wang.setPrice(product_Wang.getPrice() - 30);
        result2 = productMapper.updateById(product_Wang);
    }
    System.out.println("小王修改的结果: " + result2);

    //最终的价格
    Product Boss = productMapper.selectById(1L);
    System.out.println(Boss);
}

MybatisPlus——插件(MybatisPlus学习该专栏就够啦)

版权声明:程序员胖胖胖虎阿 发表于 2022年10月21日 下午12:16。
转载请注明:MybatisPlus——插件(MybatisPlus学习该专栏就够啦) | 胖虎的工具箱-编程导航

相关文章

暂无评论

暂无评论...