碼上歡樂
相關內容    簡體    繁體

MyBatis-Plus

本文轉載自   查看原文   2019-11-02 14:10   363 

簡介

是什么

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

MyBatis-Plus（簡稱 MP）是一個 MyBatis 的增強工具，在 MyBatis 的基礎上只做增強不做改變，為簡化開發、提高效率而生。

特性

  • 無侵入：只做增強不做改變，引入它不會對現有工程產生影響，如絲般順滑
  • 損耗小：啟動即會自動注入基本 CURD，性能基本無損耗，直接面向對象操作
  • 強大的 CRUD 操作：內置通用 Mapper、通用 Service，僅僅通過少量配置即可實現單表大部分 CRUD 操作，更有強大的條件構造器，滿足各類使用需求
  • 支持 Lambda 形式調用：通過 Lambda 表達式，方便的編寫各類查詢條件，無需再擔心字段寫錯
  • 支持多種數據庫：支持 MySQL、MariaDB、Oracle、DB2、H2、HSQL、SQLite、Postgre、SQLServer2005、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，注意字符集選擇utf8mb4

1572598283299

創建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工程

Group：com.atguigu

Artifact：mybatis_plus

版本：2.0.7.RELEASE

1572598581226

1572598625584

這里都不勾選，后面直接把依賴引入進來，點擊next

1572598649523

點擊finish

1572598697690

添加依賴

spring-boot-starter、spring-boot-starter-test
添加：mybatis-plus-boot-starter、MySQL、lombok、
在項目中使用Lombok可以減少很多重復代碼的書寫。比如說getter/setter/toString等方法的編寫

注意：引入 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插件

1572599360194

配置

在 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

注意：

1、這里的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

2、這里的 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使用參考

1572599994758

編寫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 注解

1572600372305

輸出

1572600565552

配置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

再次查看輸出

1572600695487

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位

1572616235895

主鍵策略

ID_WORKER

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

參考資料：分布式系統唯一ID生成方案匯總

自增策略

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

1572617733126

1572617700925

如果要想影響所有實體的配置，可以設置全局主鍵配置，修改配置文件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 注解

1572623263813

修改配置文件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

1572623576357

測試邏輯刪除

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

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

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

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

    int result = userMapper.deleteById(1L);
    System.out.println(result);
}

刪除前

1572623769652

刪除后

1572623800852

控制台

1572623844815

測試邏輯刪除后的查詢

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

1572623997959

改

根據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

1572618251284

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

`create_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,

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

實體上增加字段並添加注解

1572618688671

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

注意：不要忘記添加 @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);
    }

新增前

1572619036544

新增后

1572620042633

測試修改

@Test
    public void testUpdateById(){

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

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

    }

修改前

1572618897008

修改后

1572618962760

樂觀鎖

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

樂觀鎖實現方式：

取出記錄時，獲取當前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 注解

1572620796994

特別說明:

支持的數據類型只有 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);
    }

更新前

1572621566816

更新后

1572621594393

查

根據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());
}

控制台

1572622699346

測試二

@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());
}

控制台

1572622957357

條件構造器

wapper介紹

1572659063025

  • 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);
}

控制台

1572659974850

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);
}

控制台

1572660310438

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);
}

控制台

1572660417253

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);
}

控制台

1572660484305

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);
}

控制台

1572660590700

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);
}

控制台

1572660648362

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);
}

控制台

1572662700937

嵌套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);
}

控制台

1572662819824

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);
}

控制台

1572662935710

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);
}

控制台

1572663018323

指定要查詢的列

@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);
}

控制台

1572663090708

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);
}

控制台

1572663190264

性能分析

性能分析攔截器，用於輸出每條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

1572624531911

1572624551619

測試

測試一

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

控制台

1572624763492

測試二

將maxTime 改小為5毫秒之后再次進行測試

1572624869219

控制台

執行時間如果超過5毫秒則會報錯，讓你優化

1572625037752

本文由博客一文多發平台 OpenWrite 發布！


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 Mybatis-plus的使用 Mybatis-Plus的使用 MyBatis-Plus使用 mybatis-plus - buildSqlSessionFactory() mybatis-plus - 初識 mybatis-plus - MybatisPlusAutoConfiguration Mybatis-plus基本用法 MyBatis與Mybatis-plus的區別 springboot - logback & mybatis-plus Mybatis-Plus 分頁插件
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM