2. 程式人生 > 程式設計 >Spring Boot + Mybatis-Plus實現多資料來源的方法

Spring Boot + Mybatis-Plus實現多資料來源的方法

阿新 • • 發佈：2020-11-22

前段時間寫了一篇基於mybatis實現的多資料來源部落格。感覺不是很好，這次打算加入git，來搭建一個基於Mybatis-Plus的多資料來源專案
Mybatis-Plus就是香

前言：該專案分為master資料來源與local資料來源。假定master資料來源為線上資料庫，local為本地資料庫。後續我們將通過xxl-job的方式，將線上(master)中的資料同步到本地(local)中

專案git地址 抽時間把專案提交到git倉庫，方便大家直接克隆
sql檔案已置於專案中，資料庫使用的mysql

建立專案

我這裡使用的idea，正常建立spring boot專案就行了。

sql 

-- 建立master資料庫
CREATE DATABASE db_master;

USE db_master;
-- 使用者表
CREATE TABLE users(
	id INT PRIMARY KEY AUTO_INCREMENT COMMENT '主鍵id',username VARCHAR(20) NOT NULL COMMENT '使用者名稱',pwd VARCHAR(50) NOT NULL COMMENT '密碼',phone CHAR(11) NOT NULL COMMENT '手機號',email VARCHAR(50) COMMENT '郵箱',gender CHAR(1) COMMENT '性別 1-->男 0-->女',age INT COMMENT '年齡',created_time TIMESTAMP NULL DEFAULT NULL COMMENT '建立時間',updated_time TIMESTAMP NULL DEFAULT NULL COMMENT '修改時間',deleted_time TIMESTAMP NULL DEFAULT NULL COMMENT '刪除時間',type INT DEFAULT 1 COMMENT '狀態 1-->啟用 2-->禁用 3-->軟刪除'
)ENGINE=INNODB;

INSERT INTO users(username,pwd,phone,email,gender,age) VALUES('supperAdmin','admin123','13000000000','[email protected]',1,20); 
INSERT INTO users(username,age) VALUES('admin','admin','13200840033','[email protected]',14); 
INSERT INTO users(username,age) VALUES('wanggang','wanggang','13880443322','[email protected]',36); 
INSERT INTO users(username,age) VALUES('xiaobao','xiaobao','18736450102','[email protected]',22); 
INSERT INTO users(username,age) VALUES('zhaoxing','zhaoxing','18966004400','[email protected]',29); 
INSERT INTO users(username,age) VALUES('chenyun','chenyun','13987613540','[email protected]',25); 
INSERT INTO users(username,age) VALUES('ouyangruixue','ouyangruixue','15344773322','[email protected]',24); 

-- 建立local資料庫
CREATE DATABASE db_local;

USE db_local;
-- 本地庫使用者表
CREATE TABLE users(
	id INT PRIMARY KEY AUTO_INCREMENT COMMENT '主鍵id',type INT DEFAULT 1 COMMENT '狀態 1-->啟用 2-->禁用 3-->軟刪除'
)ENGINE=INNODB;
-- 本地庫測試表
CREATE TABLE local_test(
	id INT PRIMARY KEY AUTO_INCREMENT,str VARCHAR(20)
)ENGINE=INNODB;
INSERT INTO local_test(str) VALUES ('Hello');
INSERT INTO local_test(str) VALUES ('World');
INSERT INTO local_test(str) VALUES ('Mysql');
INSERT INTO local_test(str) VALUES ('^.^');

pom檔案

目前只引入了lombok、mybatis-plus、mysql相關的依賴

	<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
		<!-- lombok -->
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>
    <!-- Mybatis-Plus -->
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus-boot-starter</artifactId>
      <version>3.2.0</version>
    </dependency>
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <scope>runtime</scope>
    </dependency>

application.yml

properties刪除，yml建立。其實無所謂yml還是properties

server:
 port: 8001

spring:
 datasource:
  master:
   url: jdbc:mysql://localhost:3306/db_master?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai&allowMultiQueries=true
   username: root
   password: 123456
   driver-class-name: com.mysql.cj.jdbc.Driver

  local:
   url: jdbc:mysql://localhost:3306/db_local?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai&allowMultiQueries=true
   username: root
   password: 123456
   driver-class-name: com.mysql.cj.jdbc.Driver

mybatis-plus:
 mapper-locations: classpath:mappers/*/*Mapper.xml
 #實體掃描，多個package用逗號或者分號分隔
 typeAliasesPackage: com.niuniu.sys.module
 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: auto
   #欄位驗證策略 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

pagehelper:            #pagehelper分頁外掛
 helperDialect: mysql     #設定資料庫方言
 reasonable: true
 supportMethodsArguments: true
 params: count=countSql

目錄結構

由於該專案分為兩個資料來源。在各個分層中，你將分別見到master、local。

在這裡插入圖片描述

備註：由於users表在兩個資料來源中完全相同，將Users實體置於model層公用

關鍵程式碼

在config包中，我們需要對master、local的資料來源進行配置，使其可以通過不同的請求，自動切換資料來源

另外 由於該專案使用mybatis-plus，在建立SqlSessionFactory的時候，請使用MybatisSqlSessionFactoryBean進行bean物件的建立

在這裡插入圖片描述

local資料來源 

package com.demo.config;

import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import com.zaxxer.hikari.HikariDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.demo.dao.local",sqlSessionFactoryRef = "localSqlSessionFactory")
public class LocalDataSourceConfig {
  @Value("${spring.datasource.local.driver-class-name}")
  private String driverClassName;
  @Value("${spring.datasource.local.url}")
  private String url;
  @Value("${spring.datasource.local.username}")
  private String username;
  @Value("${spring.datasource.local.password}")
  private String password;

  @Bean(name = "localDataSource")
  public DataSource localDataSource() {
    HikariDataSource dataSource = new HikariDataSource();
    dataSource.setUsername(username);
    dataSource.setPassword(password);
    dataSource.setJdbcUrl(url);
    dataSource.setDriverClassName(driverClassName);
    dataSource.setMaximumPoolSize(10);
    dataSource.setMinimumIdle(5);
    dataSource.setPoolName("localDataSourcePool");
    return dataSource;
  }

  /**
   * local資料來源
   */
  @Bean(name = "localSqlSessionFactory")
  public SqlSessionFactory sqlSessionFactory(@Qualifier("localDataSource") DataSource dataSource) throws Exception {
    MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
    bean.setDataSource(dataSource);
    // 設定Mybatis全域性配置路徑
    bean.setConfigLocation(new ClassPathResource("mybatis-config.xml"));
    bean.setMapperLocations(
        new PathMatchingResourcePatternResolver().getResources("classpath*:mappers/local/*.xml"));
    return bean.getObject();
  }

  @Bean(name = "localTransactionManager")
  public DataSourceTransactionManager transactionManager(@Qualifier("localDataSource") DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
  }

  @Bean(name = "localSqlSessionTemplate")
  public SqlSessionTemplate testSqlSessionTemplate(
      @Qualifier("localSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    return new SqlSessionTemplate(sqlSessionFactory);
  }
}

master資料來源

package com.demo.config;

import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import com.zaxxer.hikari.HikariDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.demo.dao.master",sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {
  @Value("${spring.datasource.master.driver-class-name}")
  private String driverClassName;
  @Value("${spring.datasource.master.url}")
  private String url;
  @Value("${spring.datasource.master.username}")
  private String username;
  @Value("${spring.datasource.master.password}")
  private String password;

  @Bean(name = "masterDataSource")
  @Primary
  public DataSource masterDataSource() {
    HikariDataSource dataSource = new HikariDataSource();
    dataSource.setUsername(username);
    dataSource.setPassword(password);
    dataSource.setJdbcUrl(url);
    dataSource.setDriverClassName(driverClassName);
    dataSource.setMaximumPoolSize(10);
    dataSource.setMinimumIdle(5);
    dataSource.setPoolName("masterDataSource");
    return dataSource;
  }


  /**
   * master資料來源
   */
  @Bean(name = "masterSqlSessionFactory")
  @Primary
  public SqlSessionFactory sqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
    MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
    bean.setDataSource(dataSource);
    bean.setConfigLocation(new ClassPathResource("mybatis-config.xml"));
    bean.setMapperLocations(
        new PathMatchingResourcePatternResolver().getResources("classpath*:mappers/master/*.xml"));
    return bean.getObject();
  }

  @Bean(name = "masterTransactionManager")
  @Primary
  public DataSourceTransactionManager transactionManager(@Qualifier("masterDataSource") DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
  }

  @Bean(name = "masterSqlSessionTemplate")
  @Primary
  public SqlSessionTemplate testSqlSessionTemplate(
      @Qualifier("masterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    return new SqlSessionTemplate(sqlSessionFactory);
  }
}

部分程式碼

Users實體類

package com.demo.model;

import lombok.Data;
import java.util.Date;

@Data
public class Users {
  private Integer id;
  private String username;
  private String pwd;
  private String phone;
  private String email;
  private Integer gender;
  private Integer age;
  private Date created_time;
  private Date updated_time;
  private Date deleted_time;
  private Integer type;
}

UsersMapper

package com.demo.dao.master;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.demo.model.Users;
import org.apache.ibatis.annotations.Mapper;

@Mapper
public interface UsersMapper extends BaseMapper<Users> {
}

UsersService

package com.demo.service.master;

import com.baomidou.mybatisplus.extension.service.IService;
import com.demo.model.Users;

public interface UsersService extends IService<Users> {
}

UsersServiceImpl

package com.demo.service.master.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.demo.dao.master.UsersMapper;
import com.demo.model.Users;
import com.demo.service.master.UsersService;
import org.springframework.stereotype.Service;

@Service
public class UsersServiceImpl extends ServiceImpl<UsersMapper,Users> implements UsersService {
}

UsersController

package com.demo.controller.master;

import com.demo.model.Users;
import com.demo.service.master.UsersService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/master")
public class UsersController {
  @Autowired
  private UsersService userssService;
  
  @RequestMapping("/users")
  public List<Users> list() {
    return userssService.list();
  }
}

最終的專案結構

在這裡插入圖片描述

執行結果

在這裡插入圖片描述
在這裡插入圖片描述

至此Spring Boot + Mybatis-Plus已經完成了多資料來源的實現。
最後再寫一點我遇到的坑吧
1、master與local中不要出現同名的檔案
2、資料來源配置中SqlSessionFactoryBean替換為MybatisSqlSessionFactoryBean

下一篇將會圍繞xxl-job任務排程中心，介紹如何通過xxl-job實現本地庫與線上庫的定時同步

到此這篇關於Spring Boot + Mybatis-Plus實現多資料來源的文章就介紹到這了,更多相關Spring Boot Mybatis-Plus多資料來源內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！

相關推薦

Spring Boot + Mybatis-Plus實現多資料來源的方法

前段時間寫了一篇基於mybatis實現的多資料來源部落格。感覺不是很好，這次打算加入git，來搭建一個基於Mybatis-Plus的多資料來源專案

MyBatis-Plus實現多資料來源的示例程式碼

多資料來源的目的在於一個程式碼模組可呼叫多個數據庫的資料進行某些業務操作。

mybatis plus + druid多資料來源（使用dynamic實現）

參考開源專案dynamic:https://github.com/baomidou/dynamic-datasource-spring-boot-starter 引入pom：

Mybatis plus 配置多資料來源的實現示例

記得面試時候，有面試官會問道，你們多資料來源是怎麼實現的呀。.......，一陣矇蔽中，然後說道我們之前專案中，沒有用到多資料來源。

Spring Boot + Mybatis Plus + ClickHouse 輕鬆實現增刪改查，看了必懂。。

來源：blog.csdn.net/qq_15371293/article/details/117090780 專案場景： ClickHouse 操作基於 Mybatis-puls原始碼擴充套件開發。解決ClickHouse的修改和刪除 SQL操作與Mysql不相同。

Spring boot+mybatis+thymeleaf 實現登入註冊增刪改查功能的示例程式碼

本文重在實現理解，過濾器，業務，邏輯需求，樣式請無視。。 專案結構如下

mybatis 自定義外掛 獲取元資料 spring boot + mybatis plus（prepareStatement.getMetaData()）

@org.springframework.context.annotation.Configuration@MapperScan(basePackages = {\"xxx.xxx.xxx\"})public class MybatisPlusConfig {@Beanpublic ConfigurationCustomizer configurationCustomizer() {Configu

spring boot:用dynamic-datasource-spring-boot-starter配置druid多資料來源(spring boot 2.3.3)

一，dynamic-datasource-spring-boot-starter的用途? 1,dynamic-datasource-spring-boot-starter 是一個基於springboot的快速整合多資料來源的啟動器

springboot+druid+mybatis plus的多資料來源配置

https://www.jianshu.com/p/ff5af6c59365 多資料來源配置，在我們整合多個系統或者對接的時候經常會用到，結合springboot、druid提供了比較方便的整合方案。

MyBatis Plus 實現多表分頁查詢功能的示例程式碼

在Mybatis Plus 中，雖然IService 介面幫我們定義了很多常用的方法，但這些都是 T 物件有用，如果涉及到 多表的查詢，還是需要自定義Vo 物件和自己編寫sql 語句，Mybatis Plus提供了一個Page 物件,查詢是需要設定其中

mybatis下實現多資料來源

這次要完成的是從一個數據庫中讀取資料，然後再把資料插入到另一個數據庫中。在同一套專案程式碼中要完成這個操作，就不可避免的涉及到了多資料來源。本文即介紹在mybatis中完成多資料來源的切換相關內容

springboot + mybatis-plus實現多表聯合查詢功能(註解方式)

第一步：加入mybatis-plus依賴 第二步：配置資料來源 spring: thymeleaf: cache: false encoding: utf-8

Springboot mybatis plus druid多資料來源解決方案 dynamic-datasource的使用詳解

依賴 <dependency> <groupId>com.baomidou</groupId> <artifactId>dynamic-datasource-spring-boot-starter</artifactId>

基於Mybatis Plus實現多表分頁查詢的示例程式碼

注意：Mybatis Plus 3.0.7 版本才開始用【自定義sql】+【QueryWrapper】，低版本不能使用，還是老實寫SQL進行條件拼接

spring boot mybatis多資料來源解決方案過程解析

在我們的專案中不免會遇到需要在一個專案中使用多個數據源的問題，像我在得到一個任務將使用者的聊天記錄進行遷移的時候，就是用到了三個資料來源，當時使用的AOP的程式設計方式根據訪問的方法的不同進行動態的切換資

Spring Boot 整合 Sharding-JDBC + Mybatis-Plus 實現分庫分表功能

一、 Sharding-jdbc簡介 “ Sharding-jdbc是開源的資料庫操作中介軟體；定位為輕量級Java框架，在Java的JDBC層提供的額外服務。它使用客戶端直連資料庫，以jar包形式提供服務，無需額外部署和依賴，可理解為增強版的

最簡單的MyBatis Plus的多表聯接、分頁查詢實現方法

一、前言 最近在加強 ITAEM 團隊的一個 app 專案——學生教師學習交流平臺 人員組成：安卓 + 前端 + 後臺

spring中使用mybatis plus連線sqlserver的方法實現

本文主要關注如何使用mybatis/mybatis plus連線SQL Server資料庫，因此將省略其他專案配置、程式碼。

解決：MyBatis-plus多資料來源方法上方新增事務，資料來源切換失敗

說明：MyBatis-plus配置了多資料來源，新增事務後，資料來源切換失敗了... 一、場景描述

Mybatis-plus多資料來源方法新增事務，資料來源切換失敗

一、問題情況： 1.專案中使用的多資料來源，各個方法上加了@DataSource註解，對於批量操作，需要做使用事務保持批操作的一致性。