Mybatis-plus超详细讲解(2022)

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: MyBatis-Plus(简称 MP)是一个 MyBatis 的增强工具,在 MyBatis 的基础上只做增强不做改变,为简化开发、提高效率而生。我们的愿景是成为 MyBatis 最好的搭档,就像 魂斗罗 中的 1P、2P,基友搭配,效率翻倍。

Mybatis-plus学习笔记

1、创建数据库及表

1.1、创建表

CREATE DATABASE `mybatis_plus`;USE `mybatis_plus`;CREATETABLE `user`
(        `id` BIGINT(20)NOTNULL COMMENT '主键ID',        `name` VARCHAR(30)NULL DEFAULT NULL COMMENT '姓名',        `age` INT(11)NULL DEFAULT NULL COMMENT '年龄',        `email` VARCHAR(50)NULL DEFAULT NULL COMMENT '邮箱',        PRIMARY KEY (`id`))ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

1.2、添加数据

DELETEFROM user;INSERTINTO user (id, name, age, email)VALUES(1,'Jone',18,'test1@baomidou.com'),(2,'Jack',20,'test2@baomidou.com'),(3,'Tom',28,'test3@baomidou.com'),(4,'Sandy',21,'test4@baomidou.com'),(5,'Billie',24,'test5@baomidou.com');

2、创建Spring Boot工程

2.1、初始化工程

使用Spring Initializr 快速初始化一个Spring Boot 工程

MySQL、lombok、mybatis-plus依赖

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><!--mybatis-plus启动器--><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.1</version></dependency><!--mysql驱动器--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><!--lombok依赖用于简化实体类开发--><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope><exclusions><exclusion><groupId>org.junit.vintage</groupId><artifactId>junit-vintage-engine</artifactId></exclusion></exclusions></dependency></dependencies>

安装lombok插件File——>Settings——>Plugins 搜lombok

2.2、配置application.yml(application.properties)

application.yml

spring:# 配置数据源  datasource:# 数据源类型    type: com.zaxxer.hikari.HikariDataSource
# 配置连接数据库的各个信息    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-8&useSSL=false&serverTimezone=GMT2%B8
    username: root
    password: ****

application.properties

spring.datasource.type=com.zaxxer.hikari.HikariDataSourcespring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverspring.datasource.url=jdbc:mysql://localhost:3306/mybatis_plus?useSSL=false&serverTimezone=GMT%2B8spring.datasource.username=rootspring.datasource.password=****

3、创建实体类及lombok的简单使用

3.1、创建实体类

@DatapublicclassUser {
privatelongid;
privateStringname;
privateIntegerage;
privateStringemail;
}

3.2、创建mapper接口

@RepositorypublicinterfaceUserMapperextendsBaseMapper<User> {
}

在启动类上添加@MapperScan

@SpringBootApplication// 扫描mapper所在的包@MapperScan("com.chen.mapper")
publicclassMybatisPlusApplication {
publicstaticvoidmain(String[] args) {
SpringApplication.run(MybatisPlusApplication.class, args);
    }
}

3.3、编写测试类

MybatisPlusTest

@SpringBootTestpublicclassMybatisPlusTest {
@AutowiredprivateUserMapperuserMapper;
@TestpublicvoidtestSelectList() {
// 通过条件构造器查询一个list集合,若有条件,则可以设置为nullList<User>list=userMapper.selectList(null);
list.forEach(System.out::println);
    }
}

3.4、加入日志功能

在application.yml中加入以下代码

mybatis-plus:  configuration:    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

运行之后,可以查看生成SQL语句,也可以使用Log4jImpl对日志进行打印

4、BaseMapper

4.1、BaseMapper的添加方法测试

@TestpublicvoidtestInsert() {
// 实现新增用户信息// INSERT INTO user ( id, name, age, email ) VALUES ( ?, ?, ?, ? )Useruser=newUser();
user.setName("张三");
user.setAge(18);
user.setEmail("zhangsan@atguigu.com");
intresult=userMapper.insert(user);
System.out.println("result:"+result);
System.out.println("id:"+user.getId());
}

4.2、BaseMapper的删除方法测试

@TestpublicvoidtestDelete() {
// 通过ID删除一个用户// DELETE FROM user WHERE id=?/*int result = userMapper.deleteById(1499047219186933761L);System.out.println(result);*/// 根据map集合中的所设置的条件删除用户信息// DELETE FROM user WHERE name = ? AND age = ?/*Map<String, Object> map = new HashMap<>();map.put("name","张三");map.put("age",18);int result = userMapper.deleteByMap(map);System.out.println(result);*/// 通过多个id实现批量删除// DELETE FROM user WHERE id IN ( ? , ? )List<Long>list=Arrays.asList(1499047368323870722L, 1499047451270430721L);
intresult=userMapper.deleteBatchIds(list);
System.out.println(result);
}

4.3、BaseMapper的更新方法测试

@TestpublicvoidtestUpdate() {
// 通过id来更新用户的信息// UPDATE user SET name=?, age=? WHERE id=?Useruser=newUser();
user.setId(1499050741030797314L);
user.setName("张三");
user.setAge(23);
intresult=userMapper.updateById(user);
System.out.println(result);
}

4.4、BaseMapper的查询方法测试

@TestpublicvoidtestSelect() {
// 通过id查询用户信息// SELECT id,name,age,email FROM user WHERE id=?Useruser=userMapper.selectById(1L);
System.out.println(user);
// 通过多个id实现批量查询用户的信息// SELECT id,name,age,email FROM user WHERE id IN ( ? , ? , ? )List<Long>list=Arrays.asList(1L, 2L, 3L);
List<User>userList=userMapper.selectBatchIds(list);
userList.forEach(System.out::println);
// 根据map集合中的条件来查询用户信息// SELECT id,name,age,email FROM user WHERE id = ? AND age = ?Map<String, Object>map=newHashMap<>();
map.put("id",1L);
map.put("age",18);
List<User>users=userMapper.selectByMap(map);
users.forEach(System.out::println);
// 查询所有数据的// SELECT id,name,age,email FROM userList<User>userList=userMapper.selectList(null);
userList.forEach(System.out::println);
}

4.5、自定义功能

Mapper

@RepositorypublicinterfaceUserMapperextendsBaseMapper<User> {
/*** 根据id查询用户信息为map集合* @param id* @return*/Map<String, Object>selectMapById(Longid);
}

UserMapper.xml

<?xmlversion="1.0" encoding="UTF-8"?><!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mappernamespace="com.chen.mapper.UserMapper"><selectid="selectMapById"resultType="java.util.Map"parameterType="java.lang.Long">        SELECT id,name,age,email FROM mybatis_plus.user WHERE id = #{id}
</select></mapper>

Test

@TestpublicvoidselectMapById() {
Map<String, Object>map=userMapper.selectMapById(1L);
System.out.println(map);
}

5、通用Service接口

说明:

5.1、自定义的Service接口

@ServicepublicclassUserServiceImplextendsServiceImpl<UserMapper, User>implementsUserService {
}
// Service 接口publicinterfaceUserServiceextendsIService<User> {
}

测试Service接口查询总数

@SpringBootTestpublicclassMybatisPlusServiceTest {
@AutowiredprivateUserServiceuserService;
@TestpublicvoidtestGetCount() {
// 查询总记录数的// SELECT COUNT( * ) FROM userlongcount=userService.count();
System.out.println(count);
    }
}

Service测试批量添加数据

@TestpublicvoidtestInsertMore() {
// Service接口实现批量添加// INSERT INTO user ( id, name, age ) VALUES ( ?, ?, ? )List<User>list=newArrayList<>();
for (inti=0; i<=10; i++) {
Useruser=newUser();
user.setName("ch"+i);
user.setAge(20+i);
list.add(user);
    }
booleanb=userService.saveBatch(list);
System.out.println(b);
}

5.2、常用注解

5.2.1、@TableName

// 设置实体类所对应的表名
@TableName("t_user")
mybatis-plus:# 设置Mybatis-plus的全局配置    global-config:        db-config:# 设置实体类所对应的标的统一前缀            table-prefix: t_

5.2.2、TableId注解

将属性所对应字段作为主键

@TableId// 将uid作为主键privateLonguid;

TableId的value属性

@TableId(value="uid")
// 将uid作为主键privateLonguid;

TableId的type属性

  • 可以设置主键生成策略
@TableId(value="uid", type=IdType.AUTO)
// 将uid作为主键privateLonguid;

全局配置主键生成策略

# 设置Mybatis-plus的全局配置  global-config:    db-config:# 设置统一的主键生成策略      id-type: auto

雪花算法

snowflake是Twitter开源的分布式ID生成算法,结果是一个long型的ID。其核心思想是:使用41bit作为毫秒数,10bit作为机器的ID(5个bit是数据中心,5个bit的机器ID),12bit作为毫秒内的流水号(意味着每个节点在每毫秒可以产生 4096 个 ID),最后还有一个符号位,永远是0。可以保证几乎全球唯一!

其余源码的解释

publicenumIdType {
AUTO(0), // 数据库id自增NONE(1), // 未设置主键INPUT(2), // 手动输入,自己写idID_WORKER(3), // 默认的全局唯一idUUID(4), // 全局唯一id uuidID_WORKER_STR(5); // ID_WORKER 字符串表示法}

5.2.3、TableField注解

在数据库字段名和自己定义的字段名不一致时可以使用该注解

// 指定属性所对应的字段名@TableField("name")
privateStringname;

5.2.4、TableLogic注解

可以实现对数据库中的数据进行逻辑删除,可以进行数据恢复

  • 在数据库中添加字段is deleted
@TableLogicprivateIntegerisDeleted;

6、条件构造器

6.1、wrapper介绍

在学习Wapper之前,先来看一下它的类图结构。

类图关键类说明:

  • Wrapper : 条件构造抽象类,最顶端父类
  • AbstractWrapper : 用于查询条件封装,生成 sql 的 where 条件
  • QueryWrapper : Entity 对象封装操作类,不是用lambda语法
  • UpdateWrapper : Update 条件封装,用于Entity对象更新操作
  • AbstractLambdaWrapper : Lambda 语法使用 Wrapper统一处理解析 lambda 获取 column。
  • LambdaQueryWrapper :看名称也能明白就是用于Lambda语法使用的查询Wrapper
  • LambdaUpdateWrapper : Lambda 更新封装Wrapper

6.2、QueryWrapper条件构造器

组装条件查询并测试

@TestpublicvoidtestSelectWrapper() {
// 查询用户名包含a,年龄在20到30之间,邮箱信息不为null的用户信息// SELECT id,name,age,email FROM user WHERE (name LIKE ? AND age BETWEEN ? AND ? AND email IS NOT NULL)QueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.like("name","a")
                 .between("age", 20, 30)
                 .isNotNull("email");
List<User>userList=userMapper.selectList(queryWrapper);
userList.forEach(System.out::println);
}

组装排序条件并测试

@Testpublicvoidtest02() {
// 查询用户信息,按照年龄的降序排序,若年龄相同,则按照id升序排序// SELECT id,name,age,email FROM user ORDER BY age DESC,id ASCQueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.orderByDesc("age")
                .orderByAsc("id");
List<User>list=userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}

组装删除条件并测试

@Testpublicvoidtest03() {
// 删除邮箱地址null的用户信息// DELETE FROM user WHERE (email IS NULL)QueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.isNull("email");
inti=userMapper.delete(queryWrapper);
System.out.println(i);
}

组装修改功能并测试

@Testpublicvoidtest04() {
// 将(年龄大于20并且用户名中包含有a)或邮箱为null的用户信息修改// UPDATE user SET name=?, email=? WHERE (age > ? AND name LIKE ? OR email IS NULL)QueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.gt("age", 20)
            .like("name", "a")
            .or()
            .isNull("email");
Useruser=newUser();
user.setName("小明");
user.setEmail("test@atguigu.com");
intresult=userMapper.update(user, queryWrapper);
System.out.println(result);
}

条件优先级的测试

@Testpublicvoidtest05() {
// 将用户名中包含a并且(年龄大于20或邮箱为null)的用户信息修改// Lambda中的条件优先执行// UPDATE user SET name=?, email=? WHERE (name LIKE ? AND (age > ? OR email IS NULL))QueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.like("name", "a")
            .and(i->i.gt("age", 20)
            .or()
            .isNull("email"));
Useruser=newUser();
user.setName("小红");
user.setEmail("tset@atguigu.com");
intresult=userMapper.update(user, queryWrapper);
System.out.println(result);
}

组装select语句

@Testpublicvoidtest06() {
// 查询用户的用户名,年龄,邮箱信息// SELECT name,age,email FROM userQueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.select("name", "age", "email");
List<Map<String, Object>>maps=userMapper.selectMaps(queryWrapper);
maps.forEach(System.out::println);
}

组装子查询并测试

@Testpublicvoidtest07() {
// 查询id小于等于100的用户信息// SELECT id,name,age,email FROM user WHERE (id IN (select id from user where id <= 100))QueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.inSql("id", "select id from user where id <= 100");
List<User>list=userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}

使用UpdateWrapper实现修改功能

@Testpublicvoidtest08() {
// 将用户名中包含a并且(年龄大于20或邮箱为null)的用户信息修改// UPDATE user SET name=?,email=? WHERE (name LIKE ? AND (age > ? OR email IS NULL))UpdateWrapper<User>updateWrapper=newUpdateWrapper<>();
updateWrapper.like("name", "a")
            .and(i->i.gt("age", 20)
                    .or()
                    .isNull("email"));
updateWrapper.set("name", "小黑");
updateWrapper.set("email", "abc@atguigu.com");
intresult=userMapper.update(null, updateWrapper);
System.out.println(result);
}

模拟开发中的组装条件

@Testpublicvoidtest09() {
Stringusername="";
IntegerageBegin=20;
IntegerageEnd=30;
QueryWrapper<User>queryWrapper=newQueryWrapper<>();
if (StringUtils.isNotBlank(username)) {
// 判断某个字符串是否不为空字符串,不为null,不为空白符// SELECT id,name,age,email FROM user WHERE (age >= ? AND age <= ?)queryWrapper.like("name", username);
    }
if (ageBegin!=null) {
queryWrapper.ge("age", ageBegin);
    }
if (ageEnd!=null) {
queryWrapper.le("age", ageEnd);
    }
List<User>list=userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}

使用condition动态组装条件

@Testpublicvoidtest() {
Stringusername="a";
IntegerageBegin=null;
IntegerageEnd=30;
QueryWrapper<User>queryWrapper=newQueryWrapper<>();
queryWrapper.like(StringUtils.isNotBlank(username), "name", username)
            .ge(ageBegin!=null, "age", ageBegin)
            .lt(ageEnd!=null, "age", ageEnd);
List<User>list=userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}

LambdaQueryWrapper

@Testpublicvoidtest11() {
// SELECT id,name,age,email FROM user WHERE (name LIKE ? AND age < ?)Stringusername="a";
IntegerageBegin=null;
IntegerageEnd=30;
LambdaQueryWrapper<User>queryWrapper=newLambdaQueryWrapper<>();
queryWrapper.like(StringUtils.isNotBlank(username), User::getName, username)
            .ge(ageBegin!=null, User::getAge, ageBegin)
            .lt(ageEnd!=null, User::getAge, ageEnd);
List<User>list=userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}

LambdaUpdateWrapper

@Testpublicvoidtest12() {
// 将用户名中包含a并且(年龄大于20或邮箱为null)的用户信息修改LambdaUpdateWrapper<User>updateWrapper=newLambdaUpdateWrapper<>();
updateWrapper.like(User::getName, "a")
            .and(i->i.gt(User::getAge, 20)
                    .or()
                    .isNull(User::getEmail));
updateWrapper.set(User::getName, "小黑").set(User::getName, "abc@atguigu.com");
intresult=userMapper.update(null, updateWrapper);
System.out.println(result);
}

7、插件

7.1、分页插件

Mybatis-plus自带分页插件,自己需要简单的配置计科实现分页功能

添加配置

  • 可以把启动类上的扫描mapper的注解放在MyBatisPlusConfig上
@Configuration// 扫描mapper所在的包@MapperScan("com.chen.mapper")
publicclassMyBatisPlusConfig {
@Bean// 配置MybatisPlus中的插件publicMybatisPlusInterceptormybatisPlusInterceptor() {
MybatisPlusInterceptorinterceptor=newMybatisPlusInterceptor();
interceptor.addInnerInterceptor(newPaginationInnerInterceptor(DbType.MYSQL));
returninterceptor;
    }
}    
@TestpublicvoidtestPage() {
Page<User>page=newPage<>(1, 3);
userMapper.selectPage(page, null);
System.out.println(page);
}

获取分页相关的数据

@TestpublicvoidtestPage() {
Page<User>page=newPage<>(2, 3);
userMapper.selectPage(page, null);
System.out.println(page.getRecords());
System.out.println(page.getPages());
System.out.println(page.getTotal());
System.out.println(page.hasNext());
System.out.println(page.hasPrevious());
}

自定义的分页功能

/*** 通过年龄查询用户信息并分页* @param page  Mybatis-Plus所提供的分页对象,必须位于第一个参数的位置* @param age   参数值* @return  返回值*/Page<User>selectPageVo(@Param("page") Page<User>page, @Param("age") Integerage);
<select id="selectPageVo" resultType="com.chen.pojo.User">SELECT id, name, age, email FROM mybatis_plus.userWHERE age > #{age}</select>
@TestpublicvoidtestPageVo() {
Page<User>page=newPage<>();
userMapper.selectPageVo(page, 20);
System.out.println(page.getRecords());
System.out.println(page.getPages());
System.out.println(page.getTotal());
System.out.println(page.hasNext());
System.out.println(page.hasPrevious());
}

6.2、乐观锁

6.2.1、模拟修改冲突

数据库中增加商品表

CREATETABLE product
(    id BIGINT(20)NOTNULL COMMENT '主键id',    NAME VARCHAR(30)NULL DEFAULT NULL COMMENT '商品名称',    price INT(11) DEFAULT 0 COMMENT '价格',    VERSION INT(11) DEFAULT 0 COMMENT '乐观锁版本号',    PRIMARY KEY (id));

添加数据

INSERTINTO t_product (id, NAME, price)VALUES(1,'外星人',10000);

创建实体类

packagecom.chen.pojo;
importlombok.Data;
@DatapublicclassProduct {
privateLongid;
privateStringname;
privateIntegerprice;
privateIntegerversion;
}

添加Mapper

@Repository// 持久化注解publicinterfaceProductMapperextendsBaseMapper<Product> {
}

模拟修改冲突问题

@TestpublicvoidtestProduct01() {
// 小李查询商品价格ProductproductLi=productMapper.selectById(1);
System.out.println("小李查询的商品价格:"+productLi.getPrice());
// 小王查询商品价格ProductproductWang=productMapper.selectById(1);
System.out.println("小王查询的商品价格:"+productWang.getPrice());
// 小李将商品价格+50productLi.setPrice(productLi.getPrice() +50);
productMapper.updateById(productLi);
// 小王将商品的价格-30productWang.setPrice(productWang.getPrice() -30);
productMapper.updateById(productWang);
// 老板查询商品价格ProductproductBOSS=productMapper.selectById(1);
System.out.println("老板查询的商品价格:"+productBOSS.getPrice());
}

乐观锁的实现流程

取出记录是,获取当前的version

SELECT id, `name`, price, `version` FROM product WHERE id =1

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

UPDATE product SET price = price +50, `version` = `version` +1WHERE id =1AND `version` =1;

Mybatis-plus实现乐观锁

修改实体类

@DatapublicclassProduct {
privateLongid;
privateStringname;
privateIntegerprice;
// 表示乐观锁版本号字段@VersionprivateIntegerversion;
}

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

// 添加乐观锁插件interceptor.addInnerInterceptor(newOptimisticLockerInnerInterceptor());

重新进行测试

@TestpublicvoidtestProduct01() {
// 小李查询商品价格ProductproductLi=productMapper.selectById(1);
System.out.println("小李查询的商品价格:"+productLi.getPrice());
// 小王查询商品价格ProductproductWang=productMapper.selectById(1);
System.out.println("小王查询的商品价格:"+productWang.getPrice());
// 小李将商品价格+50productLi.setPrice(productLi.getPrice() +50);
productMapper.updateById(productLi);
// 小王将商品的价格-30productWang.setPrice(productWang.getPrice() -30);
intresult=productMapper.updateById(productWang);
if (result==0) {
// 操作失败,重试ProductproductNew=productMapper.selectById(1);
productNew.setPrice(productNew.getPrice() -30);
productMapper.updateById(productNew);
    }
// 老板查询商品价格ProductproductBoss=productMapper.selectById(1);
System.out.println("老板查询的商品价格:"+productBoss.getPrice());
}

8、通用枚举

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

数据库添加字段sex

在实体类中添加属性

privateSexEnumsex;

创建枚举类型

@GetterpublicenumSexEnum {
/****/MALE(1, "男"),
FEMALE(2, "女");
// 将注解所标识的属性值保存到数据库中@EnumValueprivateIntegersex;
privateStringsexname;
SexEnum(Integersex, Stringsexname) {
this.sex=sex;
this.sexname=sexname;
    }
}

创建测试类

@SpringBootTestpublicclassMybatisPlusEnumTest {
@AutowiredprivateUserMapperuserMapper;
@Testpublicvoidtest() {
Useruser=newUser();
user.setName("admin");
user.setAge(33);
user.setSex(SexEnum.MALE);
intinsert=userMapper.insert(user);
System.out.println(insert);
    }
}

需要在配置文件中配置通用枚举的扫描包

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.chen.pojo#扫描通用枚举的包type-enums-package: com.chen.enums

9、代码生成器

9.1、引入依赖

<!--代码生成器的依赖--><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId><version>3.4.1</version></dependency><dependency><groupId>org.freemarker</groupId><artifactId>freemarker</artifactId></dependency>

9.2、快速生成

publicclassFastAutoGeneratorTest {
publicstaticvoidmain(String[] args) {
FastAutoGenerator.create("jdbc:mysql://localhost:3306/mybatis_plus?useSSL=false&serverTimezone=GMT%2B8",
"root", "root")
                .globalConfig(builder-> {
builder.author("chen") // 设置作者//.enableSwagger() // 开启 swagger 模式                            .fileOverride() // 覆盖已生成文件                            .outputDir("D://mybatis-plus"); // 指定输出目录                })
                .packageConfig(builder-> {
builder.parent("com.chen") // 设置父包名                            .moduleName("mybatis-plus") // 设置父包模块名                            .pathInfo(Collections.singletonMap(OutputFile.mapperXml, "D://mybatis-plus")); // 设置mapperXml生成路径                })
                .strategyConfig(builder-> {
builder.addInclude("user") // 设置需要生成的表名                            .addTablePrefix("t_", "c_"); // 设置过滤表前缀                })
                .templateEngine(newFreemarkerTemplateEngine()) // 使用Freemarker引擎模板,默认的是Velocity引擎模板                .execute();
    }
}

10、多数据源

10.1、创建数据库及表

创建数据库mybatis_plus_1和表product

CREATE DATABASE mybatis_plus_1;
USE mybatis_plus_1;
CREATE TABLE 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)
);

添加测试数据

INSERTINTO product (id, NAME, price)VALUES(1,'外星人',100);

删除mybatis_plus库和product表

USE mybatis_plus;DROPTABLE IF EXISTS product;

10.2、引入依赖

<dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>3.5.0</version></dependency>

10.3、配置多数据源

说明:注释掉之前的数据库连接,添加新配置

spring:# 配置数据源信息  datasource:    dynamic:# 设置默认的数据源或数据源组,默认值即为master      primary: master
# 严格匹配数据源,默认false,true未匹配到指定数据源时抛异常,false使用默认数据源      strict: false      datasource:        master:          url: jdbc:mysql://localhost:3306/mybatis_plus?useSSL=false&serverTimezone=GMT%2B8
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: root
        save_1:          url: jdbc:mysql://localhost:3306/mybatis_plus_1?useSSL=false&serverTimezone=GMT%2B8
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: root

10.4、创建用户service

publicinterfaceUserServiceextendsIService<User> {
}
@DS("master")
@ServicepublicclassUserServiceImplextendsServiceImpl<UserMapper, User>implementsUserService {
}

10.5、创建商品service

publicinterfaceProductServiceextendsIService<Product> {
}
@DS("slave_1")
@ServicepublicclassProductServiceImplextendsServiceImpl<ProductMapper, Product>implementsProductService {
}

10.6、测试

@AutowiredprivateUserServiceuserService;
@AutowiredprivateProductServiceproductService;
@Testpublicvoidtest() {
System.out.println(userService.getById(1));
System.out.println(productService.getById(1));
}

11、MybatisX插件

安装

MybatisX插件的用法:https://baomidou.com/pages/ba5b24

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
SQL Java 数据库连接
|
SQL Java 数据库连接
Mybatis之discriminator(鉴别器)详解
前言 最近干了一个工作是使用discriminator去写一个新的API,那么写这个新的API原因是什么呢?原因是这样的:我们的项目使用Mybatis,我们项目中有一个实体类叫做User,在User中还含有很多别的实体类,例如Role,Permission,Address等(有经验的肯定知道这种嵌套实体类的情况,使用和)。
4143 0
|
4月前
|
SQL Java 数据库连接
MyBatis常用的小技巧
这篇文章分享了MyBatis中的一些常用技巧,包括使用`in`语句处理字符串或集合参数、在`insert`语句后获取自增ID,以及使用`like concat`进行模糊查询以防止SQL注入。
24 0
|
Java 数据库连接 测试技术
mybatis中@Many
mybatis中@Many
104 0
|
XML Java 数据库连接
MyBatis-Plus使用
MyBatis-Plus使用
|
SQL XML 缓存
了解mybatis
了解mybatis
68 0
|
SQL XML 缓存
Mybatis详解(1)
你好看官,里面请!今天笔者讲的是Mybatis详解(1)。不懂或者觉得我写的有问题可以在评论区留言,我看到会及时回复。 注意:本文仅用于学习参考,不可用于商业用途,如需转载请跟我联系。
241 2
|
SQL Java 数据库连接
|
SQL 算法 Oracle
MyBatis-Plus的使用
MyBatis-Plus的使用
176 1
MyBatis-Plus的使用
|
Java 数据库连接 mybatis
MyBatis总结
MyBatis总结
72 0
MyBatis总结