springboot + Mybatisplus多數據源 分頁


 

轉:

springboot簡易集成mybatisPlus+多數據源

 

【我好用的配置文件

1、pom:【注意druid吧版本要能獲取到jar

<?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.3.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>demo</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <mysql.version>6.0.6</mysql.version>
        <mybatisplus.boot.version>3.1.0</mybatisplus.boot.version>
        <druid.version>1.1.22</druid.version>
        <dynamic.datasource.boot.version>2.5.4</dynamic.datasource.boot.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>commons-net</groupId>
            <artifactId>commons-net</artifactId>
            <version>3.3</version>
        </dependency>

        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>2.9.0</version>
        </dependency>

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

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.version}</version>
        </dependency>

        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>${mybatisplus.boot.version}</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>${druid.version}</version>
        </dependency>

        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
            <version>${dynamic.datasource.boot.version}</version>
        </dependency>

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

    </dependencies>

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

</project>

 

2、application.yml:主要注意加粗的紅色兩行要配成和自己本地的mapper及xml一致的

spring:
  autoconfigure:
    exclude: com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure  # 為了某些版本的springboot  @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class}) 無法生效
  datasource:
    dynamic:
      primary: master #設置默認的數據源或者數據源組,默認值即為master,如果讀者只是單數據源只需要注釋掉slave相關配置即可,這里為了方便演示master與slave保持相同
      datasource:
        master:
          url: jdbc:mysql://localhost:3306/account1?serverTimezone=Hongkong&allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false  # serverTimezone=Hongkong 需要填上時區
          username: root
          password: 123
          driverClassName:  com.mysql.cj.jdbc.Driver
        slave:
          url: jdbc:mysql://localhost:3306/account2?serverTimezone=Hongkong&allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false  # serverTimezone=Hongkong 需要填上時區
          username: root
          password: 123
          driverClassName:  com.mysql.cj.jdbc.Driver
      initial-size: 10 # 以下是連接池配置
      max-active: 100
      min-idle: 10
      max-wait: 60000
      pool-prepared-statements: true
      max-pool-prepared-statement-per-connection-size: 20
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      #validation-query: SELECT 1
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      stat-view-servlet:
        enabled: true
        url-pattern: /druid/*
        login-username: druid
        login-password: 123456
      filter:
        stat:
          log-slow-sql: true
          slow-sql-millis: 1000
          merge-sql: false
        wall:
          config:
            multi-statement-allow: true



#mybatis plus
mybatis-plus:
#  mapper-locations: classpath:mapper/**/*.xml
  mapper-locations: classpath:/com/example/demo/verifyaccount/mapper/xml/*Mapper.xml
  #實體掃描,多個package用逗號或者分號分隔
#  typeAliasesPackage: com.example.mybatisplus.entity
  typeAliasesPackage: com.example.demo.verifyaccount.entity
  check-config-location: true
  configuration:
    #是否開啟自動駝峰命名規則(camel case)映射
    map-underscore-to-camel-case: true
    #全局地開啟或關閉配置文件中的所有映射器已經配置的任何緩存
    cache-enabled: false
    call-setters-on-nulls: true
    #配置JdbcTypeForNull, oracle數據庫必須配置
    jdbc-type-for-null: 'null'
    #MyBatis 自動映射時未知列或未知屬性處理策略 NONE:不做任何處理 (默認值), WARNING:以日志的形式打印相關警告信息, FAILING:當作映射失敗處理,並拋出異常和詳細信息
    auto-mapping-unknown-column-behavior: warning
  #這個配置會將執行的sql打印出來,在開發或測試的時候可以用
  log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
global-config: banner: false db-config: #主鍵類型 0:"數據庫ID自增", 1:"未設置主鍵類型",2:"用戶輸入ID (該類型可以通過自己注冊自動填充插件進行填充)", 3:"全局唯一ID (idWorker), 4:全局唯一ID (UUID), 5:字符串全局唯一ID (idWorker 的字符串表示)"; id-type: UUID #字段驗證策略 IGNORED:"忽略判斷", NOT_NULL:"非NULL判斷", NOT_EMPTY:"非空判斷", DEFAULT 默認的,一般只用於注解里(1. 在全局里代表 NOT_NULL,2. 在注解里代表 跟隨全局) field-strategy: NOT_EMPTY #數據庫大寫下划線轉換 capital-mode: true #邏輯刪除值 logic-delete-value: 0 #邏輯未刪除值 logic-not-delete-value: 1 server: port: 7000

 

3、啟動類:

【要注意這一行:

@MapperScan("com.example.mybatisplus.mapper") //掃描mapper的包,或者讀者可以在對應的mapper上加上@Mapper的注解

 

最好在生產的Mpper類上都加上@Mapper注解

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

@SpringBootApplication(exclude= {DataSourceAutoConfiguration.class}) //去掉springboot 默認的數據源配置
@MapperScan("com.example.mybatisplus.mapper") //掃描mapper的包,或者讀者可以在對應的mapper上加上@Mapper的注解
public class MybatisplusSpringbootApplication {

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

}

 

4、分頁攔截器【加上這個就可以用分頁了】

package com.example.demo.config;
import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
//@MapperScan("com.example.demo.verifyaccount.*")
public class MybatisPlusConfig {
    @Bean
    public PaginationInterceptor paginationInterceptor() {
        return new PaginationInterceptor();
    }
}

-----------------------------

經過上面4個步驟就可以了,不需要其他config配置類

使用例子:

默認使用主數據源,要想使用其他數據源,可以在生成的service上加@DS("副數據源名稱")

eg:這里的slave對應application.yml中的配置

 

 

分頁查詢

eg:

需要現在生成的service中加入分頁查詢代碼:

public interface IDzDetailService extends IService<DzDetail> {
    public IPage selectPage(IPage iPage, QueryWrapper QueryWrapper);
}

 

然后在業務中調用即可

QueryWrapper<DzDetail> dzDetailQueryWrapper = new QueryWrapper<>();
dzDetailQueryWrapper.eq("status_cd", "1");//未處理
dzDetailQueryWrapper.eq("doc_id", dzDocId);
dzDetailQueryWrapper.orderByAsc("id");
int count = dzDetailService.count(dzDetailQueryWrapper);
//根據文檔id查詢記錄表,分頁查詢,每一萬條處理一次
int size = 10000;
int batchNum = count / size + 1;
IPage<DzDetail> userPage = new Page<>(i*size, size);//參數一是當前頁,參數二是每頁個數
IPage iPage = dzDetailService.selectPage(userPage, dzDetailQueryWrapper);
List<DzDetail> detailList = iPage.getRecords();

 

 

 

---- -----------------------------------------------------------

Mybatisplus多數據源

 

 

2019-04-30 14:37:08 12005 收藏 13
分類專欄: springboot

該項目主要實現mybatisplus、多數據源、lombok、druid的集成
主要參考 https://mp.baomidou.com/guide/quick-start.html
項目地址:https://github.com/Blankwhiter/mybatisplus-springboot release1.0
項目結構:
在這里插入圖片描述

一、創建表以及測試數據

CREATE TABLE user ( id VARCHAR(32) 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) ); 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'); 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17

二、引入項目依賴,加入配置,修改啟動類,編寫實體類和mapper對象(讀者可以根據自動生成工具生成這塊代碼)

1.引入依賴

pom.xml

<?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 http://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.1.4.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.example</groupId> <artifactId>mybatisplus-springboot</artifactId> <version>0.0.1-SNAPSHOT</version> <name>mybatisplus-springboot</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> <mysql.version>6.0.6</mysql.version> <mybatisplus.boot.version>3.1.0</mybatisplus.boot.version> <druid.version>1.1.10</druid.version> <dynamic.datasource.boot.version>2.5.4</dynamic.datasource.boot.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>${mysql.version}</version> </dependency> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>${mybatisplus.boot.version}</version> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>${druid.version}</version> </dependency> <dependency> <groupId>com.baomidou</groupId> <artifactId>dynamic-datasource-spring-boot-starter</artifactId> <version>${dynamic.datasource.boot.version}</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project> 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
2.編寫配置

application.yml

spring:
  autoconfigure:
    exclude: com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure  # 為了某些版本的springboot  @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class}) 無法生效
  datasource:
    dynamic:
      primary: master #設置默認的數據源或者數據源組,默認值即為master,如果讀者只是單數據源只需要注釋掉slave相關配置即可,這里為了方便演示master與slave保持相同
      datasource:
        master:
          url: jdbc:mysql://localhost:3306/test?serverTimezone=Hongkong&allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false  # serverTimezone=Hongkong 需要填上時區
          username: root
          password: 111111
          driverClassName:  com.mysql.cj.jdbc.Driver
        slave:
          url: jdbc:mysql://localhost:3306/test?serverTimezone=Hongkong&allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false  # serverTimezone=Hongkong 需要填上時區
          username: root
          password: 111111
          driverClassName:  com.mysql.cj.jdbc.Driver
      initial-size: 10 # 以下是連接池配置
      max-active: 100
      min-idle: 10
      max-wait: 60000
      pool-prepared-statements: true
      max-pool-prepared-statement-per-connection-size: 20
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      #validation-query: SELECT 1
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      stat-view-servlet:
        enabled: true
        url-pattern: /druid/*
        login-username: druid
        login-password: 123456
      filter:
        stat:
          log-slow-sql: true
          slow-sql-millis: 1000
          merge-sql: false
        wall:
          config:
            multi-statement-allow: true



#mybatis plus
mybatis-plus:
  mapper-locations: classpath:mapper/**/*.xml
  #實體掃描,多個package用逗號或者分號分隔
  typeAliasesPackage: com.example.mybatisplus.entity
  check-config-location: true
  configuration:
    #是否開啟自動駝峰命名規則(camel case)映射
    map-underscore-to-camel-case: true
    #全局地開啟或關閉配置文件中的所有映射器已經配置的任何緩存
    cache-enabled: false
    call-setters-on-nulls: true
    #配置JdbcTypeForNull, oracle數據庫必須配置
    jdbc-type-for-null: 'null'
    #MyBatis 自動映射時未知列或未知屬性處理策略 NONE:不做任何處理 (默認值), WARNING:以日志的形式打印相關警告信息, FAILING:當作映射失敗處理,並拋出異常和詳細信息
    auto-mapping-unknown-column-behavior: warning
  global-config:
    banner: false
    db-config:
      #主鍵類型  0:"數據庫ID自增", 1:"未設置主鍵類型",2:"用戶輸入ID (該類型可以通過自己注冊自動填充插件進行填充)", 3:"全局唯一ID (idWorker), 4:全局唯一ID (UUID), 5:字符串全局唯一ID (idWorker 的字符串表示)";
      id-type: UUID
      #字段驗證策略 IGNORED:"忽略判斷", NOT_NULL:"非NULL判斷", NOT_EMPTY:"非空判斷", DEFAULT 默認的,一般只用於注解里(1. 在全局里代表 NOT_NULL,2. 在注解里代表 跟隨全局)
      field-strategy: NOT_EMPTY
      #數據庫大寫下划線轉換
      capital-mode: true
      #邏輯刪除值
      logic-delete-value: 0
      #邏輯未刪除值
      logic-not-delete-value: 1

server:
  port: 7000

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
3.修改啟動類

MybatisplusSpringbootApplication.java

import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class}) //去掉springboot 默認的數據源配置 @MapperScan("com.example.mybatisplus.mapper") //掃描mapper的包,或者讀者可以在對應的mapper上加上@Mapper的注解 public class MybatisplusSpringbootApplication { public static void main(String[] args) { SpringApplication.run(MybatisplusSpringbootApplication.class, args); } } 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
4.編寫實體

4.1 user.java

import lombok.Data; /** * user 實體類 */ @Data public class User { private String id; private String name; private Integer age; private String email; } 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12

注:讀者請自行在開發工具安裝lombok插件,或者去掉@data注解換成setter getter方法即可

4.2 UserMapper.java

import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.example.mybatisplus.entity.User; /** * 用戶mapper */ @DS("slave") //這里是配置數據源注解,默認是master public interface UserMapper extends BaseMapper<User> { } 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11

三、編寫測試用例


import com.example.mybatisplus.entity.User; import com.example.mybatisplus.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; /** * 簡單的測試增刪改查 */ @RunWith(SpringRunner.class) @SpringBootTest public class MybatisplusSpringbootApplicationTests { @Autowired private UserMapper userMapper; @Test public void addUser() { User user = new User(); user.setAge(200); user.setEmail("belonghuang@outlook.com"); user.setName("belongHuang"); userMapper.insert(user); } @Test public void updateUser() { User user = userMapper.selectById(1); user.setAge(300); int i = userMapper.updateById(user); if (i>0) { System.out.println("修改成功"); }else { System.out.println("修改失敗"); } } @Test public void deleteUser() { int i = userMapper.deleteById(1); if (i>0) { System.out.println("刪除成功"); }else { System.out.println("刪除失敗"); } } @Test public void selectUser() { List<User> users = userMapper.selectList(null); users.stream().map(User::getName).forEach(System.out::println);//打印出所用用戶名字 } } 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60

本文側重點於集成,更多功能移步至官網。


免責聲明!

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



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