• 快速学习MyBatisPlus



    前言

    MyBatisPlus的条件构造器和常用接口、分页插件、乐观锁、悲观锁、通用枚举、多数据源操作、MyBatisX插件、快速生成代码。
    承接上篇文章(代码中的mapper类在上篇文章搭建过了):MyBatisPlus常用注解和基本CRUD操作文章


    一、条件构造器和常用接口

    1.wapper介绍

    在这里插入图片描述
    在这里插入图片描述

    • Wrapper : 条件构造抽象类,最顶端父类
      • AbstractWrapper : 用于查询条件封装,生成 sql 的 where 条件
        • QueryWrapper : 查询条件封装
        • UpdateWrapper : Update 条件封装
        • AbstractLambdaWrapper : 使用Lambda 语法
          • LambdaQueryWrapper :用于Lambda语法使用的查询Wrapper
          • LambdaUpdateWrapper : Lambda 更新封装Wrapper

    2.QueryWrapper

    (1)组装查询条件

    @Test
    public void test01(){
    //查询用户名包含a,年龄在20到30之间,并且邮箱不为null的用户信息
    //SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE
    is_deleted=0 AND (username LIKE ? AND age BETWEEN ? AND ? AND email IS NOT NULL)
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.like("username", "a")
    .between("age", 20, 30)
    .isNotNull("email");
    List<User> list = userMapper.selectList(queryWrapper);
    list.forEach(System.out::println);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12

    (2)组装排序查询

    @Test
    public void test02(){
    //按年龄降序查询用户,如果年龄相同则按id升序排列
    //SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE
    is_deleted=0 ORDER BY age DESC,id ASC
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper
    .orderByDesc("age")
    .orderByAsc("id");
    List<User> users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12

    (3)组装删除查询

    @Test
    public void test03(){
    //删除email为空的用户
    //DELETE FROM t_user WHERE (email IS NULL)
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.isNull("email");
    //条件构造器也可以构建删除语句的条件
    int result = userMapper.delete(queryWrapper);
    System.out.println("受影响的行数:" + result);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10

    (4)条件优先级

    @Test
    public void test04() {
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    //将(年龄大于20并且用户名中包含有a)或邮箱为null的用户信息修改
    //UPDATE t_user SET age=?, email=? WHERE (username LIKE ? AND age > ? OR
    email IS NULL)
    queryWrapper
    .like("username", "a")
    .gt("age", 20)
    .or()
    .isNull("email");
    User user = new User();
    user.setAge(18);
    user.setEmail("user@dragon.com");
    int result = userMapper.update(user, queryWrapper);
    System.out.println("受影响的行数:" + result);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    @Test
    public void test04() {
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    //将用户名中包含有a并且(年龄大于20或邮箱为null)的用户信息修改
    //UPDATE t_user SET age=?, email=? WHERE (username LIKE ? AND (age > ? OR email IS NULL))
    //lambda表达式内的逻辑优先运算
    queryWrapper.like("username", "a")
    .and(i -> i.gt("age", 20).or().isNull("email"));
    User user = new User();
    user.setAge(18);
    user.setEmail("user@dragon.com");
    int result = userMapper.update(user, queryWrapper);
    System.out.println("受影响的行数:" + result);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14

    (5)组装select子句

    @Test
    public void test05() {
    //查询用户信息的username和age字段
    //SELECT username,age FROM t_user
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.select("username", "age");
    //selectMaps()返回Map集合列表,通常配合select()使用,避免User对象中没有被查询到的列值为null
    List<Map<String, Object>> maps = userMapper.selectMaps(queryWrapper);
    maps.forEach(System.out::println);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10

    (6)实现子查询

    @Test
    public void test06() {
    //查询id小于等于3的用户信息
    //SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE (id IN
    (select id from t_user where id <= 3))
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.inSql("id", "select id from t_user where id <= 3");
    List<User> list = userMapper.selectList(queryWrapper);
    list.forEach(System.out::println);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10

    3.UpdateWrapper

    @Test
    public void test07() {
    //将(年龄大于20或邮箱为null)并且用户名中包含有a的用户信息修改
    //组装set子句以及修改条件
    UpdateWrapper<User> updateWrapper = new UpdateWrapper<>();
    //lambda表达式内的逻辑优先运算
    updateWrapper
    .set("age", 18)
    .set("email", "user@dragon.com")
    .like("username", "a")
    .and(i -> i.gt("age", 20).or().isNull("email"));
    //这里必须要创建User对象,否则无法应用自动填充。如果没有自动填充,可以设置为null
    //UPDATE t_user SET username=?, age=?,email=? WHERE (username LIKE ? AND (age > ? OR email IS NULL))
    //User user = new User();
    //user.setName("张三");
    //int result = userMapper.update(user, updateWrapper);
    //UPDATE t_user SET age=?,email=? WHERE (username LIKE ? AND (age > ? OR email IS NULL))
    int result = userMapper.update(null, updateWrapper);
    System.out.println(result);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20

    4.condition

    在真正开发的过程中,组装条件是常见的功能,而这些条件数据来源于用户输入,是可选的,因
    此我们在组装这些条件时,必须先判断用户是否选择了这些条件,若选择则需要组装该条件,若
    没有选择则一定不能组装,以免影响SQL执行的结果。

    方法一:

    @Test
    public void test08() {
    //定义查询条件,有可能为null(用户未输入或未选择)
    String username = null;
    Integer ageBegin = 10;
    Integer ageEnd = 24;
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    //StringUtils.isNotBlank()判断某字符串是否不为空且长度不为0且不由空白符(whitespace)构成
    if(StringUtils.isNotBlank(username)){
    queryWrapper.like("username","a");
    }
    if(ageBegin != null){
    queryWrapper.ge("age", ageBegin);
    }
    if(ageEnd != null){
    queryWrapper.le("age", ageEnd);
    }
    //SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE (age >=
    ? AND age <= ?)
    List<User> users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22

    方法二(推荐):
    上面的实现方案没有问题,但是代码比较复杂,我们可以使用带condition参数的重载方法构建查
    询条件,简化代码的编写。

    @Test
    public void test08UseCondition() {
    //定义查询条件,有可能为null(用户未输入或未选择)
    String username = null;
    Integer ageBegin = 10;
    Integer ageEnd = 24;
    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    //StringUtils.isNotBlank()判断某字符串是否不为空且长度不为0且不由空白符(whitespace)构成
    queryWrapper.like(StringUtils.isNotBlank(username), "username", "a")
    .ge(ageBegin != null, "age", ageBegin)
    .le(ageEnd != null, "age", ageEnd);
    //SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE (age >=
    ? AND age <= ?)
    List<User> users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16

    5.LambdaQueryWrapper

    @Test
    public void test09() {
    //定义查询条件,有可能为null(用户未输入)
    String username = "a";
    Integer ageBegin = 10;
    Integer ageEnd = 24;
    LambdaQueryWrapper<User> queryWrapper = new LambdaQueryWrapper<>();
    //避免使用字符串表示字段,防止运行时错误
    queryWrapper
    .like(StringUtils.isNotBlank(username), User::getName, username)
    .ge(ageBegin != null, User::getAge, ageBegin)
    .le(ageEnd != null, User::getAge, ageEnd);
    List<User> users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    6.LambdaUpdateWrapper

    @Test
    public void test10() {
    //组装set子句
    LambdaUpdateWrapper<User> updateWrapper = new LambdaUpdateWrapper<>();
    updateWrapper
    .set(User::getAge, 18)
    .set(User::getEmail, "user@dragon.com")
    .like(User::getName, "a")
    .and(i -> i.lt(User::getAge, 24).or().isNull(User::getEmail)); //lambda表达式内的逻辑优先运算
    User user = new User();
    int result = userMapper.update(user, updateWrapper);
    System.out.println("受影响的行数:" + result);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13

    二、分页插件

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

    创建配置类:

    @Configuration
    @MapperScan("com.dragon.mybatisplus.mapper")
    public class MyBatisPlusConfig {
        @Bean
        public MybatisPlusInterceptor mybatisPlusInterceptor(){
            MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
            //添加分页插件
            interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
            return interceptor;
        }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11

    如果你是跟着上一篇文章,这里注意:主类中的mapper扫描注解移到此配置类中了。

    @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
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    xml自定义分页

    将年龄大于20的数据分页

    UserMapper接口:

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

    UserMapper.xml:

    <!--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>
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    @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());
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    三、乐观锁

    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)
    );
    
    INSERT INTO t_product (id, NAME, price) VALUES (1, '雷神笔记本', 100);
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10

    实体类:

    @Data
    public class Product {
    private Long id;
    private String name;
    private Integer price;
    private Integer version;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    ProductMapper:

    public interface ProductMapper extends BaseMapper<Product> {
    }
    
    • 1
    • 2

    测试:

    @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());
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21

    4.乐观锁实现流程

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

    上面场景使用乐观锁后,小王和小李同时都取了一百,这时取出的版本号都是一样的,但是当其中一个人修改存入后版本号变化,另一个人存入时还是用的以前版本号,就会更新失败。

    实现

    在实体类的版本号上添加@Version注解

    @Data
    public class Product {
    private Long id;
    private String name;
    private Integer price;
    @Version
    private Integer version;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

    在配置类中添加乐观锁插件

    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
    MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    //添加分页插件
    interceptor.addInnerInterceptor(new
    PaginationInnerInterceptor(DbType.MYSQL));
    //添加乐观锁插件
    interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
    return interceptor;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10

    运行上面的测试:

    小李查询商品信息:
    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=?

    优化流程

    上面小王因版本号不对修改失败,我们优化流程,让小王修改后如果版本号还是没变前的,让他重新获取进行修改存入,这样结果就是我们想要的120了。

    @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());
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25

    四、通用枚举

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

    在这里插入图片描述
    创建通用枚举类型:

    @Getter
    public enum SexEnum {
        MALE(1, "男"),
        FEMALE(2, "女");
        @EnumValue//将注解所标识的属性的值存储到数据库中
        private Integer sex;
        private String sexName;
    
        SexEnum(Integer sex, String sexName) {
            this.sex = sex;
            this.sexName = sexName;
        }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13

    配置扫描通用枚举:

    mybatis-plus:
      configuration:
        log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
      # 设置MyBatis-Plus的全局配置
      global-config:
        db-config:
          # 设置实体类所对应的表的统一前缀
          table-prefix: t_
          # 设置统一的主键生成策略
          id-type: auto
      # 配置类型别名所对应的包
      type-aliases-package: com.dragon.mybatisplus.pojo
      # 配置扫描通用枚举
      type-enums-package: com.dragon.mybatisplus.enums
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14

    测试:

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

    上面的@EnumValue注解是因为设置性别为枚举类型的时候,SexEnum.MALE是属性“男”或“女”,而数据库中的sex是数字表示,使用此注解会将@EnumValue注解所标识的属性值存储到数据库。

    五、代码快速生成

    1.逆向工程

    引入依赖:

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

    快速生成代码:

    只需要把代码里的数据库名称和用户密码修改成你的就能运行。
    下面的盘符路径是你代码想生成的位置。
    运行下面代码就可以生成了。

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

    2.MyBatisX插件( 强大)

    首先在idea–>Settings–>Plugins安装MyBatisX插件
    在这里插入图片描述
    其实好多人都用过这个插件,有了这个插件我们就能轻松找到mapper接口与xml映射文件了:点击小蓝鸟或小红鸟就可以快速定位到了。
    在这里插入图片描述

    真正的强大

    上面只是冰山一角,真正的强大开始了。

    首先连接数据库

    在这里插入图片描述
    在这里插入图片描述

    右键要生成的表

    点击MyBatisX-Generator
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

    点击finsh

    你就获得了这样的目录结构:
    在这里插入图片描述

    见证强大

    在UserMapper里添加方法:
    根据用户名和uid删除(这俩是表里的属性):
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述
    鼠标放在该方法上Alt+Enter
    在这里插入图片描述
    在这里插入图片描述
    自动生成了这些。
    大家可以看到在写方法的时候都是自动有提示的你只需要打出想要的增删改操作首字母(i,d,u)后面的操作就根据弹出的提示选择就可以了。

    六、多数据源操作

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

    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

    1.引入依赖

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

    2.配置多数据源

    spring:
      # 配置数据源信息
      datasource:
        dynamic:
          # 设置默认的数据源或者数据源组,默认值即为master
          primary: master
          # 严格匹配数据源,默认false.  true未匹配到指定数据源时抛异常,false未匹配到使用默认数据源
          strict: false
          datasource:
            master:
              url: jdbc:mysql://localhost:3306/mybatis_plus
              driver-class-name: com.mysql.cj.jdbc.Driver
              username: root
              password: root
            slave_1:
              url: jdbc:mysql://localhost:3306/mybatis_plus_1
              driver-class-name: com.mysql.cj.jdbc.Driver
              username: root
              password: root
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19

    3.service

    UserServiceImpl和UserService:

    @Service
    @DS("master")
    public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
    }
    =================================
    public interface UserService extends IService<User> {
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    ProductServiceImpl和ProductService:

    @Service
    @DS("slave_1")
    public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
    }
    ===================================
    public interface ProductService extends IService<Product> {
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    4.测试

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

    @DS这个注解如果添加在类上就是为整个类配置数据源,如果在方法上就是仅仅为这个方法配置数据源。使用这个我们就可以实现多个数据库一起使用了。


    总结

    以上就是MyBatisPlus的讲解。

  • 相关阅读:
    无人机的视频图传技术
    一个基于.Net Core、Vue开发仿掘金的CMS开源系统
    C#开发的OpenRA游戏之电力系统之二
    消息队列Beanstalkd介绍
    【Rust 日报】2023-11-19 solars:可视化太阳系
    在云服务器上安装配置和调优Zerotier服务器的详细教程
    【Unity基础】4.动画Animation
    华南理工大学建筑学院建筑设计及其理论专业考研上岸经验分享
    @RequestBody详解:用于获取请求体中的Json格式参数
    金仓数据库 KingbaseES 客户端编程接口指南 - JDBC(11. JDBC 示例说明)
  • 原文地址:https://blog.csdn.net/weixin_62951900/article/details/133843043