AI 助理
文档备案控制台
开发者社区 数据库 文章 正文

Mybatis-plus超详细讲解(2022)

2022-05-15 4527
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 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

文章标签：
云数据库 RDS MySQL 版
Java
SQL
关系型数据库
MySQL
Spring
数据中心
mybatis
算法
数据库
数据库连接
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
java小豪
目录
相关文章
从未止步..
|
SQL 测试技术 数据库
一篇文章带你学会MybatisPlus~（三）
一篇文章带你学会MybatisPlus~
从未止步..
342 0
怒放吧德德
|
存储 JavaScript 前端开发
【前端系列】- 富文本组件(mavon-editor)
mavon-editor是一款基于vue的markdown编辑器，可以用来做文本的编辑，比如是某种业务需要发送公告、个人博客等，都可以用到，操作也十分简单。
怒放吧德德
5019 0
【前端系列】- 富文本组件(mavon-editor)
程序员王天
|
前端开发 JavaScript 容器
三行代码，完美解决vue-quill-editor富文本样式失效问题
只用三行代码哦
程序员王天
1436 1
游客rptpd75w3yo66
|
9月前
|
运维 监控 Shell
【自动化运维】告别手动搬运！编写Shell脚本自动备份与清理日志
本文介绍如何通过Shell脚本结合Crontab，实现服务器日志的自动备份与清理。每天凌晨2点自动压缩昨日日志并保存至备份目录，同时删除7天前的旧备份，防止磁盘占满。脚本具备目录创建、压缩打包、错误提示和日志记录功能，操作安全可靠，适合Linux运维新手实践自动化管理。
游客rptpd75w3yo66
823 0
游客h2p5himj2xcrw
|
消息中间件 自然语言处理 搜索推荐
超卖率从3%到0.2%：商品API如何让商家告别“库存噩梦”？
本文深入解析电商API接口的核心功能与技术架构，涵盖商品管理、订单处理、支付系统与物流履约四大模块，揭示其如何实现跨平台、跨场景的无缝衔接，支撑现代电商业务高效运转。
游客h2p5himj2xcrw
457 0
阿珊和她的猫
|
移动开发 JSON 前端开发
跨域资源共享（CORS）：详解跨域请求的限制与解决方法
跨域资源共享（CORS）：详解跨域请求的限制与解决方法
阿珊和她的猫
3228 1
游客g7tyjakgxxk5g
|
敏捷开发 数据可视化 前端开发
敏捷开发任务分配工具选型指南：功能、价格与适用场景
Scrum团队任务分配常面临冲刺目标模糊、资源失衡、进度断层与协作不畅四大痛点。解决关键在于建立适配Scrum流程的任务分配机制，遵循需求拆解、资源匹配、进度可视、协作衔接与迭代优化五大原则。合理选用板栗看板、Jira等工具，并通过流程适配、团队培训与数据复盘，提升分配效率，实现敏捷开发闭环，助力团队摆脱混乱、提升效能。
游客g7tyjakgxxk5g
476 0
敏捷开发任务分配工具选型指南：功能、价格与适用场景
我是快乐的嘟嘟
Flutter 实现扫码
Flutter 实现扫码
我是快乐的嘟嘟
753 59
bailiantest1
|
人工智能 Java 语音技术
【最佳实践系列】零基础上手阿里云百炼语音AI模型
阿里云百炼语音AI服务提供了丰富的功能，包括语音识别、语音合成、实时翻译等。通过`alibabacloud-bailian-speech-demo`项目，可以一键调用这些服务，体验语音及大模型的魅力，降低接入门槛。该项目支持Python和Java，涵盖从简单的一句话合成到复杂的同声传译等多个示例，助力开发者快速上手并进行二次开发。
bailiantest1
3957 5
技术小达人
|
缓存 算法 搜索推荐
618省心凑背后的新算法——个性化凑单商品打包购推荐
作为购物导购链路的一个重要环节，凑单旨在快速帮助用户找到达成某个满减门槛（比如满300减50）的商品，完成性价比最高的跨店组合结算。
技术小达人
1702 0
618省心凑背后的新算法——个性化凑单商品打包购推荐

热门文章

最新文章

  • 1
    PolarDB Serverless能力测评：秒级弹升、无感伸缩与强一致性，助您实现高效云数据库管理！
  • 2
    TableStore: 海量结构化数据分层存储方案
  • 3
    IDM软件许可证密钥Internet Download Manager2023中文语言支持
  • 4
    数据库基础知识
  • 5
    linux cp命令参数及用法详解---linux 复制文件命令cp
  • 6
    阿里云OSS图床搭建
  • 7
    如何修复 Android 和 Windows 不支持视频编解码器的问题？
  • 8
    Java技术周刊第14期：浅谈HashMap，探索JDK（集合框架）
  • 9
    换npm yarn的源让install超时去死吧
  • 10
    跑腿小程序配送费到底怎么定？低价真的能带来订单吗？
  • 1
    复用 Qwen3-ASR 的解码器做口述整理：一个 1.7B LoRA 的训练记录
    40
  • 2
    非一样的感觉，万相 3.0 基于SKILL视频生成！
    53
  • 3
    大模型本质是词语接龙：Transformer的极简进化史
    26
  • 4
    智以致用，安全先行！——2026云栖大会阿里云安全专场全攻略
    48
  • 5
    阿里云百炼Coding Plan最新说明（之前的失效了）只有Pro高级套餐、每天9:30开抢，按请求次数计费
    29
  • 6
    最新版：阿里云Coding Plan官方订阅入口，Pro高级版每天9:30开抢，不支持退款！
    29
  • 7
    阿里云百炼CodingPlan Pro套餐购买页面长啥样？一键直达
    21
  • 8
    阿里云百炼AI大模型官网链接入口：免费Tokens领取、按量付费、TokenPlan及CodingPlan计费指南
    33
  • 9
    阿里云百炼官网入口：前台、后台、免费Tokens领取、按量付费、TokenPlan及CodingPlan计费说明
    35
  • 10
    AI写代码越来越快，测试工程师还在比“一天写多少用例”吗？
    25

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！