• 【尚硅谷】MybatisPlus 学习笔记（下）

    目录

    六、插件

    6.1、分页插件

    6.1.1、添加配置类

    6.1.2、测试

    6.2、xml自定义分页

    6.2.1、UserMapper中定义接口方法

    6.2.2、UserMapper.xml中编写SQL

    6.2.3、测试

    6.3、乐观锁

    6.3.1、场景

    6.3.2、乐观锁与悲观锁

    6.3.3、模拟修改冲突

    数据库中增加商品表

    添加数据

    添加实体

    添加mapper

    测试

    6.3.4、乐观锁实现流程

    6.3.5、Mybatis-Plus实现乐观锁

    修改实体类

    添加乐观锁插件配置

    测试修改冲突

    优化流程

    七、通用枚举

    7.1、数据库表添加字段sex

    7.2、创建通用枚举类型

    7.3、配置扫描通用枚举

    7.4、测试

    八、代码生成器

    8.1、引入依赖

    8.2、快速生成

    九、多数据源

    9.1、创建数据库及表

    9.2、引入依赖

    9.3、配置多数据源

    9.4、创建用户service

    9.5、创建商品service

    9.6、测试

    十、MyBatisX插件

    六、插件

    6.1、分页插件

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

    6.1.1、添加配置类

    1. @Configuration
    2. @MapperScan("com.oracle.mapper")
    3. public class MybatisPlusConfig {
    4.  
    5.     @Bean
    6.     public MybatisPlusInterceptor mybatisPlusInterceptor() {
    7.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    8.         interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
    9.         return interceptor;
    10.     }
    11.  
    12. }

    6.1.2、测试

    1. @Test
    2. public void testPage(){
    3. 	// 设置分页参数
    4. 	Page page = new Page<>(1, 5);
    5. 	userMapper.selectPage(page, null);
    6. 	// 获取分页数据
    7. 	List list = page.getRecords();
    8. 	list.forEach(System.out::println);
    9. 	System.out.println("当前页："+page.getCurrent());
    10. 	System.out.println("每页显示的条数："+page.getSize());
    11. 	System.out.println("总记录数："+page.getTotal());
    12. 	System.out.println("总页数："+page.getPages());
    13. 	System.out.println("是否有上一页："+page.hasPrevious());
    14. 	System.out.println("是否有下一页："+page.hasNext());
    15. }

    6.2、xml自定义分页

    6.2.1、UserMapper中定义接口方法

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

    6.2.2、UserMapper.xml中编写SQL

    2. <sql id="BaseColumns">id,username,age,emailsql>
    3.  
    4. <select id="selectPageVo" resultType="com.oracle.pojo.User">
    5. 	SELECT <include refid="BaseColumns">include> FROM t_user WHERE age > #{age}
    6. select>

    6.2.3、测试

    1. @Test
    2. public void testSelectPageVo(){
    3. 	// 设置分页参数
    4. 	Page page = new Page<>(1, 5);
    5. 	userMapper.selectPageVo(page, 20);
    6. 	// 获取分页数据
    7. 	List list = page.getRecords();
    8. 	list.forEach(System.out::println);
    9. 	System.out.println("当前页："+page.getCurrent());
    10. 	System.out.println("每页显示的条数："+page.getSize());
    11. 	System.out.println("总记录数："+page.getTotal());
    12. 	System.out.println("总页数："+page.getPages());
    13. 	System.out.println("是否有上一页："+page.hasPrevious());
    14. 	System.out.println("是否有下一页："+page.hasNext());
    15. }

    6.3、乐观锁

    6.3.1、场景

    一件商品，成本价是80元，售价是100元。老板先是通知小李，说你去把商品价格增加50元。小李正在玩游戏，耽搁了一个小时。正好一个小时后，老板觉得商品价格增加到150元，价格太高，可能会影响销量。又通知小王，你把商品价格降低30元。


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


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

    6.3.2、乐观锁与悲观锁

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


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

    6.3.3、模拟修改冲突

    数据库中增加商品表
    1. CREATE TABLE t_product
    2. (
    3.     id BIGINT(20) NOT NULL COMMENT '主键ID',
    4.     NAME VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名称',
    5.     price INT(11) DEFAULT 0 COMMENT '价格',
    6.     VERSION INT(11) DEFAULT 0 COMMENT '乐观锁版本号',
    7.     PRIMARY KEY (id)
    8. );

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

    添加实体
    1. package com.oracle.pojo;
    2.  
    3. import lombok.Data;
    4.  
    5. @Data
    6. public class Product {
    7.     private Long id;
    8.     private String name;
    9.     private Integer price;
    10.     private Integer version;
    11. }

    添加mapper
    1. public interface ProductMapper extends BaseMapper {
    2.     
    3. }

    测试
    1. @Test
    2. public void testConcurrentUpdate() {
    3. 	// 1、小李
    4. 	Product p1 = productMapper.selectById(1L);
    5. 	System.out.println("小李取出的价格：" + p1.getPrice());
    6. 	// 2、小王
    7. 	Product p2 = productMapper.selectById(1L);
    8. 	System.out.println("小王取出的价格：" + p2.getPrice());
    9. 	// 3、小李将价格加了50元，存入了数据库
    10. 	p1.setPrice(p1.getPrice() + 50);
    11. 	int result1 = productMapper.updateById(p1);
    12. 	System.out.println("小李修改结果：" + result1);
    13. 	// 4、小王将商品减了30元，存入了数据库
    14. 	p2.setPrice(p2.getPrice() - 30);
    15. 	int result2 = productMapper.updateById(p2);
    16. 	System.out.println("小王修改结果：" + result2);
    17. 	// 最后的结果
    18. 	Product p3 = productMapper.selectById(1L);
    19. 	// 价格覆盖，最后的结果：70
    20. 	System.out.println("最后的结果：" + p3.getPrice());
    21. }

    6.3.4、乐观锁实现流程

    数据库中添加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;

    6.3.5、Mybatis-Plus实现乐观锁

    修改实体类
    1. @Data
    2. public class Product {
    3.     private Long id;
    4.     private String name;
    5.     private Integer price;
    6.     @Version // 标识乐观锁版本号
    7.     private Integer version;
    8. }

    添加乐观锁插件配置
    1. package com.oracle.config;
    2.  
    3. import com.baomidou.mybatisplus.annotation.DbType;
    4. import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
    5. import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
    6. import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
    7. import org.mybatis.spring.annotation.MapperScan;
    8. import org.springframework.context.annotation.Bean;
    9. import org.springframework.context.annotation.Configuration;
    10.  
    11. @Configuration
    12. @MapperScan("com.oracle.mapper")
    13. public class MybatisPlusConfig {
    14.  
    15.     @Bean
    16.     public MybatisPlusInterceptor mybatisPlusInterceptor() {
    17.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    18.         interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
    19.         // 添加乐观锁插件
    20.         interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
    21.         return interceptor;
    22.     }
    23.  
    24. }

    测试修改冲突

    优化流程
    1. @Test
    2. public void testConcurrentVersionUpdate() {
    3. 	// 小李取数据
    4. 	Product p1 = productMapper.selectById(1L);
    5. 	// 小王取数据
    6. 	Product p2 = productMapper.selectById(1L);
    7. 	// 小李修改 + 50
    8. 	p1.setPrice(p1.getPrice() + 50);
    9. 	int result1 = productMapper.updateById(p1);
    10. 	System.out.println("小李修改的结果：" + result1);
    11. 	// 小王修改 - 30
    12. 	p2.setPrice(p2.getPrice() - 30);
    13. 	int result2 = productMapper.updateById(p2);
    14. 	System.out.println("小王修改的结果：" + result2);
    15. 	if(result2 == 0){
    16. 	// 失败重试，重新获取version并更新
    17. 		p2 = productMapper.selectById(1L);
    18. 		p2.setPrice(p2.getPrice() - 30);
    19. 		result2 = productMapper.updateById(p2);
    20. 	}
    21. 	System.out.println("小王修改重试的结果：" + result2);
    22. 	// 老板看价格
    23. 	Product p3 = productMapper.selectById(1L);
    24. 	System.out.println("老板看价格：" + p3.getPrice());
    25. }

    七、通用枚举

    表中的有些字段值是固定的，例如性别（男或女），此时我们可以使用MyBatis-Plus的通用枚举来实现

    7.1、数据库表添加字段sex

    7.2、创建通用枚举类型

    1. package com.oracle.enums;
    2.  
    3. import com.baomidou.mybatisplus.annotation.EnumValue;
    4. import lombok.Getter;
    5.  
    6. @Getter
    7. public enum SexEnum {
    8.     MALE(1, "男"),
    9.     FEMALE(2, "女");
    10.  
    11.     @EnumValue
    12.     private Integer sex;
    13.     private String sexName;
    14.     
    15.     SexEnum(Integer sex, String sexName) {
    16.         this.sex = sex;
    17.         this.sexName = sexName;
    18.     }
    19. }

    7.3、配置扫描通用枚举

    1. # 配置MyBatis日志
    2. mybatis-plus:
    3.   configuration:
    4.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    5.   global-config:
    6.     db-config:
    7.       # 配置MybatisPlus操作表的默认前缀
    8.       table-prefix: t_
    9.       # 配置MyBatis-Plus的主键策略
    10.       id-type: auto
    11.   # 配置扫描通用枚举
    12.   type-enums-package: com.oracle.enums

    7.4、测试

    1. @Test
    2. public void testSexEnum(){
    3. 	User user = new User();
    4. 	user.setName("Enum");
    5. 	user.setAge(20);
    6. 	// 设置性别信息为枚举项，会将@EnumValue注解所标识的属性值存储到数据库
    7. 	user.setSex(SexEnum.MALE);
    8. 	// INSERT INTO t_user ( username, age, sex ) VALUES ( ?, ?, ? )
    9. 	// Parameters: Enum(String), 20(Integer), 1(Integer)
    10. 	userMapper.insert(user);
    11. }

    八、代码生成器

    8.1、引入依赖

    1. <dependency>
    2. 	<groupId>com.baomidougroupId>
    3. 	<artifactId>mybatis-plus-generatorartifactId>
    4. 	<version>3.5.1version>
    5. dependency>
    6. <dependency>
    7. 	<groupId>org.freemarkergroupId>
    8. 	<artifactId>freemarkerartifactId>
    9. 	<version>2.3.31version>
    10. dependency>

    8.2、快速生成

    1. package com.oracle;
    2.  
    3. import com.baomidou.mybatisplus.generator.FastAutoGenerator;
    4. import com.baomidou.mybatisplus.generator.config.OutputFile;
    5. import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
    6.  
    7. import java.util.Collections;
    8.  
    9. public class FastAutoGeneratorTest {
    10.     public static void main(String[] args) {
    11.         FastAutoGenerator.create("jdbc:mysql://127.0.0.1:3306/mybatis_plus?characterEncoding=utf-8&userSSL=false", "root", "root")
    12.                         .globalConfig(builder -> {
    13.                             builder.author("atguigu") // 设置作者
    14.                                     //.enableSwagger() // 开启 swagger 模式
    15.                                     .fileOverride() // 覆盖已生成文件
    16.                                     .outputDir("D://mybatis_plus"); // 指定输出目录
    17.                         })
    18.                         .packageConfig(builder -> {
    19.                             builder.parent("com.atguigu") // 设置父包名
    20.                                     .moduleName("mybatisplus") // 设置父包模块名
    21.                                     .pathInfo(Collections.singletonMap(OutputFile.mapperXml, "D://mybatis_plus"));
    22.                         // 设置mapperXml生成路径
    23.                         })
    24.                         .strategyConfig(builder -> {
    25.                             builder.addInclude("t_user") // 设置需要生成的表名
    26.                                     .addTablePrefix("t_", "c_"); // 设置过滤表前缀
    27.                         })
    28.                         .templateEngine(new FreemarkerTemplateEngine()) // 使用Freemarker引擎模板，默认的是Velocity引擎模板
    29.                         .execute();
    30.     }
    31. }

    九、多数据源

    适用于多种场景：纯粹多库、 读写分离、 一主多从、 混合模式等
    目前我们就来模拟一个纯粹多库的一个场景，其他场景类似
    场景说明：
    我们创建两个库，分别为：mybatis_plus（以前的库不动）与mybatis_plus_1（新建），将
    mybatis_plus库的product表移动到mybatis_plus_1库，这样每个库一张表，通过一个测试用例分别获取用户数据与商品数据，如果获取到说明多库模拟成功

    9.1、创建数据库及表

    创建数据库mybatis_plus_1和表product

    1. CREATE DATABASE `mybatis_plus_1` /*!40100 DEFAULT CHARACTER SET utf8mb4 */;
    2. use `mybatis_plus_1`;
    3. CREATE TABLE product
    4. (
    5.     id BIGINT(20) NOT NULL COMMENT '主键ID',
    6.     name VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名称',
    7.     price INT(11) DEFAULT 0 COMMENT '价格',
    8.     version INT(11) DEFAULT 0 COMMENT '乐观锁版本号',
    9.     PRIMARY KEY (id)
    10. );
    添加测试数据 
    INSERT INTO product (id, NAME, price) VALUES (1, '外星人笔记本', 100);
    删除 mybatis_plus 库 product 表 
    1. use mybatis_plus;
    2. DROP TABLE IF EXISTS product;

    9.2、引入依赖

    1. <dependency>
    2. 	<groupId>com.baomidougroupId>
    3. 	<artifactId>dynamic-datasource-spring-boot-starterartifactId>
    4. 	<version>3.5.0version>
    5. dependency>

    9.3、配置多数据源

    说明：注释掉之前的数据库连接，添加新配置 
    1. spring:
    2.   datasource:
    3.     dynamic:
    4.       primary: master
    5.       strict: false
    6.       datasource:
    7.         master:
    8.           url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-8&useSSL=false
    9.           driver-class-name: com.mysql.cj.jdbc.Driver
    10.           username: root
    11.           password: root
    12.         slave_1:
    13.           url: jdbc:mysql://localhost:3306/mybatis_plus_1?characterEncoding=utf-8&useSSL=false
    14.           driver-class-name: com.mysql.cj.jdbc.Driver
    15.           username: root
    16.           password: root

    9.4、创建用户service

    1. public interface UserService extends IService {
    2.  
    3. }
    1. @DS("master") //指定所操作的数据源
    2. @Service
    3. public class UserServiceImpl extends ServiceImpl implements UserService {
    4.  
    5. }

    9.5、创建商品service

    1. public interface ProductService extends IService {
    2.  
    3. }
    1. @DS("slave_1")
    2. @Service
    3. public class ProductServiceImpl extends ServiceImpl implements ProductService {
    4.  
    5. }

    9.6、测试

    1. @Autowired
    2. private UserService userService;
    3.  
    4. @Autowired
    5. private ProductService productService;
    6.  
    7. @Test
    8. public void testDynamicDataSource(){
    9. 	System.out.println(userService.getById(1L));
    10. 	System.out.println(productService.getById(1L));
    11. }

    结果：
    1、都能顺利获取对象，则测试成功
    2、如果我们实现读写分离，将写操作方法加上主库数据源，读操作方法加上从库数据源，自动切换，是不是就能实现读写分离？

    十、MyBatisX插件

    MyBatis-Plus为我们提供了强大的mapper和service模板，能够大大的提高开发效率。
    但是在真正开发过程中，MyBatis-Plus并不能为我们解决所有问题，例如一些复杂的SQL，多表联查，我们就需要自己去编写代码和SQL语句，我们该如何快速的解决这个问题呢，这个时候可以使用MyBatisX插件。
    MyBatisX一款基于 IDEA 的快速开发插件，为效率而生。

    MyBatisX插件用法：https://baomidou.com/pages/ba5b24/

  • 相关阅读:
    IoC和DI
    微信小程序引入地图
    基于Springboot Aop实现注解鉴权式框架
    GitLab使用
    Java Collections.replaceAll()方法具有什么功能呢?
    vite源码分析之dev
    原来用 MySQL 也可以做全文检索
    OI 模板合集
    SwiftUI 4 新功能大全之 Toggle与 Mixed Toggle 多个绑定组件
    聊聊jedis连接池参数配置
  • 原文地址：https://blog.csdn.net/qq_38196449/article/details/136276263