MyBatis-Plus

時間 2019-11-22

標籤 mybatis 欄目 MyBatis 简体版

原文原文鏈接

簡介

是什麼

參考教程：http://mp.baomidou.com/guide/html

MyBatis-Plus（簡稱 MP）是一個 MyBatis 的加強工具，在 MyBatis 的基礎上只作加強不作改變，爲簡化開發、提升效率而生。java

特性

無侵入：只作加強不作改變，引入它不會對現有工程產生影響，如絲般順滑
損耗小：啓動即會自動注入基本 CURD，性能基本無損耗，直接面向對象操做
強大的 CRUD 操做：內置通用 Mapper、通用 Service，僅僅經過少許配置便可實現單表大部分 CRUD 操做，更有強大的條件構造器，知足各種使用需求
支持 Lambda 形式調用：經過 Lambda 表達式，方便的編寫各種查詢條件，無需再擔憂字段寫錯
支持多種數據庫：支持 MySQL、MariaDB、Oracle、DB二、H二、HSQL、SQLite、Postgre、SQLServer200五、SQLServer 等多種數據庫
支持主鍵自動生成：支持多達 4 種主鍵策略（內含分佈式惟一 ID 生成器 - Sequence），可自由配置，完美解決主鍵問題
支持 XML 熱加載：Mapper 對應的 XML 支持熱加載，對於簡單的 CRUD 操做，甚至能夠無 XML 啓動
支持 ActiveRecord 模式：支持 ActiveRecord 形式調用，實體類只需繼承 Model 類便可進行強大的 CRUD 操做
支持自定義全局通用操做：支持全局通用方法注入（ Write once, use anywhere ）
支持關鍵詞自動轉義：支持數據庫關鍵詞（order、key......）自動轉義，還可自定義關鍵詞
內置代碼生成器：採用代碼或者 Maven 插件可快速生成 Mapper 、 Model 、 Service 、 Controller 層代碼，支持模板引擎，更有超多自定義配置等您來使用
內置分頁插件：基於 MyBatis 物理分頁，開發者無需關心具體操做，配置好插件以後，寫分頁等同於普通 List 查詢
內置性能分析插件：可輸出 Sql 語句以及其執行時間，建議開發測試時啓用該功能，能快速揪出慢查詢
內置全局攔截插件：提供全表 delete 、 update 操做智能分析阻斷，也可自定義攔截規則，預防誤操做
內置 Sql 注入剝離器：支持 Sql 注入剝離，有效預防 Sql 注入攻擊

入門

建立數據庫

mybatis_plus，注意字符集選擇utf8mb4mysql

建立user表

DROP TABLE IF EXISTS user;

CREATE TABLE user
(
    id BIGINT(20) NOT NULL 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)
);
DELETE FROM user;

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');複製代碼

初始化工程

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

Group：com.atguigugithub

Artifact：mybatis_plus算法

版本：2.0.7.RELEASEspring

這裏都不勾選，後面直接把依賴引入進來，點擊nextsql

點擊finish數據庫

添加依賴

spring-boot-starter、spring-boot-starter-test添加：mybatis-plus-boot-starter、MySQL、lombok、在項目中使用Lombok能夠減小不少重複代碼的書寫。好比說getter/setter/toString等方法的編寫apache

注意：引入 MyBatis-Plus 以後請不要再次引入 MyBatis 以及 MyBatis-Spring，以免因版本差別致使的問題。

修改前

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.atguigu</groupId>
    <artifactId>mybatis_plus</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>mybatis_plus</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </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>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>
複製代碼

修改後

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.7.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.atguigu</groupId>
    <artifactId>mybatis_plus</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>mybatis_plus</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--mybatis-plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.0.5</version>
        </dependency>

        <!--mysql-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

        <!--lombok用來簡化實體類-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>
複製代碼

idea中安裝lombok插件

配置

在 application.properties 配置文件中添加 MySQL 數據庫的相關配置：

本機的mysql版本：mysql5

#mysql數據庫鏈接
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://192.168.1.103:3306/mybatis_plus?useSSL=false
spring.datasource.username=root
spring.datasource.password=000000複製代碼

mysql8以上（spring boot 2.1）

注意：driver和url的變化

spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://192.168.1.103:3306/mybatis_plus?serverTimezone=GMT%2B8
spring.datasource.username=root
spring.datasource.password=000000複製代碼

注意：

一、這裏的 url 使用了 ?serverTimezone=GMT%2B8 後綴，由於Spring Boot 2.1 集成了 8.0版本的jdbc驅動，這個版本的 jdbc 驅動須要添加這個後綴，不然運行測試用例報告以下錯誤：

java.sql.SQLException: The server time zone value 'ÖÐ¹ú±ê×¼Ê±¼ä' is unrecognized or represents more

二、這裏的 driver-class-name 使用了 com.mysql.cj.jdbc.Driver ，在 jdbc 8 中建議使用這個驅動，以前的 com.mysql.jdbc.Driver 已經被廢棄，不然運行測試用例的時候會有 WARN 信息

編寫代碼

修改啓動類

@MapperScan("com.atguigu.mybatis_plus.mapper")配置掃描mapper

package com.atguigu.mybatis_plus;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan("com.atguigu.mybatis_plus.mapper")
public class MybatisPlusApplication {

    public static void main(String[] args) {
        SpringApplication.run(MybatisPlusApplication.class, args);
    }

}
複製代碼

編寫實體

建立包 entity 編寫實體類 User.java（此處使用了 Lombok 簡化代碼）

package com.atguigu.mybatis_plus.entity;

import lombok.Data;
@Data
public class User {
    private Long id;
    private String name;
    private Integer age;
    private String email;
    
}
複製代碼

由於使用了lombok註解，自動生成了get和set方法

Lombok使用參考

編寫mapper

建立包 mapper 編寫Mapper 接口： UserMapper.java

package com.atguigu.mybatis_plus.mapper;

import com.atguigu.mybatis_plus.entity.User;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;

public interface UserMapper  extends BaseMapper<User> {
}
複製代碼

編寫測試類

package com.atguigu.mybatis_plus;

import com.atguigu.mybatis_plus.entity.User;
import com.atguigu.mybatis_plus.mapper.UserMapper;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;

@SpringBootTest
@RunWith(SpringRunner.class)
class MybatisPlusApplicationTests {
    @Autowired
    private UserMapper userMapper;

    @Test
    public void testSelectList() {
        System.out.println(("----- selectAll method test ------"));
        //UserMapper 中的 selectList() 方法的參數爲 MP 內置的條件封裝器 Wrapper
        //因此不填寫就是無任何條件
        List<User> users = userMapper.selectList(null);
        users.forEach(System.out::println);
    }

}

複製代碼

注意：

IDEA在 userMapper 處報錯，由於找不到注入的對象，由於類是動態建立的，可是程序能夠正確的執行。

爲了不報錯，能夠在 dao 層的接口上添加 @Repository 註解

輸出

配置SQL日誌輸出

修改application.properties

#mysql數據庫鏈接
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://192.168.1.103:3306/mybatis_plus?useSSL=false
spring.datasource.username=root
spring.datasource.password=000000

#mybatis日誌
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
複製代碼

再次查看輸出

CRUD接口

增

package com.atguigu.mybatis_plus;

import com.atguigu.mybatis_plus.entity.User;
import com.atguigu.mybatis_plus.mapper.UserMapper;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class CRUDTests {

    @Autowired
    private UserMapper userMapper;

    @Test
    public void testInsert(){

        User user = new User();
        user.setName("Helen");
        user.setAge(18);
        user.setEmail("55317332@qq.com");

        int result = userMapper.insert(user);
        //影響的行數
        System.out.println(result);
        //id自動會填
        System.out.println(user);
    }
}

複製代碼

注意：數據庫插入id值默認爲：全局惟一id，這裏的id是經過雪花算法生成的19位

主鍵策略

ID_WORKER

MyBatis-Plus默認的主鍵策略是：ID_WORKER 全局惟一ID

參考資料：分佈式系統惟一ID生成方案彙總

自增策略

要想主鍵自增須要配置以下主鍵策略，須要在建立數據表的時候設置主鍵自增，同時在實體字段中配置@TableId(type = IdType.AUTO)

若是要想影響全部實體的配置，能夠設置全局主鍵配置，修改配置文件application.properties，追加

#全局設置主鍵生成策略
mybatis-plus.global-config.db-config.id-type=auto
複製代碼

其它主鍵策略：分析 IdType 源碼可知

@Getter
public enum IdType {
    /**
     * 數據庫ID自增
     */
    AUTO(0),
    /**
     * 該類型爲未設置主鍵類型
     */
    NONE(1),
    /**
     * 用戶輸入ID
     * 該類型能夠經過本身註冊自動填充插件進行填充
     */
    INPUT(2),

    /* 如下3種類型、只有當插入對象ID 爲空，才自動填充。 */
    /**
     * 全局惟一ID (idWorker)
     */
    ID_WORKER(3),
    /**
     * 全局惟一ID (UUID)
     */
    UUID(4),
    /**
     * 字符串全局惟一ID (idWorker 的字符串表示)
     */
    ID_WORKER_STR(5);

    private int key;

    IdType(int key) {
        this.key = key;
    }
}
複製代碼

刪

根據id刪除記錄

@Test
public void testDeleteById(){

    int result = userMapper.deleteById(8L);
    System.out.println(result);
}
複製代碼

批量刪除

@Test
public void testDeleteBatchIds() {

    int result = userMapper.deleteBatchIds(Arrays.asList(8, 9, 10));
    System.out.println(result);
}
複製代碼

簡單的條件查詢刪除

@Test
public void testDeleteByMap() {

    HashMap<String, Object> map = new HashMap<>();
    map.put("name", "Helen");
    map.put("age", 18);

    int result = userMapper.deleteByMap(map);
    System.out.println(result);
}
複製代碼

邏輯刪除

物理刪除：真實刪除，將對應數據從數據庫中刪除，以後查詢不到此條被刪除數據
邏輯刪除：假刪除，將對應數據中表明是否被刪除字段狀態修改成「被刪除狀態」，以後在數據庫中仍舊能看到此條數據記錄

數據庫中添加 deleted字段

也能夠採起業務層自動填充方案 @TableField(fill = FieldFill.INSERT) 註解

ALTER TABLE `user` ADD COLUMN `deleted` boolean DEFAULT 0
複製代碼

實體類添加deleted 字段

並加上 @TableLogic 註解

修改配置文件application.properties

追加

mybatis-plus.global-config.db-config.logic-delete-value=1
mybatis-plus.global-config.db-config.logic-not-delete-value=0
複製代碼

在 MybatisPlusConfig 中註冊 Bean

測試邏輯刪除

測試後發現，數據並無被刪除，deleted字段的值由0變成了1

測試後分析打印的sql語句，是一條update

注意：被刪除數據的deleted 字段的值必須是 0，才能被選取出來執行邏輯刪除的操做

/**
 * 測試 邏輯刪除
 */
@Test
public void testLogicDelete() {

    int result = userMapper.deleteById(1L);
    System.out.println(result);
}
複製代碼

刪除前

刪除後

控制檯

測試邏輯刪除後的查詢

MyBatis Plus中查詢操做也會自動添加邏輯刪除字段的判斷

/**
 * 測試 邏輯刪除後的查詢：
 * 不包括被邏輯刪除的記錄
 */
@Test
public void testLogicDeleteSelect() {
    User user = new User();
    List<User> users = userMapper.selectList(null);
    users.forEach(System.out::println);
}
複製代碼

控制檯

測試後分析打印的sql語句，包含 WHERE deleted=0

改

根據Id更新操做

注意：update時生成的sql自動是動態sql：UPDATE user SET age=? WHERE id=?

@Test
    public void testUpdateById(){

        User user = new User();
        user.setId(1L);
        user.setAge(28);

        int result = userMapper.updateById(user);
        System.out.println(result);

    }
複製代碼

自動填充

項目中常常會遇到一些數據，每次都使用相同的方式填充，例如記錄的建立時間，更新時間等。

咱們可使用MyBatis Plus的自動填充功能，完成這些字段的賦值工做：

數據庫表中添加自動填充字段

在User表中添加datetime類型的新的字段 create_time、update_time

自動填充方案1、數據級別的自動填充，分別設置默認值：

`create_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
複製代碼

自動填充方案2、業務層處理：

實體上增長字段並添加註解

編寫實現元對象處理器接口

注意：不要忘記添加 @Component 註解

package com.atguigu.mybatis_plus.handler;

import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;

import java.util.Date;

@Slf4j
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        log.info("start insert fill ....");
        this.setFieldValByName("createTime", new Date(), metaObject);
        this.setFieldValByName("updateTime", new Date(), metaObject);
    }

    @Override
    public void updateFill(MetaObject metaObject) {
        log.info("start update fill ....");
        this.setFieldValByName("updateTime", new Date(), metaObject);
    }
}

複製代碼

測試新增

@Test
    public void testInsert(){

        User user = new User();
        user.setName("Helen");
        user.setAge(18);
        user.setEmail("55317332@qq.com");

        int result = userMapper.insert(user);
        //影響的行數
        System.out.println(result);
        //id自動會填
        System.out.println(user);
    }
複製代碼

新增前

新增後

測試修改

@Test
    public void testUpdateById(){

        User user = new User();
        user.setId(1L);
        user.setAge(28);

        int result = userMapper.updateById(user);
        System.out.println(result);

    }
複製代碼

修改前

修改後

樂觀鎖

主要適用場景：當要更新一條記錄的時候，但願這條記錄沒有被別人更新，也就是說實現線程安全的數據更新

樂觀鎖實現方式：

取出記錄時，獲取當前version：假設取出的version=1

SELECT id,name,age,email,create_time,update_time,version FROM user WHERE id=1
複製代碼

更新時，帶上這個version

UPDATE USER SET `name`='helen yao', `version`=`version` + 1 WHERE id=1 AND `version`=1
複製代碼

執行更新時， set version = newVersion where version = oldVersion

若是version不對，就更新失敗

數據庫中添加version字段

ALTER TABLE `user` ADD COLUMN `version` INT DEFAULT 1
複製代碼

實體類添加version字段

並添加 @Version 註解

特別說明:

支持的數據類型只有 int,Integer,long,Long,Date,Timestamp,LocalDateTime

整數類型下 newVersion = oldVersion + 1，newVersion 會回寫到 entity 中僅支持 updateById(id) 與 update(entity, wrapper) 方法

在 update(entity, wrapper) 方法下, wrapper 不能複用!!!

編寫配置文件

建立包config，建立文件MybatisPlusConfig.java

此時能夠刪除主類中的 @MapperScan 掃描註解，並註冊bean

package com.atguigu.mybatis_plus.config;

import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;


@EnableTransactionManagement
@Configuration
public class MybatisPlusConfig {
    /**
     * 樂觀鎖插件
     */
    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor() {
        return new OptimisticLockerInterceptor();
    }
}

複製代碼

測試樂觀鎖

要先查詢出實體對象以得到更新前的版本號

/**
     * 測試 樂觀鎖插件
     */
    @Test
    public void testOptimisticLocker() {

        //查詢
        User user = userMapper.selectById(1L);
        //修改數據
        user.setName("Helen Yao");
        user.setEmail("helen@qq.com");
        //執行更新
        userMapper.updateById(user);
    }
複製代碼

更新前

更新後

查

根據id查詢記錄

@Test
public void testSelectById(){

    User user = userMapper.selectById(1L);
    System.out.println(user);
}
複製代碼

經過多個id批量查詢

完成了動態sql的foreach的功能

@Test
public void testSelectBatchIds(){

    List<User> users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3));
    users.forEach(System.out::println);
}
複製代碼

簡單的條件查詢

經過map封裝查詢條件

@Test
public void testSelectByMap(){

    HashMap<String, Object> map = new HashMap<>();
    map.put("name", "Helen");
    map.put("age", 18);
    List<User> users = userMapper.selectByMap(map);

    users.forEach(System.out::println);
}
複製代碼

注意：map中的key對應數據庫中的列名。如：數據庫user_id，實體類是userId，這時map的key須要填寫user_id

分頁查詢

MyBatis Plus自帶分頁插件，只要簡單的配置便可實現分頁功能

修改配置類

添加分頁插件

package com.atguigu.mybatis_plus.config;

import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;


@EnableTransactionManagement
@Configuration
public class MybatisPlusConfig {
    /**
     * 樂觀鎖插件
     */
    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor() {
        return new OptimisticLockerInterceptor();
    }
    /**
     * 分頁插件
     */
    @Bean
    public PaginationInterceptor paginationInterceptor() {
        return new PaginationInterceptor();
    }
}

複製代碼

測試分頁查詢

測試一

最終經過page對象獲取相關數據

@Test
public void testSelectPage() {

    Page<User> page = new Page<>(1,5);
    userMapper.selectPage(page, null);

    page.getRecords().forEach(System.out::println);
    System.out.println(page.getCurrent());
    System.out.println(page.getPages());
    System.out.println(page.getSize());
    System.out.println(page.getTotal());
    System.out.println(page.hasNext());
    System.out.println(page.hasPrevious());
}
複製代碼

控制檯

測試二

@Test
public void testSelectMapsPage() {

    Page<User> page = new Page<>(1, 5);

    IPage<Map<String, Object>> mapIPage = userMapper.selectMapsPage(page, null);

    //注意：此行必須使用 mapIPage 獲取記錄列表，不然會有數據類型轉換錯誤
    mapIPage.getRecords().forEach(System.out::println);
    System.out.println(page.getCurrent());
    System.out.println(page.getPages());
    System.out.println(page.getSize());
    System.out.println(page.getTotal());
    System.out.println(page.hasNext());
    System.out.println(page.hasPrevious());
}
複製代碼

控制檯

條件構造器

wapper介紹

Wrapper ：條件構造抽象類，最頂端父類
- AbstractWrapper ：用於查詢條件封裝，生成 sql 的 where 條件
  - QueryWrapper ： Entity 對象封裝操做類，不是用lambda語法
  - UpdateWrapper ： Update 條件封裝，用於Entity對象更新操做
  - AbstractLambdaWrapper ： Lambda 語法使用 Wrapper統一處理解析 lambda 獲取 column。
    - LambdaQueryWrapper ：看名稱也能明白就是用於Lambda語法使用的查詢Wrapper
    - LambdaUpdateWrapper ： Lambda 更新封裝Wrapper

編寫QueryWrapperTests類

package com.atguigu.mybatis_plus;

import com.atguigu.mybatis_plus.mapper.UserMapper;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class QueryWrapperTests {
    @Autowired
    private UserMapper userMapper;
}

複製代碼

測試

注意：如下條件構造器的方法入參中的 column 均表示數據庫字段

ge、gt、le、lt、isNull、isNotNull

@Test
public void testDelete() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper
        .isNull("name")
        .ge("age", 12)
        .isNotNull("email");
    int result = userMapper.delete(queryWrapper);
    System.out.println("delete return count = " + result);
}
複製代碼

控制檯

eq、ne

注意：seletOne返回的是一條實體記錄，當出現多條時會報錯

@Test
public void testSelectOne() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.eq("name", "Tom");

    User user = userMapper.selectOne(queryWrapper);
    System.out.println(user);
}
複製代碼

控制檯

between、notBetween

包含大小邊界

@Test
public void testSelectCount() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.between("age", 20, 30);

    Integer count = userMapper.selectCount(queryWrapper);
    System.out.println(count);
}
複製代碼

控制檯

allEq

@Test
public void testSelectList() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    Map<String, Object> map = new HashMap<>();
    map.put("id", 2);
    map.put("name", "Jack");
    map.put("age", 20);

    queryWrapper.allEq(map);
    List<User> users = userMapper.selectList(queryWrapper);

    users.forEach(System.out::println);
}
複製代碼

控制檯

like、notLike、likeLeft、likeRight

selectMaps返回Map集合列表

@Test
public void testSelectMaps() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper
        .notLike("name", "e")
        .likeRight("email", "t");

    List<Map<String, Object>> maps = userMapper.selectMaps(queryWrapper);//返回值是Map列表
    maps.forEach(System.out::println);
}
複製代碼

控制檯

in、notIn、inSql、notinSql、exists、notExists

@Test
public void testSelectObjs() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    //queryWrapper.in("id", 1, 2, 3);
    queryWrapper.inSql("id", "select id from user where id < 3");

    List<Object> objects = userMapper.selectObjs(queryWrapper);//返回值是Object列表
    objects.forEach(System.out::println);
}
複製代碼

控制檯

or、and

注意：這裏使用的是 UpdateWrapper

不調用or則默認爲使用 and 連

@Test
public void testUpdate1() {

    //修改值
    User user = new User();
    user.setAge(99);
    user.setName("Andy");

    //修改條件
    UpdateWrapper<User> userUpdateWrapper = new UpdateWrapper<>();
    userUpdateWrapper
        .like("name", "h")
        .or()
        .between("age", 20, 30);

    int result = userMapper.update(user, userUpdateWrapper);

    System.out.println(result);
}
複製代碼

控制檯

嵌套or、嵌套and

這裏使用了lambda表達式，or中的表達式最後翻譯成sql時會被加上圓括號

@Test
public void testUpdate2() {


    //修改值
    User user = new User();
    user.setAge(99);
    user.setName("Andy");

    //修改條件
    UpdateWrapper<User> userUpdateWrapper = new UpdateWrapper<>();
    userUpdateWrapper
        .like("name", "h")
        .or(i -> i.eq("name", "李白").ne("age", 20));

    int result = userMapper.update(user, userUpdateWrapper);

    System.out.println(result);
}
複製代碼

控制檯

orderBy、orderByDesc、orderByAsc

@Test
public void testSelectListOrderBy() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.orderByDesc("id");

    List<User> users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
}
複製代碼

控制檯

last

直接拼接到 sql 的最後

注意：只能調用一次,屢次調用以最後一次爲準有sql注入的風險,請謹慎使用

@Test
public void testSelectListLast() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.last("limit 1");

    List<User> users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
}
複製代碼

控制檯

指定要查詢的列

@Test
public void testSelectListColumn() {

    QueryWrapper<User> queryWrapper = new QueryWrapper<>();
    queryWrapper.select("id", "name", "age");

    List<User> users = userMapper.selectList(queryWrapper);
    users.forEach(System.out::println);
}
複製代碼

控制檯

set、setSql

最終的sql會合並 user.setAge()，以及 userUpdateWrapper.set() 和 setSql() 中的字段

@Test
public void testUpdateSet() {

    //修改值
    User user = new User();
    user.setAge(99);

    //修改條件
    UpdateWrapper<User> userUpdateWrapper = new UpdateWrapper<>();
    userUpdateWrapper
        .like("name", "h")
        .set("name", "老李頭")//除了能夠查詢還可使用set設置修改的字段
        .setSql(" email = '123@qq.com'");//能夠有子查詢

    int result = userMapper.update(user, userUpdateWrapper);
}
複製代碼

控制檯

性能分析

性能分析攔截器，用於輸出每條 SQL 語句及其執行時間

SQL 性能執行分析,開發環境使用，超過指定時間，中止運行。有助於發現問題

配置插件

參數說明

參數：maxTime： SQL 執行最大時長，超過自動中止運行，有助於發現問題。

參數：format： SQL是否格式化，默認false。

修改配置

修改MybatisPlusConfig.java

/**
     * SQL 執行性能分析插件
     * 開發環境使用，線上不推薦。 maxTime 指的是 sql 最大執行時長
     */
    @Bean
    // 設置 dev test 環境開啓    
    @Profile({"dev","test"})
    public PerformanceInterceptor performanceInterceptor() {
        PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
        performanceInterceptor.setMaxTime(100);//ms，超過此處設置的ms則sql不執行
        performanceInterceptor.setFormat(true);
        return performanceInterceptor;
    }
複製代碼

Spring Boot 中設置dev環境

複製application.properties配置文件，分別爲開發、生產、測試環境的配置文件

能夠針對各環境新建不一樣的配置文件application-dev.properties、application-test.properties、application-prod.properties

也能夠自定義環境名稱：如test1、test2

測試

測試一

/**
 * 測試 性能分析插件
 */
@Test
public void testPerformance() {
    User user = new User();
    user.setName("我是Helen");
    user.setEmail("helen@sina.com");
    user.setAge(18);
    userMapper.insert(user);
}
複製代碼

控制檯