極簡Spring Boot整合MyBatis多數據源

關於多數據源的配置，前面和大夥介紹過JdbcTemplate多數據源配置，那個比較簡單，本文來和大夥說說MyBatis多數據源的配置。
其實關於多數據源，個人態度仍是和以前同樣，複雜的就直接上分佈式數據庫中間件，簡單的再考慮多數據源。這是項目中的建議，技術上的話，固然仍是各類技術都要掌握的。

工程建立

首先須要建立MyBatis項目，項目建立和前文的同樣，添加MyBatis、MySQL以及Web依賴：

項目建立完成後，添加Druid依賴，和JdbcTemplate同樣，這裏添加Druid依賴也必須是專爲Spring boot打造的Druid，不能使用傳統的Druid。完整的依賴以下：

<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>2.0.0</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.1.10</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.28</version>
    <scope>runtime</scope>
</dependency>

多數據源配置

接下來配置多數據源，這裏基本上仍是和JdbcTemplate多數據源的配置方式一致，首先在application.properties中配置數據庫基本信息，而後提供兩個DataSource便可，這裏我再把代碼貼出來，裏邊的道理條條框框的，大夥能夠參考前面的文章，這裏再也不贅述。

application.properties中的配置：

spring.datasource.one.url=jdbc:mysql:///test01?useUnicode=true&characterEncoding=utf-8
spring.datasource.one.username=root
spring.datasource.one.password=root
spring.datasource.one.type=com.alibaba.druid.pool.DruidDataSource

spring.datasource.two.url=jdbc:mysql:///test02?useUnicode=true&characterEncoding=utf-8
spring.datasource.two.username=root
spring.datasource.two.password=root
spring.datasource.two.type=com.alibaba.druid.pool.DruidDataSource

而後再提供兩個DataSource，以下：

@Configuration
public class DataSourceConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.one")
    DataSource dsOne() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.two")
    DataSource dsTwo() {
        return DruidDataSourceBuilder.create().build();
    }
}

MyBatis配置

接下來則是MyBatis的配置，不一樣於JdbcTemplate，MyBatis的配置要稍微麻煩一些，由於要提供兩個Bean，所以這裏兩個數據源我將在兩個類中分開來配置，首先來看第一個數據源的配置：

@Configuration
@MapperScan(basePackages = "org.sang.mybatis.mapper1",sqlSessionFactoryRef = "sqlSessionFactory1",sqlSessionTemplateRef = "sqlSessionTemplate1")
public class MyBatisConfigOne {
    @Resource(name = "dsOne")
    DataSource dsOne;

    @Bean
    SqlSessionFactory sqlSessionFactory1() {
        SqlSessionFactory sessionFactory = null;
        try {
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dsOne);
            sessionFactory = bean.getObject();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return sessionFactory;
    }
    @Bean
    SqlSessionTemplate sqlSessionTemplate1() {
        return new SqlSessionTemplate(sqlSessionFactory1());
    }
}

建立MyBatisConfigOne類，首先指明該類是一個配置類，配置類中要掃描的包是org.sang.mybatis.mapper1，即該包下的Mapper接口將操做dsOne中的數據，對應的SqlSessionFactory和SqlSessionTemplate分別是sqlSessionFactory1和sqlSessionTemplate1，在MyBatisConfigOne內部，分別提供SqlSessionFactory和SqlSessionTemplate便可，SqlSessionFactory根據dsOne建立，而後再根據建立好的SqlSessionFactory建立一個SqlSessionTemplate。

這裏配置完成後，依據這個配置，再來配置第二個數據源便可：

@Configuration
@MapperScan(basePackages = "org.sang.mybatis.mapper2",sqlSessionFactoryRef = "sqlSessionFactory2",sqlSessionTemplateRef = "sqlSessionTemplate2")
public class MyBatisConfigTwo {
    @Resource(name = "dsTwo")
    DataSource dsTwo;

    @Bean
    SqlSessionFactory sqlSessionFactory2() {
        SqlSessionFactory sessionFactory = null;
        try {
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dsTwo);
            sessionFactory = bean.getObject();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return sessionFactory;
    }
    @Bean
    SqlSessionTemplate sqlSessionTemplate2() {
        return new SqlSessionTemplate(sqlSessionFactory2());
    }
}

好了，這樣MyBatis多數據源基本上就配置好了，接下來只須要在org.sang.mybatis.mapper1和org.sang.mybatis.mapper2包中提供不一樣的Mapper，Service中注入不一樣的Mapper就能夠操做不一樣的數據源。

mapper建立

org.sang.mybatis.mapper1中的mapper：

public interface UserMapperOne {
    List<User> getAllUser();
}

對應的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="org.sang.mybatis.mapper1.UserMapperOne">
    <select id="getAllUser" resultType="org.sang.mybatis.model.User">
        select * from t_user;
    </select>
</mapper>

org.sang.mybatis.mapper2中的mapper：

public interface UserMapper {
    List<User> getAllUser();
}

對應的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="org.sang.mybatis.mapper2.UserMapper">
    <select id="getAllUser" resultType="org.sang.mybatis.model.User">
        select * from t_user;
    </select>
</mapper>

接下來，在Service中注入兩個不一樣的Mapper，不一樣的Mapper將操做不一樣的數據源。