SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法
更新時(shí)間：2021年12月06日 15:06:27 作者：XiaoHH Superme
說(shuō)起多數(shù)據(jù)源,一般都來(lái)解決那些問(wèn)題呢,主從模式或者業(yè)務(wù)比較復(fù)雜需要連接不同的分庫(kù)來(lái)支持業(yè)務(wù)。本文主要介紹了SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法，感興趣的可以了解一下，感興趣的可以額了解一下
首先我們建立兩個(gè)數(shù)據(jù)庫(kù)（可以不在同一臺(tái)電腦上）:
multiple_order：
DROP DATABASE IF EXISTS `multiple_order`;
CREATE DATABASE `multiple_order`;
USE `multiple_order`;
CREATE TABLE `order` (
`order_id` BIGINT UNSIGNED PRIMARY KEY AUTO_INCREMENT COMMENT '訂單id',
`user_id` BIGINT UNSIGNED NOT NULL COMMENT '用戶(hù)id',
`cost` DECIMAL(13, 2) COMMENT '訂單費(fèi)用'
) COMMENT '訂單表';
multiple_user：
DROP DATABASE IF EXISTS `multiple_user`;
CREATE DATABASE `multiple_user`;
USE `multiple_user`;
CREATE TABLE `user` (
`user_id` BIGINT UNSIGNED PRIMARY KEY AUTO_INCREMENT COMMENT '用戶(hù)id',
`username` VARCHAR(50) NOT NULL COMMENT '用戶(hù)名',
`age` TINYINT UNSIGNED COMMENT '年齡'
) COMMENT '用戶(hù)表';
然后創(chuàng)建一個(gè)maven項(xiàng)目，其中 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>
<!-- SpringBoot的夫項(xiàng)目 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.9.RELEASE</version>
</parent>
<groupId>love.xiaohh.datasource</groupId>
<artifactId>multiple-datasources</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
<dependencies>
<!-- SpringMVC 相關(guān)的依賴(lài) -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Spring 健康檢測(cè)模塊 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- mybatis 相關(guān)依賴(lài) -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>
<!-- MySQL 驅(qū)動(dòng) -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- json 工具類(lèi) -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.78</version>
</dependency>
</dependencies>
<build>
<plugins>
<!-- 制作一個(gè)可運(yùn)行的 jar 包需要的插件 -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
在 application.yml 中需要配置兩個(gè)數(shù)據(jù)源：
spring:
datasource:
# 用戶(hù)模塊數(shù)據(jù)庫(kù)配置
user:
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://127.0.0.1:3306/multiple_user?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: xiaohh
# 訂單模塊數(shù)據(jù)庫(kù)配置
order:
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://127.0.0.1:3306/multiple_order?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: xiaohh
mybatis:
# Mapper 的目錄
mapper-locations: classpath:mapper/**/*Mapper.xml
然后我們定義一個(gè)配置類(lèi) DataSourseConfig 用于配置多數(shù)據(jù)源，首先是申明數(shù)據(jù)源，按照 application.yml 當(dāng)中的配置定義兩個(gè)數(shù)據(jù)源，注意當(dāng)中的DataSource 是 javax.sql.DataSource：
/**
* 配置用戶(hù)的數(shù)據(jù)源
*
* @return 用戶(hù)的數(shù)據(jù)源對(duì)象
*/
@Primary // 需要一個(gè)默認(rèn)配置的數(shù)據(jù)源
@Bean("user")
@ConfigurationProperties(prefix = "spring.datasource.user") // 在yml中配置數(shù)據(jù)源的前綴
public DataSource user() {
return DataSourceBuilder.create().build();
}
/**
* 配置訂單的數(shù)據(jù)源
*
* @return 訂單的數(shù)據(jù)源對(duì)象
*/
@Bean("order")
@ConfigurationProperties(prefix = "spring.datasource.order") // 在yml中配置數(shù)據(jù)源的前綴
public DataSource order() {
return DataSourceBuilder.create().build();
}
然后創(chuàng)建 SqlSessionFactory ：
/**
* 注冊(cè)用戶(hù)的 SqlSession 工廠
*
* @param user 數(shù)據(jù)源
* @return SqlSession 工廠
* @throws Exception 可能會(huì)拋出異常
*/
@Primary // 配置一個(gè)這個(gè)類(lèi)型默認(rèn)的 bean
@Bean("userSqlSessionFactory")
public SqlSessionFactory userSqlSessionFactory(@Qualifier("user") DataSource user) throws Exception {
// 創(chuàng)建bean
SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
// 設(shè)置數(shù)據(jù)源
factory.setDataSource(user);
// 設(shè)置 mapper 文件的掃描
factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/user/*.xml"));
return factory.getObject();
}
/**
* 注冊(cè)訂單的 SqlSession 工廠
*
* @param order 數(shù)據(jù)源
* @return SqlSession 工廠
* @throws Exception 可能會(huì)拋出異常
*/
@Bean("orderSqlSessionFactory")
public SqlSessionFactory orderSqlSessionFactory(@Qualifier("order") DataSource order) throws Exception {
// 創(chuàng)建bean
SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
// 設(shè)置數(shù)據(jù)源
factory.setDataSource(order);
// 設(shè)置 mapper 文件的掃描
factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/order/*.xml"));
return factory.getObject();
}
最后聲明兩個(gè) SqlSessionTemplate ：
/**
* 用戶(hù)的 SqlSessionTemplate
*
* @param userSqlSessionFactory 用戶(hù)的 SqlSession 工廠
* @return 用戶(hù)的 SqlSessionTemplate
*/
@Primary // 設(shè)置這個(gè)類(lèi)型默認(rèn)的 bean
@Bean("userSqlSessionTemplate")
public SqlSessionTemplate userSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory userSqlSessionFactory) {
return new SqlSessionTemplate(userSqlSessionFactory);
}
/**
* 訂單的 SqlSessionTemplate
*
* @param orderSqlSessionFactory 訂單的 SqlSession 工廠
* @return 用戶(hù)的 SqlSessionTemplate
*/
@Bean("orderSqlSessionTemplate")
public SqlSessionTemplate orderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory") SqlSessionFactory orderSqlSessionFactory) {
return new SqlSessionTemplate(orderSqlSessionFactory);
}
最后別忘了在配置類(lèi)上加上一個(gè)注解，用于聲明哪些Mapper文件用哪些注解：
@Configuration
@MapperScans({
// basePackages 是mapper的包路徑，sqlSessionTemplateRef 是指定我們創(chuàng)建的 SqlSessionTemplate
@MapperScan(basePackages = "love.xiaohh.datasource.mapper.user", sqlSessionTemplateRef = "userSqlSessionTemplate"),
@MapperScan(basePackages = "love.xiaohh.datasource.mapper.order", sqlSessionTemplateRef = "orderSqlSessionTemplate")
})
完整的 DataSourceConfig 類(lèi)的代碼：
package love.xiaohh.datasource.config;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.mybatis.spring.annotation.MapperScans;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import javax.sql.DataSource;
/**
* <p>
* 多數(shù)據(jù)源的配置類(lèi)
* </p>
*
* @author XiaoHH
* @version 1.0
* @date 2021-12-03 星期五 11:15:06
* @file DataSourceConfig.java
*/
@Configuration
@MapperScans({
// basePackages 是mapper的包路徑，sqlSessionTemplateRef 是指定我們創(chuàng)建的 SqlSessionTemplate
@MapperScan(basePackages = "love.xiaohh.datasource.mapper.user", sqlSessionTemplateRef = "userSqlSessionTemplate"),
@MapperScan(basePackages = "love.xiaohh.datasource.mapper.order", sqlSessionTemplateRef = "orderSqlSessionTemplate")
})
public class DataSourceConfig {
/**
* 配置用戶(hù)的數(shù)據(jù)源
*
* @return 用戶(hù)的數(shù)據(jù)源對(duì)象
*/
@Primary // 需要一個(gè)默認(rèn)配置的數(shù)據(jù)源
@Bean("user")
@ConfigurationProperties(prefix = "spring.datasource.user") // 在yml中配置數(shù)據(jù)源的前綴
public DataSource user() {
return DataSourceBuilder.create().build();
}
/**
* 配置訂單的數(shù)據(jù)源
*
* @return 訂單的數(shù)據(jù)源對(duì)象
*/
@Bean("order")
@ConfigurationProperties(prefix = "spring.datasource.order") // 在yml中配置數(shù)據(jù)源的前綴
public DataSource order() {
return DataSourceBuilder.create().build();
}
/**
* 注冊(cè)用戶(hù)的 SqlSession 工廠
*
* @param user 數(shù)據(jù)源
* @return SqlSession 工廠
* @throws Exception 可能會(huì)拋出異常
*/
@Primary // 配置一個(gè)這個(gè)類(lèi)型默認(rèn)的 bean
@Bean("userSqlSessionFactory")
public SqlSessionFactory userSqlSessionFactory(@Qualifier("user") DataSource user) throws Exception {
// 創(chuàng)建bean
SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
// 設(shè)置數(shù)據(jù)源
factory.setDataSource(user);
// 設(shè)置 mapper 文件的掃描
factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/user/*.xml"));
return factory.getObject();
}
/**
* 注冊(cè)訂單的 SqlSession 工廠
*
* @param order 數(shù)據(jù)源
* @return SqlSession 工廠
* @throws Exception 可能會(huì)拋出異常
*/
@Bean("orderSqlSessionFactory")
public SqlSessionFactory orderSqlSessionFactory(@Qualifier("order") DataSource order) throws Exception {
// 創(chuàng)建bean
SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
// 設(shè)置數(shù)據(jù)源
factory.setDataSource(order);
// 設(shè)置 mapper 文件的掃描
factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/order/*.xml"));
return factory.getObject();
}
/**
* 用戶(hù)的 SqlSessionTemplate
*
* @param userSqlSessionFactory 用戶(hù)的 SqlSession 工廠
* @return 用戶(hù)的 SqlSessionTemplate
*/
@Primary // 設(shè)置這個(gè)類(lèi)型默認(rèn)的 bean
@Bean("userSqlSessionTemplate")
public SqlSessionTemplate userSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory userSqlSessionFactory) {
return new SqlSessionTemplate(userSqlSessionFactory);
}
/**
* 訂單的 SqlSessionTemplate
*
* @param orderSqlSessionFactory 訂單的 SqlSession 工廠
* @return 用戶(hù)的 SqlSessionTemplate
*/
@Bean("orderSqlSessionTemplate")
public SqlSessionTemplate orderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory") SqlSessionFactory orderSqlSessionFactory) {
return new SqlSessionTemplate(orderSqlSessionFactory);
}
}
然后按照注解上面定義的包創(chuàng)建兩個(gè) Mapper 接口
OrderMapper：
package love.xiaohh.datasource.mapper.order;
import love.xiaohh.datasource.entities.order.Order;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* <p>
* 訂單的數(shù)據(jù)庫(kù)訪問(wèn)接口
* </p>
*
* @author tanghai
* @version 1.0
* @date 2021-12-03 星期五 14:08:19
* @file OrderMapper.java
*/
@Mapper
public interface OrderMapper {
/**
* 新增一個(gè)訂單實(shí)體
*
* @param order 訂單實(shí)體
* @return 受影響行數(shù)
*/
int insertOrder(Order order);
/**
* 查詢(xún)一個(gè)訂單列表
*
* @param order 查詢(xún)參數(shù)
* @return 符合條件的訂單列表
*/
List<Order> selectOrder(Order order);
}
UserMapper：
package love.xiaohh.datasource.mapper.user;
import love.xiaohh.datasource.entities.user.User;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* <p>
* 用戶(hù)的數(shù)據(jù)庫(kù)訪問(wèn)接口
* </p>
*
* @author tanghai
* @version 1.0
* @date 2021-12-03 星期五 14:11:55
* @file UserMapper.java
*/
@Mapper
public interface UserMapper {
/**
* 新增一個(gè)用戶(hù)
*
* @param user 用戶(hù)對(duì)象
* @return 受影響行數(shù)
*/
int insertUser(User user);
/**
* 查詢(xún)用戶(hù)列表
*
* @param user 查詢(xún)參數(shù)
* @return 符合條件的用戶(hù)列表
*/
List<User> selectUser(User user);
}
之后我會(huì)將代碼提交到 gitee，所以 Mapper.xml、Controller、Service 代碼在此處省略，然后我們新增幾條用戶(hù)數(shù)據(jù)：
查詢(xún)一下：
同時(shí)訂單數(shù)據(jù)庫(kù)：
查詢(xún)：
然后在數(shù)據(jù)庫(kù)當(dāng)中查看是否是發(fā)送到不同的數(shù)據(jù)庫(kù)：
可以確定，確實(shí)是存入了兩個(gè)數(shù)據(jù)庫(kù)。好了下課
代碼倉(cāng)庫(kù)：https://gitee.com/xiaohha/multiple-datasources
到此這篇關(guān)于SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法的文章就介紹到這了,更多相關(guān)SpringBoot搭建多數(shù)據(jù)源內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
- SpringBoot多數(shù)據(jù)源配置的全過(guò)程記錄
- 利用SpringBoot實(shí)現(xiàn)多數(shù)據(jù)源的兩種方式總結(jié)
- SpringBoot+Mybatis plus實(shí)現(xiàn)多數(shù)據(jù)源整合的實(shí)踐
- springboot+springJdbc+postgresql 實(shí)現(xiàn)多數(shù)據(jù)源的配置
- springboot 中整合mybatis多數(shù)據(jù)源不使用JPA
- springboot配置多數(shù)據(jù)源并集成Druid和mybatis的操作
- springboot中mybatis多數(shù)據(jù)源動(dòng)態(tài)切換實(shí)現(xiàn)
- 教你使用springboot配置多數(shù)據(jù)源
相關(guān)文章
Springboot?RestTemplate設(shè)置超時(shí)時(shí)間的簡(jiǎn)單方法
學(xué)習(xí)springboot ,RestTemplate的使用場(chǎng)景非常非常多,比如springcloud中的服務(wù)消費(fèi),下面這篇文章主要給大家介紹了關(guān)于Springboot?RestTemplate設(shè)置超時(shí)時(shí)間的簡(jiǎn)單方法,需要的朋友可以參考下2022-01-01
Hadoop源碼分析六啟動(dòng)文件namenode原理詳解
本篇是Hadoop源碼分析系列文章第六篇，主要介紹Hadoop中的啟動(dòng)文件namenode，后續(xù)本系列文章會(huì)持續(xù)更新，有需要的朋友可以借鑒參考下2021-09-09
Spring Boot攔截器實(shí)現(xiàn)步驟及測(cè)試實(shí)例
這篇文章主要介紹了Spring Boot攔截器實(shí)現(xiàn)步驟及測(cè)試實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-04-04
SpringBoot中@Scheduled實(shí)現(xiàn)服務(wù)啟動(dòng)時(shí)執(zhí)行一次
本文主要介紹了SpringBoot中@Scheduled實(shí)現(xiàn)服務(wù)啟動(dòng)時(shí)執(zhí)行一次,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2024-08-08
Java的反射（reflection）機(jī)制是指在程序的運(yùn)行狀態(tài)中，可以構(gòu)造任意一個(gè)類(lèi)的對(duì)象，可以了解任意一個(gè)對(duì)象所屬的類(lèi)，可以了解任意一個(gè)類(lèi)的成員變量和方法，可以調(diào)用任意一個(gè)對(duì)象的屬性和方法2022-03-03
這篇文章主要介紹了Spring和SpringBoot之間的區(qū)別，幫助大家更好的理解和學(xué)習(xí)使用這兩種框架，感興趣的朋友可以了解下2021-04-04
Java中Date、LocalDate、LocalDateTime、LocalTime、時(shí)間戳之間的相互轉(zhuǎn)換代碼
這篇文章主要介紹了Java中日期時(shí)間轉(zhuǎn)換的多種方法,包括將Date轉(zhuǎn)換為L(zhǎng)ocalDateTime、LocalDate等,以及將時(shí)間戳轉(zhuǎn)換為L(zhǎng)ocalDateTime,文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下2025-04-04
這篇文章主要介紹了Spring?boot異步任務(wù)原理，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-11-11
java并發(fā)學(xué)習(xí)之Executor源碼解析
這篇文章主要為大家介紹了java并發(fā)學(xué)習(xí)之Executor源碼示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-07-07
讓Java程序自動(dòng)重啟的實(shí)現(xiàn)方法(推薦)
下面小編就為大家?guī)?lái)一篇讓Java程序自動(dòng)重啟的實(shí)現(xiàn)方法(推薦)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-03-03