mybatisplus、三種操作數據庫及批量操作


mybatis-plus

簡介

  • 無侵入:只做增強不做改變,引入它不會對現有工程產生影響,如絲般順滑
  • 損耗小:啟動即會自動注入基本 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 注入攻擊

使用

1.創建空的boot項目,什么都不選,導入mybatisplus依賴

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

2.啟動類上記得加上@MapperScan注解,掃描mapper接口

@SpringBootApplication
@MapperScan("com.liqiliang.mybatisplusdemo.mapper")
public class MybatisplusDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(MybatisplusDemoApplication.class, args);
        System.err.println("MybatisplusDemoApplication啟動完成!!");
    }

}

3.創建mapper,實體等其他文件夾

4.創建mapper接口,並繼承通用mapper baseMapper,泛型寫實體

即一個mapper對應一個實體,對應一張數據表

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.liqiliang.mybatisplusdemo.entity.User;

public interface UserMapper extends BaseMapper<User> {
    
}

mapper接口有了,有三種方式可以對數據庫進行操作

1.注解(mapper接口要能被mybatis框架掃描到,@MapperScan注解)

2.mapper.xml(建立mapper接口和mapper.xml的映射關系,mybatis-plus.type-aliases-package配置)

3.通用mapper api(實現通用mapper接口)

代碼如下

mapper接口

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.liqiliang.mybatisplusdemo.entity.User;
import org.apache.ibatis.annotations.Select;

import java.util.List;

public interface UserMapper extends BaseMapper<User> {

    @Select("select * from user")
    List<User> findAll();

    List<User> selectAll();
    
}

mapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper namespace="com.liqiliang.mybatisplusdemo.mapper.UserMapper">
    <select id="selectAll" resultType="com.liqiliang.mybatisplusdemo.entity.User">
        select * from user
    </select>
</mapper>

boot配置文件

# 應用名稱
spring.application.name=mybatisplus_demo
#mysql數據庫連接
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://192.168.180.170:3306/mybatis_plus?useSSL=false
spring.datasource.username=root
spring.datasource.password=root
# 別名掃描
mybatis-plus.type-aliases-package=com.liqiliang.mybatisplusdemo.entity
# mapper的xml文件地址
mybatis-plus.mapper-locations=classpath*:mappers/*.xml

測試類

import com.liqiliang.mybatisplusdemo.entity.User;
import com.liqiliang.mybatisplusdemo.mapper.UserMapper;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

@SpringBootTest
class MybatisplusDemoApplicationTests {

    @Autowired
    private UserMapper userMapper;

    @Test
    void selectTest() {

        //注解開發
        List<User> list = userMapper.findAll();
        list.forEach(System.err::println);

        //寫mapper.xml
        List<User> list1 = userMapper.selectAll();
        list1.forEach(System.err::println);

        //使用mybatisplus api
        List<User> list2 = userMapper.selectList(null);
        list2.forEach(System.err::println);
    }

}

完成!

tips:

mapper接口和mapper xml之間來回切換的插件是

free Mybatis Plugin

mybatis批量操作

package com.liqiliang.mybatisplusdemo;

import com.liqiliang.mybatisplusdemo.entity.User;
import com.liqiliang.mybatisplusdemo.mapper.UserMapper;
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.SqlSession;
import org.junit.jupiter.api.Test;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.SqlSessionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

@SpringBootTest
class MybatisplusDemoApplicationTests {

    @Autowired
    private UserMapper userMapper;

    @Autowired
    private SqlSessionTemplate sqlSessionTemplate;


    @Test
    void selectTest() {

        //注解開發
        List<User> list = userMapper.findAll();
        list.forEach(System.err::println);

        //寫mapper.xml
        List<User> list1 = userMapper.selectAll();
        list1.forEach(System.err::println);

        //使用mybatisplus api
        List<User> list2 = userMapper.selectList(null);
        list2.forEach(System.err::println);
    }

    /**
     * 常規方法,一條一條新增1w條記錄
     */
    @Test
    void insert() {

        long start = System.currentTimeMillis();
        for (long i = 0; i < 10000; i++) {
            userMapper.insert(new User(i, "a", 18, "666"));
        }
        long end = System.currentTimeMillis();
        System.out.println("總耗時======="+(end-start));//16840
    }

    /**
     * 批量新增,使用mybatis自帶的批量操作,預編譯
     */
    @Test
    void insertBatchDemo() {
        SqlSession sqlSession = SqlSessionUtils.getSqlSession(
                sqlSessionTemplate.getSqlSessionFactory(),
                ExecutorType.BATCH,sqlSessionTemplate.getPersistenceExceptionTranslator());

        UserMapper mapper = sqlSession.getMapper(UserMapper.class);

        long start = System.currentTimeMillis();
        for (long i = 0; i < 10000; i++) {
            mapper.insert(new User(i, "a", 18, "666"));
        }
        sqlSession.commit();
        sqlSession.close();
        long end = System.currentTimeMillis();
        System.out.println("總耗時======="+(end-start));//8390
    }
}

可見效率的差異,並且通過查看控制台sql打印的結果,可以看出區別


免責聲明!

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



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM