Mybaties-Plus【SpringBoot版】看着一篇章就够啦。

文章目录

• 一、MyBatis-Plus简介
• 二、基本的简单认识
• • 1)、简单环境搭建
  • 2)、基本CRUD
  • 3)、通用Service
• 三、常见的注解
• • 1)、@TableName
  • 2)、@TableId
  • 3)、@TableField
  • 4)、@TableLogic
• 四、条件构造器和常用接口
• • 1)、条件构造器体系的基本了解
  • 2)、QueryWrapper
  • 3)、UpdateWrapper
  • 4)、Condition
  • 5)、LambdaQueryWrapper
  • 6)、LambdaUpdateWrapper
• 五、插件
• • 1)、分页插件
  • 2)、乐观锁
  • 2)、创建通用枚举类型
• 六、代码生成器
• 七、多数据源
• 八、MyabtiesX插件

一、MyBatis-Plus简介

1、简介
MyBatis-Plus(简称 MP)是一个 MyBatis的增强工具，在 MyBatis 的基础上只做增强不做改变，为 简化开发、提高效率而生

---

2、特性
● 无侵入:只做增强不做改变，引入它不会对现有工程产生影响，如丝般顺滑 损耗小:启动即会自动注入基本 CURD，性能基本无损耗，直接面向对象操作
● 强大的 CRUD 操作:内置通用 Mapper、通用 Service，仅仅通过少量配置即可实现单表大部分 CRUD 操作，更有强大的条件构造器，满足各类使用需求
● 支持 Lambda 形式调用:通过 Lambda 表达式，方便的编写各类查询条件，无需再担心字段写错
● 支持主键自动生成:支持多达 4 种主键策略(内含分布式唯一 ID 生成器 - Sequence)，可自由 配置，完美解决主键问题
● 支持 ActiveRecord 模式:支持 ActiveRecord 形式调用，实体类只需继承 Model 类即可进行强 大的 CRUD 操作
支持自定义全局通用操作:支持全局通用方法注入( Write once, use anywhere )
● 内置代码生成器:采用代码或者 Maven 插件可快速生成 Mapper 、 Model 、 Service 、 Controller 层代码，支持模板引擎，更有超多自定义配置等您来使用
● 内置分页插件:基于 MyBatis 物理分页，开发者无需关心具体操作，配置好插件之后，写分页等 同于普通 List 查询
● 分页插件支持多种数据库:支持 MySQL、MariaDB、Oracle、DB2、H2、HSQL、SQLite、 Postgre、SQLServer 等多种数据库
● 内置性能分析插件:可输出 SQL 语句以及其执行时间，建议开发测试时启用该功能，能快速揪出 慢查询

---

3、支持数据库
任何能使用MyBatis进行 CRUD, 并且支持标准 SQL 的数据库，具体支持情况如下
● MySQL，Oracle，DB2，H2，HSQL，SQLite，PostgreSQL，SQLServer，Phoenix，Gauss ， ClickHouse，Sybase，OceanBase，Firebird，Cubrid，Goldilocks，csiidb
● 达梦数据库，虚谷数据库，人大金仓数据库，南大通用(华库)数据库，南大通用数据库，神通数据 库，瀚高数据库

---

4、代码及文档地址

• 官方地址:http://mp.baomidou.com

• 代码发布地址:

• Github: https://github.com/baomidou/mybatis-plus

• Gitee: https://gitee.com/baomidou/mybatis-plus

• 文档发布地址:https://baomidou.com/pages/24112f

二、基本的简单认识 1)、简单环境搭建

1、开发环境

• IDE:idea 2019.2
• JDK:JDK8+
• 构建工具:maven 3.5.4
• MySQL版本:MySQL 5.7
• Spring Boot:2.6.3
• MyBatis-Plus:3.5.1

---

2、创建数据库和表

## 创建数据库
CREATE DATABASE `mybatis_plus` ;
##进入数据库
use `mybatis_plus`;
## 创建表
CREATE TABLE `user`
(
   `id`    bigint(20) NOT NULL COMMENT '主键ID',
   `name`  varchar(30) DEFAULT NULL COMMENT '姓名',
   `age`   int(11)     DEFAULT NULL COMMENT '年龄',
   `email` varchar(50) DEFAULT NULL COMMENT '邮箱',
   PRIMARY KEY (`id`)
) ENGINE = InnoDB
 DEFAULT CHARSET = utf8;

添加数据

INSERT INTO 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');

---

3、添加依赖

    
        org.springframework.boot
        spring-boot-starter
    
    
        org.springframework.boot
  spring-boot-starter-test
        test
    
    
        com.baomidou
        mybatis-plus-boot-starter
        3.5.1
    
    
        org.projectlombok
        lombok
        true
    
    
        mysql
        mysql-connector-java
        runtime
    

---

4.配置application.yml

配置application.yml

1. 驱动类易错说明

• spring boot 2.0(内置jdbc5驱动)，驱动类使用 : driver-class-name: com.mysql.jdbc.Driver
• Spring boot 2.1及以上(内置jdbc8驱动)，驱动类使用: driver-class-name: com.mysql.cj.jdbc.Driver

2. 连接地址url

• MySQL5.7版本的url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-8&useSSL=false

• MySQL8.0版本的url: jdbc:mysql://localhost:3306/mybatis_plus?
  serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false

否则运行测试用例报告如下错误:
java.sql.SQLException: The server time zone value ‘ÖÐ1ú±ê×1⁄4ʱ1⁄4ä’ is unrecognized or represents more

    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
username: root
    password: 123456
##配置MyBatis日志
mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

---

6、 启动类

@SpringBootApplication
@MapperScan("com.atguigu.mybatisplus.mapper")
public class MybatisplusApplication {
    public static void main(String[] args) {
        SpringApplication.run(MybatisplusApplication.class, args);
} }

---

7、 添加实体

@Data //lombok注解
 public class User {
    private Long id;
    private String name;
    private Integer age;
    private String email;
}

---

8、添加Mapper

public interface UserMapper extends BaseMapper {
}

---

9、测试

@SpringBootTest
public class MybatisPlusTest {
    @Autowired
    private UserMapper userMapper;
@Test
public void testSelectList(){ 
	//selectList()根据MP内置的条件构造器查询一个list集合，null表示没有条件，即查询所有 userMapper.selectList(null).forEach(System.out::println);
 } 

---

2)、基本CRUD

1. 插入

最终执行的结果，所获取的id为1475754982694199298 ，这是因为MyBatis-Plus在实现插入数据时，会默认基于雪花算法的策略生成id

@Test
public void testInsert(){
	User user = new User(null, "张三", 23, "zhangsan@atguigu.com"); 
	//INSERT INTO user ( id, name, age, email ) VALUES ( ?, ?, ?, ? ) 
	int result = userMapper.insert(user); 
	System.out.println("受影响行数:"+result);
	//1475754982694199298 
	System.out.println("id自动获取:"+user.getId());
}

---

2.删除

2.1 通过id删除记录

 @Test
public void testDeleteById(){
	//通过id删除用户信息
	//DELETE FROM user WHERe id=?
	int result = userMapper.deleteById(1475754982694199298L); 
	 System.out.println("受影响行数:"+result);
}

2.2 通过id批量删除记录

@Test
public void testDeleteBatchIds(){ 
    //通过多个id批量删除
	//DELETE FROM user WHERe id IN ( ? , ? , ? ) 
	List idList = Arrays.asList(1L, 2L, 3L); 
	int result = userMapper.deleteBatchIds(idList); 
	System.out.println("受影响行数:"+result);
}

2.3 通过map条件删除记录

@Test
public void testDeleteByMap(){ 
	//根据map集合中所设置的条件删除记录
	//DELETE FROM user WHERe name = ? AND age = ? 
	Map map = new HashMap<>(); 
	map.put("age", 23);
	map.put("name", "张三");
	int result = userMapper.deleteByMap(map); 
	System.out.println("受影响行数:"+result);
}

---

3. 修改

Test
public void testUpdateById(){
	User user = new User(4L, "admin", 22, null); 
	//UPDATE user SET name=?, age=? WHERe id=? 
	int result = userMapper.updateById(user); 
	System.out.println("受影响行数:"+result);
}

---

4. 查询

通过观察BaseMapper中的方法，大多方法中都有Wrapper类型的形参，此为条件构造器，可针
对于SQL语句设置不同的条件，若没有条件，则可以为该形参赋值null，即查询(删除/修改)所 有数据

4.1 通过id查询信息

@Test
public void testSelectById(){
	//根据id查询用户信息
	//SELECT id,name,age,email FROM user WHERe id=? 
	User user = userMapper.selectById(4L);
    System.out.println(user);
}

4.2 通过多个id查询多个信息

@Test
public void testSelectBatchIds(){
	//根据多个id查询多个用户信息
	//SELECT id,name,age,email FROM user WHERe id IN ( ? , ? ) 
	List idList = Arrays.asList(4L, 5L);
	List list = userMapper.selectBatchIds(idList)
	list.forEach(System.out::println);
}

4.3 通过map条件查询用户信息

@Test
public void testSelectByMap(){
	//通过map条件查询用户信息
	//SELECT id,name,age,email FROM user WHERe name = ? AND age = ? 
	Map map = new HashMap<>();
	map.put("age", 22);
	map.put("name", "admin");
	List list = userMapper.selectByMap(map);    list.forEach(System.out::println);
}

4.4 查询所有信息

@Test
public void testSelectList(){ //查询所有用户信息
    //SELECT id,name,age,email FROM user
    List list = userMapper.selectList(null);
    list.forEach(System.out::println);
}

3)、通用Service

● MyBatis-Plus中有一个接口 IService和其实现类 ServiceImpl，封装了常见的业务层逻辑

3.1 创建Service接口和实现类

public interface UserService extends IService{

}

@Service
public class UserServiceImpl extends ServiceImpl implements UserService {
	
}

3.2 测试

@Autowired
private UserService userService;

@Test
public void testGetCount(){
	long count = userService.count(); System.out.println("总记录数:" + count);
}
@Test
public void testSaveBatch(){
// SQL长度有限制，海量数据插入单条SQL无法实行，
// 因此MP将批量插入放在了通用Service中实现，而不是通用Mapper ArrayList users = new ArrayList<>();
for (int i = 0; i < 5; i++) {
        User user = new User();
        user.setName("ybc" + i);
        user.setAge(20 + i);
        users.add(user);
}
    //SQL:INSERT INTO t_user ( username, age ) VALUES ( ?, ? )
    userService.saveBatch(users);
}

三、常见的注解 1)、@TableName

在实体类类型上添加@TableName(“t_user”)，标识实体类对应的表，即可成功执行SQL语句

当然我们也可以通过yml的全局配置文件进行，全局映射

mybatis-plus:
 configuration:
 # 配置MyBatis日志
 log-impl:  org.apache.ibatis.logging.stdout.StdOutImpl
 global-config:
 db-config:
 # 配置MyBatis-Plus操作表的默认前缀 
 table-prefix: t_

---

2)、@TableId

经过以上的测试，MyBatis-Plus在实现CRUD时，会默认将id作为主键列，并在插入数据时，默认 基于雪花算法的策略生成id
若实体类和表中表示主键的不是id，而是其他字段，例如uid，MyBatis-Plus会自动识别uid为主 键列吗?
我们实体类中的属性id改为uid，将表中的字段id也改为uid，测试添加功能 程序抛出异常，Field ‘uid’ doesn’t
have a default value，说明MyBatis-Plus没有将uid作为主键 赋值

---

3)、@TableField

---

4)、@TableLogic

四、条件构造器和常用接口 1)、条件构造器体系的基本了解

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 queryWrapper = new QueryWrapper<>();
    queryWrapper.like("username", "a")
            .between("age", 20, 30)
            .isNotNull("email");
    List list = userMapper.selectList(queryWrapper);
    list.forEach(System.out::println);
}

---

例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 queryWrapper = new QueryWrapper<>();
    queryWrapper
            .orderByDesc("age")
            .orderByAsc("id");
    List users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
}

---

例3:组装删除条件

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

---

例4:条件的优先级

方法一：

函数之前的拼接默认都是and拼接的，且他们是一体的

@Test
public void test04() {
QueryWrapper 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@atguigu.com");
int result = userMapper.update(user, queryWrapper); System.out.println("受影响的行数:" + result);
}

---

方法二：

可以利用and方法，将绑定的关系，整合在一起

@Test
public void test04() {
QueryWrapper 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@atguigu.com");
int result = userMapper.update(user, queryWrapper); 
System.out.println("受影响的行数:" + result);

---

例5:只查询出来固定的几个属性

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

---

例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 queryWrapper = new QueryWrapper<>();
    queryWrapper.inSql("id", "select id from t_user where id <= 3");
    List list = userMapper.selectList(queryWrapper);
    list.forEach(System.out::println);
}

---

3)、UpdateWrapper

@Test
public void test07() { 
//将(年龄大于20或邮箱为null)并且用户名中包含有a的用户信息修改 
//组装set子句以及修改条件
UpdateWrapper updateWrapper = new UpdateWrapper<>(); 
//lambda表达式内的逻辑优先运算
updateWrapper
        .set("age", 18)
        .set("email", "user@atguigu.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 > ? ORemail IS NULL))
    int result = userMapper.update(null, updateWrapper);
    System.out.println(result);
}

---

4)、Condition

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

@Test
public void test08UseCondition() {
//定义查询条件，有可能为null(用户未输入或未选择)
String username = null;
Integer ageBegin = 10;
Integer ageEnd = 24;
QueryWrapper 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 users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
}

---

5)、LambdaQueryWrapper

利用函数式接口，防止字段名写错

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

---

6)、LambdaUpdateWrapper

@Test
public void test10() { //组装set子句
    LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>();
    updateWrapper
        .set(User::getAge, 18)
        .set(User::getEmail, "user@atguigu.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)、分页插件

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

情况1 ： 利用代码拼接的SQL

@Configuration
@MapperScan("com.atguigu.mybatisplus.mapper") //可以将主类中的注解移到此处 public class MybatisPlusConfig {
@Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new
PaginationInnerInterceptor(DbType.MYSQL));
        return interceptor;
} }

测试

@Test
public void testPage(){ 
//设置分页参数
Page page = new Page<>(1, 5); 
userMapper.selectPage(page, null);
//获取分页数据
  List 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());
}

---

情况2、 xml自定义写的分页SQL

Page selectPageVo(@Param("page") Page page, @Param("age") Integer age);

id,username,age,email


    SELECT  FROM t_user WHERe age > #
{age}

 
测试
 
@Test
public void testSelectPageVo(){ //设置分页参数
Page page = new Page<>(1, 5); userMapper.selectPageVo(page, 20);
//获取分页数据
List 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());
}
 
 
2)、乐观锁 
场景
 
 
 
一件商品，成本价是80元，售价是100元。
老板先是通知小李，说你去把商品价格增加50元。小 李正在玩游戏，耽搁了一个小时。正好一个小时后，老板觉得商品价格增加到150元，价格太 高，可能会影响销量。又通知小王，你把商品价格降低30元。
此时，小李和小王同时操作商品后台系统。小李操作的时候，系统先取出商品价格100元;小王 也在操作，取出的商品价格也是100元。小李将价格加了50元，并将100+50=150元存入了数据 库;小王将商品减了30元，并将100-30=70元存入了数据库。是的，如果没有锁，小李的操作就 完全被小王的覆盖了。
现在商品价格是70元，比成本价低10元。几分钟后，这个商品很快出售了1千多件商品，老板亏1 万多。
 
 
 
乐观锁与悲观锁
 
 
 
1、上面的故事，如果是乐观锁，小王保存价格前，会检查下价格是否被人修改过了。如果被修改过 了，则重新取出的被修改后的价格，150元，这样他会将120元存入数据库。
 2、如果是悲观锁，小李取出数据后，小王只能等小李操作完之后，才能对价格进行操作，也会保证 最终的价格是120元。
 
 
 
模拟修改冲突
 
创建表
 
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);
 
创建实体类
 
package com.atguigu.mybatisplus.entity;
import lombok.Data;
@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;
    private Integer version;
}
 
添加mapper
 
public interface ProductMapper extends BaseMapper {
}
 
问题复现测试
 
@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());
}
 
 
常规的乐观锁实现流程
 
数据库中添加version字段
 取出记录时，获取当前version
 
SELECT id,`name`,price,`version` FROM product WHERe id=1
 
更新时，version + 1，如果where语句中的version版本不对，则更新失败
 
UPDATE product SET price=price+50, `version`=`version` + 1 WHERe id=1 AND
`version`=1`
 
 
Mybatis-Plus实现乐观锁
 
 
 
myabties-plus为我们提供了 @Version 注解， 他可以在我们进行CRUD的时候，进行对version的判断
 
 
修改实体类
 
package com.atguigu.mybatisplus.entity;
import com.baomidou.mybatisplus.annotation.Version;
import lombok.Data;
@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;
    @Version
    private Integer version;
}
 
添加乐观锁插件配置
 
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){ MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); //添加分页插件
interceptor.addInnerInterceptor(new
PaginationInnerInterceptor(DbType.MYSQL)); //添加乐观锁插件
    interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
    return interceptor;
}
 
优化流程
 
 
 
当我们添加了乐观锁之后，虽然最后修改没有发生冲突，但是小王的更新操作并没有成功的，此时我们重新获取版本，进行判断，然后再去更新。
 
 
@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);
	}
	System.out.println("小王修改重试的结果:" + result2);
	//老板看价格
	Product p3 = productMapper.selectById(1L); 
	System.out.println("老板看价格:" + p3.getPrice());
	}
 
2)、创建通用枚举类型 
如果直接使用java的枚举，作为参数，执行db的操作，此时也会把枚举的key作为参数传递进去。
 
 解决方案
 
 
 
添加@EnumValue注解，他的作用是将注解所标识的值，存储到数据库中
 
 
package com.atguigu.mp.enums;
import com.baomidou.mybatisplus.annotation.EnumValue;
import lombok.Getter;
@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;
} }
 
配置扫描通用枚举
 
mybatis-plus:
  configuration:
# 配置MyBatis日志
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  global-config:
db-config:
# 配置MyBatis-Plus操作表的默认前缀 table-prefix: t_
# 配置MyBatis-Plus的主键策略 id-type: auto
# 配置扫描通用枚举
type-enums-package: com.atguigu.mybatisplus.enums
 
测试
 
@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);
}
 
六、代码生成器 
 
 
他可以生成dao，Controller，service 基本代码
 
 
1、引入依赖
 

    com.baomidou
    mybatis-plus-generator
    3.5.1


    org.freemarker
    freemarker
    2.3.31

 
2、快速生成
 
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", "123456")
             //↓↓↓↓↓↓↓↓↓↓↓↓下面的是全局配置↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓
            .globalConfig(builder -> {
				builder.author("atguigu") // 设置作者
				.enableSwagger() // 开启 swagger 模式 
				.fileOverride() // 覆盖已生成文件 
				.outputDir("D://mybatis_plus"); // 指定输出目录
                })
            //↓↓↓↓↓↓↓↓↓↓↓↓下面的是包名的配置↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓
           .packageConfig(builder -> {
				 builder.parent("com.atguigu") // 设置父包名 
				.moduleName("mybatisplus") // 设置父包模块名
				.pathInfo(Collections.singletonMap(OutputFile.mapperXml, "D://mybatis_plus")); // 设置mapperXml生成路径
                })
            //↓↓↓↓↓↓↓↓↓↓↓↓下面的是策略的配置↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓
          .strategyConfig(builder -> {
				 builder.addInclude("t_user") // 设置需要生成的表名
				.addTablePrefix("t_", "c_"); // 设置过滤表前缀 })
				.templateEngine(new FreemarkerTemplateEngine()) // 使用Freemarker 引擎模板，默认的是Velocity引擎模板
   } 
}
 
七、多数据源 
1、背景
 
 
 
适用于多种场景: 纯粹多库、 读写分离、 一主多从、 混合模式等 目前我们就来模拟一个纯粹多库的一个场景，其他场景类似 场景说明:
 我们创建两个库，分别为:mybatis_plus(以前的库不动)与mybatis_plus_1(新建)，将 mybatis_plus库的product表移动到mybatis_plus_1库，这样每个库一张表，通过一个测试用例 分别获取用户数据与商品数据，如果获取到说明多库模拟成功
 
 
2、创建数据库及表
 
 
 
创建数据库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)
);

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

##删除mybatis_plus库product表
use mybatis_plus;
DROP TABLE IF EXISTS product;


 
3、引入依赖
 

    com.baomidou
    dynamic-datasource-spring-boot-starter
    3.5.0

 
4、配置多数据源
 
 
 
说明:注释掉之前的数据库连接，添加新配置
 
 
spring:
# 配置数据源信息 datasource:
dynamic:
# 设置默认的数据源或者数据源组,默认值即为master
primary: master
# 严格匹配数据源,默认false.true未匹配到指定数据源时抛异常,false使用默认数据源 strict: false
datasource:
        master:
          url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-
8&useSSL=false
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: 123456
        slave_1:
          url: jdbc:mysql://localhost:3306/mybatis_plus_1?characterEncoding=utf-
8&useSSL=false
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: 123456
 
5、创建用户service
 
public interface UserService extends IService {
}
 
@DS("master") //指定所操作的数据源
@Service
public class UserServiceImpl extends ServiceImpl implements UserService {
}
 
6、创建商品service
 
public interface ProductService extends IService {
}
 
@DS("slave_1")
@Service
public class ProductServiceImpl extends ServiceImpl
implements ProductService {
}
 
7、测试
 
@Autowired
private UserService userService;
@Autowired
private ProductService productService;
@Test
public void testDynamicDataSource(){
    System.out.println(userService.getById(1L));
    System.out.println(productService.getById(1L));
}
 
总结
 
都能顺利获取对象，则测试成功
如果我们实现读写分离，将写操作方法加上主库数据源，读操作方法加上从库数据源，自动切 换，是不是就能实现读写分离?
 
 
八、MyabtiesX插件 
 
 
MyBatis-Plus为我们提供了强大的mapper和service模板，能够大大的提高开发效率
 但是在真正开发过程中，MyBatis-Plus并不能为我们解决所有问题，例如一些复杂的SQL，多表 联查，我们就需要自己去编写代码和SQL语句，我们该如何快速的解决这个问题呢，这个时候可 以使用MyBatisX插件
 MyBatisX一款基于 IDEA 的快速开发插件，为效率而生。
 
 
这个推荐看网关，还有GIF 动图演示， 赞！
 MyBatisX插件用法:https://baomidou.com/pages/ba5b24/



转载请注明：文章转载自 www.mshxw.com
本文地址：https://www.mshxw.com/it/880730.html


   上一篇  @DeleteMapping、@PutMapping等Rest风格在SpringBoot项目中出错的解决方案
 
   下一篇  中级职称软考设计师笔记之【数据结构及算法应用】
  






Java相关栏目本月热门文章

  
1【Linux驱动开发】设备树详解（二）设备树语法详解
  
2别跟客户扯细节
  
3Springboot+RabbitMQ+ACK机制(生产方确认(全局、局部)、消费方确认)、知识盲区
  
4【Java】对象处理流（ObjectOutputStream和ObjectInputStream）
  
5【分页】常见两种SpringBoot项目中分页技巧
  
6一文带你搞懂OAuth2.0
  
7我要写整个中文互联网界最牛逼的JVM系列教程 | 「JVM与Java体系架构」章节：虚拟机与Java虚拟机介绍
  
8【Spring Cloud】新闻头条微服务项目：FreeMarker模板引擎实现文章静态页面生成
  
9JavaSE - 封装、static成员和内部类
  
10树莓派mjpg-streamer实现监控及拍照功能调试
  
11用c++写一个蓝屏代码
  
12从JDK8源码中看ArrayList和LinkedList的区别
  
13idea 1、报错java: 找不到符号 符号: 变量 log 2、转换成Maven项目
  
14在openwrt使用C语言增加ubus接口（包含C uci操作）
  
15Spring 解决循环依赖
  
16SpringMVC——基于MVC架构的Spring框架
  
17Andy‘s First Dictionary C++ STL set应用
  
18动态内存管理
  
19我的创作纪念日
  
20Docker自定义镜像-Dockerfile







热门相关搜索



路由器设置
木托盘
宝塔面板
儿童python教程
心情低落
朋友圈
vim
双一流学科
专升本
我的学校
日记学校
西点培训学校
汽修学校
情书
化妆学校
塔沟武校
异形模板
西南大学排名
最精辟人生短句
6步教你追回被骗的钱
南昌大学排名
清朝十二帝
北京印刷学院排名
北方工业大学排名
北京航空航天大学排名
首都经济贸易大学排名
中国传媒大学排名
首都师范大学排名
中国地质大学(北京)排名
北京信息科技大学排名
中央民族大学排名
北京舞蹈学院排名
北京电影学院排名
中国戏曲学院排名
河北政法职业学院排名
河北经贸大学排名
天津中德应用技术大学排名
天津医学高等专科学校排名
天津美术学院排名
天津音乐学院排名
天津工业大学排名
北京工业大学耿丹学院排名
北京警察学院排名
天津科技大学排名
北京邮电大学(宏福校区)排名
北京网络职业学院排名
北京大学医学部排名
河北科技大学排名
河北地质大学排名
河北体育学院排名







学习工具
代数计算器
三角函数
解析几何
立体几何


知识解答
教育知识
百科知识
生活知识
常识知识


写作必备
作文大全
作文素材
句子大全

实用范文


关于我们
关于我们
联系我们
网站地图


 
名师互学网交流群


名师互学网客服





名师互学网 版权所有 (c)2021-2022      ICP备案号：晋ICP备2021003244-6号
 






关于我们
文章归档
网站地图
联系我们
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号：晋ICP备2021003244-6号