01 前言

隨著應用用戶數量的增加，相應的并發請求的數量也會跟著不斷增加，慢慢地，單個數據庫已經沒有辦法滿足我們頻繁的數據庫操作請求了，在某些場景下，我們可能會需要配置多個數據源，使用多個數據源(例如實現數據庫的讀寫分離)來緩解系統的壓力等，同樣的，Springboot官方提供了相應的實現來幫助開發者們配置多數據源，一般分為兩種方式(目前我所了解到的)，分包和AOP，其中利用AOP實現多個數據源到的動態切換時候會另開一篇文章來寫。考慮到MyBatis是JAVA開發者們使用較為頻繁的數據庫框架，所以本篇文章使用Springboot+Mybatis來實現多數據源的配置。

廢話不多說，走起。

02 數據庫準備

既然是配置多數據源，那么我們自然就要先把相應的數據源給準備好，這里呢，我本地新建了兩個數據庫，如下表：

并分別插入兩條記錄，為了方便對比，其中testdatasource1為芳年25歲的張三， testdatasource2為芳年30歲的李四。

03 環境準備

首先新建一個Springboot項目，我這里版本是2.1.7.RELEASE，并在pom文件中引入相關依賴：關鍵依賴如下:

 <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>
 </dependency>

到這里我們的環境已經基本配置完成了。

04 代碼部分

4.1 多數據源配置

首先呢，在我們Springboot的配置文件中配置我們的datasourse，和以往不一樣的是，因為我們有兩個數據源，所以要指定相關數據庫的名稱，其中主數據源為primary，次數據源為secondary如下:

#配置主數據庫
spring.datasource.primary.jdbc-url=jdbc:mysql://localhost:3306/testdatasource1?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC&useSSL=false
spring.datasource.primary.username=root
spring.datasource.primary.password=root
spring.datasource.primary.driver-class-name=com.mysql.cj.jdbc.Driver
##配置次數據庫
spring.datasource.secondary.jdbc-url=jdbc:mysql://localhost:3306/testdatasource2?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC&useSSL=false
spring.datasource.secondary.username=root
spring.datasource.secondary.password=root
spring.datasource.secondary.driver-class-name=com.mysql.cj.jdbc.Driver
spring.http.encoding.charset=UTF-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true

需要我們注意的是，Springboot2.0 在配置數據庫連接的時候需要使用jdbc-url，如果只使用url的話會報

jdbcUrl is required with driverClassName.錯誤。

新建一個配置類PrimaryDataSourceConfig，用于配置我們的主數據庫相關的bean，代碼如下:

@Configuration
@MApperScan(basePackages = "com.jdkcb.mybatisstuday.mapper.one", sqlSessionFactoryRef = "PrimarySqlSessionFactory")//basePackages:接口文件的包路徑
public class PrimaryDataSourceConfig {
 @Bean(name = "PrimaryDataSource")
 // 表示這個數據源是默認數據源
 @Primary//這個一定要加，如果兩個數據源都沒有@Primary會報錯
 @ConfigurationProperties(prefix = "spring.datasource.primary")//我們配置文件中的前綴
 public DataSource getPrimaryDateSource() {
 return DataSourceBuilder.create().build();
 }
 @Bean(name = "PrimarySqlSessionFactory")
 @Primary
 public SqlSessionFactory primarySqlSessionFactory(@Qualifier("PrimaryDataSource") DataSource datasource)
 throws Exception {
 SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
 bean.setDataSource(datasource);
 bean.setMapperLocations( 
 new PathMatchingResourcePatternResolver().getResources("classpath*:mapping/one/*.xml"));
 return bean.getObject();// 設置mybatis的xml所在位置
 }
 
 
 @Bean("PrimarySqlSessionTemplate")
 // 表示這個數據源是默認數據源
 @Primary
 public SqlSessionTemplate primarySqlSessionTemplate(
 @Qualifier("PrimarySqlSessionFactory") SqlSessionFactory sessionfactory) {
 return new SqlSessionTemplate(sessionfactory);
 }
}

注解說明:

@MapperScan ：配置mybatis的接口類放的地方

@Primary :表示使用的是默認數據庫，這個一個要加，否則會因為不知道哪個數據庫是默認數據庫而報錯

@ConfigurationProperties：讀取application.properties中的配置參數映射成為一個對象，其中prefix表示參數的前綴

大功告成~ ~ 了嗎？并沒有，然后配置我們的第二個數據源的配置類,代碼如下：

@Configuration
@MapperScan(basePackages = "com.jdkcb.mybatisstuday.mapper.two", sqlSessionFactoryRef = "SecondarySqlSessionFactory")
public class SecondaryDataSourceConfig {
 @Bean(name = "SecondaryDataSource")
 @ConfigurationProperties(prefix = "spring.datasource.secondary")
 public DataSource getSecondaryDataSource() {
 return DataSourceBuilder.create().build();
 }
 @Bean(name = "SecondarySqlSessionFactory")
 public SqlSessionFactory secondarySqlSessionFactory(@Qualifier("SecondaryDataSource") DataSource datasource)
 throws Exception {
 SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
 bean.setDataSource(datasource);
 bean.setMapperLocations(
 new PathMatchingResourcePatternResolver().getResources("classpath*:mapping/two/*.xml"));
 return bean.getObject();// 設置mybatis的xml所在位置
 }
 @Bean("SecondarySqlSessionTemplate")
 public SqlSessionTemplate secondarySqlSessionTemplate(
 @Qualifier("SecondarySqlSessionFactory") SqlSessionFactory sessionfactory) {
 return new SqlSessionTemplate(sessionfactory);
 }

剩下的就是編寫我們相應的xml文件和接口類了，代碼如下:

@Component
@Mapper
public interface PrimaryUserMapper {
 List<User> findAll();
}
@Component
@Mapper
public interface SecondaryUserMapper {
 List<User> findAll();
}

相關的xml文件如下:

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
 PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.jdkcb.mybatisstuday.mapper.one.PrimaryUserMapper">
 <select id="findAll" resultType="com.jdkcb.mybatisstuday.pojo.User">
 select * from sys_user;
 </select>
</mapper>
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
 PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.jdkcb.mybatisstuday.mapper.two.SecondaryUserMapper">
 <select id="findAll" resultType="com.jdkcb.mybatisstuday.pojo.User">
 select * from sys_user2;
 </select>
</mapper>

注:其中xml文件在本實例中目錄為：resources/mapping

4.2 測試

編寫一個Controller用于測試，因為是測試實例且代碼相對來說較為簡單，所以這里就不寫Service層了。

代碼如下:

@RestController
public class UserController {
 @Autowired
 private PrimaryUserMapper primaryUserMapper;
 @Autowired
 private SecondaryUserMapper secondaryUserMapper;
 @RequestMapping("primary")
 public Object primary(){
 List<User> list = primaryUserMapper.findAll();
 return list;
 }
 @RequestMapping("secondary")
 public Object secondary (){
 List<User> list = secondaryUserMapper.findAll();
 return list;
 }
 
}

在瀏覽器分別輸入
:http://127.0.0.1:8080/primary 和
http://127.0.0.1:8080/secondary

結果如下:

[{"user_id":1,"user_name":"張三","user_age":25}] //primary 
[{"user_id":1,"user_name":"李四","user_age":30}] //secondary

到此，Springboot結合mybatis配置多數據源就大功告成啦。

好啦，看完之后如果你覺得有所收獲，那就點個贊再走唄~