SpringBoot搭建多數(shù)據(jù)源的實現(xiàn)方法
首先我們建立兩個數(shù)據(jù)庫(可以不在同一臺電腦上):
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 '用戶id', `cost` DECIMAL(13, 2) COMMENT '訂單費用' ) 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 '用戶id', `username` VARCHAR(50) NOT NULL COMMENT '用戶名', `age` TINYINT UNSIGNED COMMENT '年齡' ) COMMENT '用戶表';
然后創(chuàng)建一個maven項目,其中 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的夫項目 --> <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 相關的依賴 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- Spring 健康檢測模塊 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <!-- mybatis 相關依賴 --> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.2.0</version> </dependency> <!-- MySQL 驅(qū)動 --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <!-- json 工具類 --> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.78</version> </dependency> </dependencies> <build> <plugins> <!-- 制作一個可運行的 jar 包需要的插件 --> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
在 application.yml
中需要配置兩個數(shù)據(jù)源:
spring: datasource: # 用戶模塊數(shù)據(jù)庫配置 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ù)庫配置 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
然后我們定義一個配置類 DataSourseConfig
用于配置多數(shù)據(jù)源,首先是申明數(shù)據(jù)源,按照 application.yml
當中的配置定義兩個數(shù)據(jù)源,注意當中的DataSource 是 javax.sql.DataSource
:
/** * 配置用戶的數(shù)據(jù)源 * * @return 用戶的數(shù)據(jù)源對象 */ @Primary // 需要一個默認配置的數(shù)據(jù)源 @Bean("user") @ConfigurationProperties(prefix = "spring.datasource.user") // 在yml中配置數(shù)據(jù)源的前綴 public DataSource user() { return DataSourceBuilder.create().build(); } /** * 配置訂單的數(shù)據(jù)源 * * @return 訂單的數(shù)據(jù)源對象 */ @Bean("order") @ConfigurationProperties(prefix = "spring.datasource.order") // 在yml中配置數(shù)據(jù)源的前綴 public DataSource order() { return DataSourceBuilder.create().build(); }
然后創(chuàng)建 SqlSessionFactory
:
/** * 注冊用戶的 SqlSession 工廠 * * @param user 數(shù)據(jù)源 * @return SqlSession 工廠 * @throws Exception 可能會拋出異常 */ @Primary // 配置一個這個類型默認的 bean @Bean("userSqlSessionFactory") public SqlSessionFactory userSqlSessionFactory(@Qualifier("user") DataSource user) throws Exception { // 創(chuàng)建bean SqlSessionFactoryBean factory = new SqlSessionFactoryBean(); // 設置數(shù)據(jù)源 factory.setDataSource(user); // 設置 mapper 文件的掃描 factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/user/*.xml")); return factory.getObject(); } /** * 注冊訂單的 SqlSession 工廠 * * @param order 數(shù)據(jù)源 * @return SqlSession 工廠 * @throws Exception 可能會拋出異常 */ @Bean("orderSqlSessionFactory") public SqlSessionFactory orderSqlSessionFactory(@Qualifier("order") DataSource order) throws Exception { // 創(chuàng)建bean SqlSessionFactoryBean factory = new SqlSessionFactoryBean(); // 設置數(shù)據(jù)源 factory.setDataSource(order); // 設置 mapper 文件的掃描 factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/order/*.xml")); return factory.getObject(); }
最后聲明兩個 SqlSessionTemplate
:
/** * 用戶的 SqlSessionTemplate * * @param userSqlSessionFactory 用戶的 SqlSession 工廠 * @return 用戶的 SqlSessionTemplate */ @Primary // 設置這個類型默認的 bean @Bean("userSqlSessionTemplate") public SqlSessionTemplate userSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory userSqlSessionFactory) { return new SqlSessionTemplate(userSqlSessionFactory); } /** * 訂單的 SqlSessionTemplate * * @param orderSqlSessionFactory 訂單的 SqlSession 工廠 * @return 用戶的 SqlSessionTemplate */ @Bean("orderSqlSessionTemplate") public SqlSessionTemplate orderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory") SqlSessionFactory orderSqlSessionFactory) { return new SqlSessionTemplate(orderSqlSessionFactory); }
最后別忘了在配置類上加上一個注解,用于聲明哪些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
類的代碼:
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ù)源的配置類 * </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 { /** * 配置用戶的數(shù)據(jù)源 * * @return 用戶的數(shù)據(jù)源對象 */ @Primary // 需要一個默認配置的數(shù)據(jù)源 @Bean("user") @ConfigurationProperties(prefix = "spring.datasource.user") // 在yml中配置數(shù)據(jù)源的前綴 public DataSource user() { return DataSourceBuilder.create().build(); } /** * 配置訂單的數(shù)據(jù)源 * * @return 訂單的數(shù)據(jù)源對象 */ @Bean("order") @ConfigurationProperties(prefix = "spring.datasource.order") // 在yml中配置數(shù)據(jù)源的前綴 public DataSource order() { return DataSourceBuilder.create().build(); } /** * 注冊用戶的 SqlSession 工廠 * * @param user 數(shù)據(jù)源 * @return SqlSession 工廠 * @throws Exception 可能會拋出異常 */ @Primary // 配置一個這個類型默認的 bean @Bean("userSqlSessionFactory") public SqlSessionFactory userSqlSessionFactory(@Qualifier("user") DataSource user) throws Exception { // 創(chuàng)建bean SqlSessionFactoryBean factory = new SqlSessionFactoryBean(); // 設置數(shù)據(jù)源 factory.setDataSource(user); // 設置 mapper 文件的掃描 factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/user/*.xml")); return factory.getObject(); } /** * 注冊訂單的 SqlSession 工廠 * * @param order 數(shù)據(jù)源 * @return SqlSession 工廠 * @throws Exception 可能會拋出異常 */ @Bean("orderSqlSessionFactory") public SqlSessionFactory orderSqlSessionFactory(@Qualifier("order") DataSource order) throws Exception { // 創(chuàng)建bean SqlSessionFactoryBean factory = new SqlSessionFactoryBean(); // 設置數(shù)據(jù)源 factory.setDataSource(order); // 設置 mapper 文件的掃描 factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/order/*.xml")); return factory.getObject(); } /** * 用戶的 SqlSessionTemplate * * @param userSqlSessionFactory 用戶的 SqlSession 工廠 * @return 用戶的 SqlSessionTemplate */ @Primary // 設置這個類型默認的 bean @Bean("userSqlSessionTemplate") public SqlSessionTemplate userSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory userSqlSessionFactory) { return new SqlSessionTemplate(userSqlSessionFactory); } /** * 訂單的 SqlSessionTemplate * * @param orderSqlSessionFactory 訂單的 SqlSession 工廠 * @return 用戶的 SqlSessionTemplate */ @Bean("orderSqlSessionTemplate") public SqlSessionTemplate orderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory") SqlSessionFactory orderSqlSessionFactory) { return new SqlSessionTemplate(orderSqlSessionFactory); } }
然后按照注解上面定義的包創(chuàng)建兩個 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ù)庫訪問接口 * </p> * * @author tanghai * @version 1.0 * @date 2021-12-03 星期五 14:08:19 * @file OrderMapper.java */ @Mapper public interface OrderMapper { /** * 新增一個訂單實體 * * @param order 訂單實體 * @return 受影響行數(shù) */ int insertOrder(Order order); /** * 查詢一個訂單列表 * * @param order 查詢參數(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> * 用戶的數(shù)據(jù)庫訪問接口 * </p> * * @author tanghai * @version 1.0 * @date 2021-12-03 星期五 14:11:55 * @file UserMapper.java */ @Mapper public interface UserMapper { /** * 新增一個用戶 * * @param user 用戶對象 * @return 受影響行數(shù) */ int insertUser(User user); /** * 查詢用戶列表 * * @param user 查詢參數(shù) * @return 符合條件的用戶列表 */ List<User> selectUser(User user); }
之后我會將代碼提交到 gitee,所以 Mapper.xml、Controller、Service 代碼在此處省略,然后我們新增幾條用戶數(shù)據(jù):
查詢一下:
同時訂單數(shù)據(jù)庫:
查詢:
然后在數(shù)據(jù)庫當中查看是否是發(fā)送到不同的數(shù)據(jù)庫:
可以確定,確實是存入了兩個數(shù)據(jù)庫。好了下課
代碼倉庫
:https://gitee.com/xiaohha/multiple-datasources
到此這篇關于SpringBoot搭建多數(shù)據(jù)源的實現(xiàn)方法的文章就介紹到這了,更多相關SpringBoot搭建多數(shù)據(jù)源內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
- SpringBoot多數(shù)據(jù)源配置的全過程記錄
- 利用SpringBoot實現(xiàn)多數(shù)據(jù)源的兩種方式總結
- SpringBoot+Mybatis plus實現(xiàn)多數(shù)據(jù)源整合的實踐
- springboot+springJdbc+postgresql 實現(xiàn)多數(shù)據(jù)源的配置
- springboot 中整合mybatis多數(shù)據(jù)源不使用JPA
- springboot配置多數(shù)據(jù)源并集成Druid和mybatis的操作
- springboot中mybatis多數(shù)據(jù)源動態(tài)切換實現(xiàn)
- 教你使用springboot配置多數(shù)據(jù)源
相關文章
SpringBoot 創(chuàng)建web項目并部署到外部Tomcat
本篇文章主要介紹了SpringBoot 創(chuàng)建web項目并部署到外部Tomcat,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-06-06Linux+Docker+SpringBoot+IDEA一鍵自動化部署的詳細步驟
這篇文章主要介紹了Linux+Docker+SpringBoot+IDEA一鍵自動化部署的詳細步驟,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-07-07