微信號：hzy1014211086，如果你正在學習Spring Boot，可以加入我們的Spring技術交流群，共同成長

一、引入依賴

<dependencies>
	
		<dependency>
			<groupId>org.mybatis.spring.boot</groupId>
			<artifactId>mybatis-spring-boot-starter</artifactId>
			<version>2.2.0</version>
		</dependency>
		
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<scope>runtime</scope>
		</dependency>
</dependencies>

二、配置&初始化資料源

接下來，在 application.properties 中配置資料源，不同于上篇文章，這里的資料源需要配置兩個，如下：

spring.datasource.master.jdbc-url = jdbc:mysql://139.196.20.xxx:3306/spring_boot1?useUnicode=true&characterEncoding=utf-8
spring.datasource.master.username = root
spring.datasource.master.password = 123456
spring.datasource.master.driver-class-name = com.mysql.cj.jdbc.Driver

spring.datasource.slave.jdbc-url = jdbc:mysql://139.196.20.xxx:3306/spring_boot2?useUnicode=true&characterEncoding=utf-8
spring.datasource.slave.username = root
spring.datasource.slave.password = 123456
spring.datasource.slave.driver-class-name = com.mysql.cj.jdbc.Driver

這里通過 master 和 slave 對資料源進行了區分，但是加了 master 和 slave 之后，這里的配置就沒法被 SpringBoot 自動加載了 （因為前面的 key 變了），需要我們自己去加載 DataSource 了，此時，需要自己配置一個 DataSourceConfig，用來提供兩個 DataSource Bean，如下：

@Configuration
public class DataSourceConfiguration {

    @Primary
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.master")
    public DataSource masterDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.slave")
    public DataSource slaveDataSource() {
        return DataSourceBuilder.create().build();
    }
}

這里提供了兩個 Bean， @ConfigurationProperties(prefix = “spring.datasource.master”) 表示使用 spring.datasource.master 前綴的資料庫配置去創建一個 DataSource，一層一層注入，通過兩個不同 DataSource 創建兩個 SqlSessionFactory，然后再包裝到 SqlSessionTemplate中，

配置類上使用 @MapperScan 注解來指定當前資料源下定義的 Entity 和 Mapper 的包路徑，另外需要指定 sqlSessionFactory 和sqlSessionTemplate，這兩個具體實作在該配置類中類中初始化，

@Configuration
@MapperScan(
  basePackages = "com.fish.chapter7.master",
  sqlSessionFactoryRef = "masterSqlSessionFactory",
  sqlSessionTemplateRef = "masterSqlSessionTemplate")
public class MasterConfig {

  @Bean
  public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource masterDataSource) throws Exception {
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    bean.setDataSource(masterDataSource);
    return bean.getObject();
  }

  @Bean
  public SqlSessionTemplate masterSqlSessionTemplate(@Qualifier("masterSqlSessionFactory") SqlSessionFactory masterSqlSessionFactory) throws Exception {
    return new SqlSessionTemplate(masterSqlSessionFactory);
  }

}

@Configuration
@MapperScan(
  basePackages = "com.fish.chapter7.slave",
  sqlSessionFactoryRef = "slaveSqlSessionFactory",
  sqlSessionTemplateRef = "slaveSqlSessionTemplate")
public class SlaveConfig {

  @Bean
  public SqlSessionFactory slaveSqlSessionFactory(@Qualifier("slaveDataSource") DataSource slaveDataSource) throws Exception {
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    bean.setDataSource(slaveDataSource);
    return bean.getObject();
  }

  @Bean
  public SqlSessionTemplate slaveSqlSessionTemplate(@Qualifier("slaveSqlSessionFactory") SqlSessionFactory slaveSqlSessionFactory) throws Exception {
    return new SqlSessionTemplate(slaveSqlSessionFactory);
  }

}

三、準備測驗資料

創建spring_boot1、spring_boot2兩個資料庫

spring_boot1

CREATE TABLE `spring_boot1`.`article`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `title` varchar(255) NULL COMMENT '文章標題',
  `author` varchar(255) NULL COMMENT '作者',
  PRIMARY KEY (`id`)
) COMMENT = '文章表';

INSERT INTO `spring_boot1`.`article`(`id`, `title`, `author`) VALUES (1, 'master', 'Java程式魚');

spring_boot2

CREATE TABLE `spring_boot2`.`article`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `title` varchar(255) NULL COMMENT '文章標題',
  `author` varchar(255) NULL COMMENT '作者',
  PRIMARY KEY (`id`)
) COMMENT = '文章表';

INSERT INTO `spring_boot2`.`article`(`id`, `title`, `author`) VALUES (1, 'slave', 'Java程式魚');

四、核心代碼

@RestController
public class BlogController {

  @Autowired
  public BlogService blogService;

  /**
   * 查詢所有文章(master資料源)
   *
   * @return
   */
  @GetMapping(value = "/getAllByMasterDatabase")
  public List<Blog> getAllByMasterDatabase() {
    return blogService.getAllByMasterDatabase();
  }

  /**
   * 查詢所有文章(slave資料源)
   *
   * @return
   */
  @GetMapping(value = "/getAllBySlaveDatabase")
  public List<Blog> getAllBySlaveDatabase() {
    return blogService.getAllBySlaveDatabase();
  }

}

@Service
public class BlogServiceImpl implements BlogService {

  @Autowired
  private BlogMapperMaster blogMapperMaster;

  @Autowired
  private BlogMapperSlave blogMapperSlave;

  @Override
  public List<Blog> getAllByMasterDatabase() {
    return blogMapperMaster.getAll();
  }

  @Override
  public List<Blog> getAllBySlaveDatabase() {
    return blogMapperSlave.getAll();
  }

}

五、原始碼

本文的相關例子可以查看下面倉庫中的 chapter7 目錄：

• Gitee：https://gitee.com/hezhiyuan007/spring-boot-study
• Github：https://github.com/java-fish-0907/spring-boot-study