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

Mybatis-plus超详细讲解(2022)

2022-05-15 2686
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群版 2核4GB 100GB
推荐场景：
搭建个人博客
云数据库 RDS MySQL，高可用版 2核4GB 50GB
简介： 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
算法
数据库
数据库连接
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
java小豪
目录
相关文章
橙子先生
|
3月前
|
SQL 缓存 Java
浅谈mybatis
浅谈mybatis
橙子先生
18 1
疯狂的猿
|
3月前
|
SQL Java 数据库连接
MyBatis-Plus详细介绍
MyBatis-Plus是基于MyBatis框架的增强工具，致力于简化MyBatis的开发。它提供了一系列的增强功能，包括代码生成器、分页查询、性能分析等，大大提高了开发效率。
疯狂的猿
27 0
waynaqua
|
9月前
|
SQL Java 关系型数据库
mybatis plus很好，但是我被它坑了！
作者今天在开发一个后台发送消息的功能时，由于需要给多个用户发送消息，于是使用了 mybatis plus 提供的 saveBatch() 方法，在测试环境测试通过上预发布后，测试反应发送消息接口很慢得等 5、6 秒，于是我就登录预发布环境查看执行日志，发现是 mybatis plus 提供的 saveBatch() 方法执行很慢导致，于是也就有了本篇文章。
waynaqua
48 1
快乐阿超
|
8月前
|
Java 数据库连接 测试技术
mybatis中@Many
mybatis中@Many
快乐阿超
77 0
YiShier
|
10月前
|
XML Java 数据库连接
MyBatis-Plus
MyBatis-Plus
YiShier
45 0
游客kb3w2zc7tyqew
|
11月前
|
XML Java 数据库连接
MyBatis-Plus使用
MyBatis-Plus使用
游客kb3w2zc7tyqew
170 0
不懂开发的程序猿
|
SQL 缓存 IDE
MyBatis总结
MyBatis总结
不懂开发的程序猿
78 0
京茶吉鹿
|
SQL 存储 算法
MyBatis-Plus详解
MyBatis-Plus详解
京茶吉鹿
159 0
这人是个程序员
|
SQL Java 数据库连接
Mybatis三剑客
Mybatis三剑客
这人是个程序员
185 0
Mybatis三剑客
1446108432
|
SQL
你应该知道的这些Mybatis-Plus使用技巧（下）
最近在用 Mybatis-Plus，嗯，真香！！！今天就来说说 Mybatis-Plus 的那些使用技巧
1446108432
555 0