SpringBoot現在是很多很多公司應用的後端框架，因為它搭建快，能更好、更快速的整合其他第三方。那麼隨著業務的不斷擴充套件，業務量的增加，這時候就會牽扯到分庫分表，雖然這個詞聽起來很熟悉，作為程式設計師也很容易理解，但是我想應該也有不少讀者沒接觸過分庫分表，今天我們不聊如何分庫分表，而是聊SpringBoot如何整合多個數據源的事情。也就是如何接入不同的（多個）資料庫。

 

我們直接開始，我們直接建立一個乾淨的SpringBoot應用。

<parent>    <groupId>org.springframework.boot</groupId>
 
    <artifactId>spring-boot-starter-parent</artifactId>    <version>2.1.0.RELEASE</version>    <relativePath/> <!-- lookup parent from repository --></parent>

 

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-web</artifactId>
 
</dependency>​<dependency>    <groupId>org.mybatis.spring.boot</groupId>    <artifactId>mybatis-spring-boot-starter</artifactId>    <version>1.3.2</version></dependency>​<dependency>    <groupId>mysql</groupId>    <artifactId>mysql-connector-java</artifactId>
 
    <scope>runtime</scope></dependency>​<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-jdbc</artifactId></dependency>​<dependency>    <groupId>org.projectlombok</groupId>    <artifactId>lombok</artifactId>    <version>1.18.8</version></dependency>

引入需要的maven座標，那麼我們這個工程就算搭建起來了，接下來就是配置，如何讓SpringBoot整合兩個Mysql資料來源。首先我們在本地建立兩個資料庫test1和test2，同時在裡面建立兩個結構一樣的表。

CREATE TABLE `user` (  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '使用者ID',  `username` varchar(100) CHARACTER SET utf8 NOT NULL COMMENT '使用者名稱',  `password` varchar(100) NOT NULL COMMENT '密碼',  `create_time` datetime DEFAULT NULL COMMENT '建立時間',  PRIMARY KEY (`id`)) ENGINE=MyISAM AUTO_INCREMENT=3 DEFAULT CHARSET=latin1;

在我們的工程中配置application.yml檔案，將資料庫的資訊配置進去

spring:  datasource:    test1:      driver-class-name: com.mysql.cj.jdbc.Driver      jdbc-url: jdbc:mysql://localhost:3306/test1?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC      username: root      password: 1234​    test2:      driver-class-name: com.mysql.cj.jdbc.Driver      jdbc-url: jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC      username: root      password: 1234

接下來就是寫我們的配置類了，這也是整合多個數據源最為關鍵的部分。

import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.SqlSessionFactoryBean;import org.mybatis.spring.SqlSessionTemplate;import org.mybatis.spring.annotation.MapperScan;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.jdbc.datasource.DataSourceTransactionManager;​import javax.sql.DataSource;​/** * @ClassName DataSource2Config * @Description TODO * @Auther lbt * @Date 2019/6/28/028 10:07 * @Version 1.0 */@Configuration@MapperScan(basePackages = "com.example.mapper.test1", sqlSessionFactoryRef = "test1SqlSessionFactory")public class DataSource1Config {​​    @Bean(name = "test1DataSource")    @ConfigurationProperties(prefix = "spring.datasource.test1")    @Primary    public DataSource test1DataSource() {        return DataSourceBuilder.create().build();    }​    @Bean(name = "test1SqlSessionFactory")    @Primary    public SqlSessionFactory test1SqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource) throws Exception {        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();        bean.setDataSource(dataSource);        return bean.getObject();    }​    @Bean(name = "test1TransactionManager")    @Primary    public DataSourceTransactionManager test1TransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {        return new DataSourceTransactionManager(dataSource);    }​    @Bean(name = "test1SqlSessionTemplate")    @Primary    public SqlSessionTemplate test1SqlSessionTemplate(@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {        return new SqlSessionTemplate(sqlSessionFactory);    }}

第二個資料來源的配置

import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.SqlSessionFactoryBean;import org.mybatis.spring.SqlSessionTemplate;import org.mybatis.spring.annotation.MapperScan;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.jdbc.datasource.DataSourceTransactionManager;​import javax.sql.DataSource;​@Configuration@MapperScan(basePackages = "com.example.mapper.test2", sqlSessionFactoryRef = "test2SqlSessionFactory")public class DataSource2Config {​​    @Bean(name = "test2DataSource")    @ConfigurationProperties(prefix = "spring.datasource.test2")    public DataSource test2DataSource() {        return DataSourceBuilder.create().build();    }​    @Bean(name = "test2SqlSessionFactory")    public SqlSessionFactory test2SqlSessionFactory(@Qualifier("test2DataSource") DataSource dataSource) throws Exception {        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();        bean.setDataSource(dataSource);        return bean.getObject();    }​    @Bean(name = "test2TransactionManager")    public DataSourceTransactionManager test2TransactionManager(@Qualifier("test2DataSource") DataSource dataSource) {        return new DataSourceTransactionManager(dataSource);    }​    @Bean(name = "test2SqlSessionTemplate")    public SqlSessionTemplate test2SqlSessionTemplate(@Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {        return new SqlSessionTemplate(sqlSessionFactory);    }}

這樣我們整個的配置其實就算好了，我們接下來寫一個Controller類來測試一下，我們整合的資料來源是不是真的可以用呢？

@RestControllerpublic class TestController {​    @Autowired    private User1Service user1Service;​    @Autowired    private User2Service user2Service;​    @RequestMapping("/user1")    public Object user1Controller() {​        List<UserPo> all = user1Service.findAll();​        return all;    }​    @RequestMapping("/user2")    public Object user2Controller() {​        List<UserPo> all = user2Service.findAll();​        return all;    }}

我寫了個兩個Controller方法，分別訪問不同的介面，我們來看下訪問結果。

當我們訪問user1的時候返回如下：

 

當我們訪問user2的時候訪問如下

看到這裡其實我們的整個整合也就完成了， 雖然看起來很簡單，但是你如果沒寫過確實會走很多坑，我剛整合的時候就遇到了很多坑，為了幫助大家重複採坑，分享出來供大家參考，另外我已經上傳GitHub，大家可以直接拉下來跑。

 

下篇給大家分享一下，這幾天在對接微信支付時，遇到的坑，已經微信支付的業務流程。

 

GitHub地址：

相關推薦