前言：在上一篇文章里面我们进行了spring boot 和 mybatis 的整合 《springboot整合mybatis使用druid数据源》, 文中是使用的单数据源，因为项目中有很多需要用到多数据源的场景，比如主从同步（读写分离）, 或者业务库拆分等，这样就需要操作不同的数据库，所以，集成多数据源就很有必要了。
网上关于 spring boot mybatis druid 多数据源的文章很多，我这里也借鉴了不少，不过也踩过各种坑，所以我在这里会将详细步骤和注意事项尽量描述清楚，希望能给需要的朋友提供一点思路和帮助。
一：开发环境： spring boot 1.5.7.RELEASE springboot-mybatis 1.3.2 druid-spring-boot-starter 1.1.5 mysql 5.7 系列
二：spring boot 和 mybatis 、druid整合我这里不再赘述，参考我上一篇文章，下面直接开始多数据源的整合。
2.1：首先配置文件 application.yml 需要更改内容，增加多数据源 one 和 two
server:port: 8088context-path: /yjbj## 配置数据源相关信息spring:datasource:type: com.alibaba.druid.pool.DruidDataSourcedruid:## 连接池配置filters: statmaxActive: 20initialSize: 1maxWait: 60000minIdle: 1timeBetweenEvictionRunsMillis: 60000minEvictableIdleTimeMillis: 300000validationQuery: select 'x'testWhileIdle: truetestOnBorrow: falsetestOnReturn: falsepoolPreparedStatements: truemaxOpenPreparedStatements: 20one:## 数据源one配置name: DBconfig1url: jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=falseusername: ***password: ******driver-class-name: com.mysql.jdbc.Drivertwo:## 数据源two配置name: DBconfig2url: jdbc:mysql://127.0.0.1:3306/slave?useUnicode=true&characterEncoding=utf8&useSSL=falseusername: ***password: ******driver-class-name: com.mysql.jdbc.Driverredis:host: 127.0.0.1 # redis服务所在的地址port: 6379password: # redis的密码默认为空pool:max-active: 8 #连接池最大连接数（使用负值表示没有限制）max-idle: 8 #连接池最大空闲数min-idle: 1 #连接池最小空闲数max-wait: 60000 #获取连接的超时等待事件timeout: 30000 #连接redis服务器的最大等待时间druid: #druid监控页面用户名和密码name: adminpass: sailing123## 该配置节点为独立的节点mybatis:mapper-locations: classpath:mapperXML/*.xml # 注意：一定要对应mapper映射xml文件的所在路径config-location: classpath:MybatisConfig.xml # 注意: mybatis的配置文件type-aliases-package: com.sailing.springbootmybatis.bean # 注意：对应实体类的路径## 配置mybatis分页插件pagehelper:helperDialect: mysqlreasonable: truesupport-methods-arguments: trueparams: count=conutSql
2.2：编写数据源的配置类，这里有两个数据源，所以需要两个配置类，DataSourceOneConifg 和DataSourceTwoConifg，内容分别如下：
package com.sailing.springbootmybatis.config;import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.SqlSessionFactoryBean;import org.mybatis.spring.SqlSessionTemplate;import org.mybatis.spring.annotation.MapperScan;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.beans.factory.annotation.Value;import org.springframework.boot.context.properties.ConfigurationProperties;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;/*** @author baibing* @project: springboot-mybatis* @package: com.sailing.springbootmybatis.config* @Description: one数据源配置类* @date /10/18 17：05*/@Configuration//下面的sqlSessionTemplateRef 值需要和生成的SqlSessionTemplate bean name相同，如果没有指定name,那么就是方法名@MapperScan(basePackages = {"com.sailing.springbootmybatis.mapper.one"}, sqlSessionTemplateRef = "sqlSessionTemplateOne")public class DataSourceOneConfig {@Value("${mybatis.mapper-locations}")private String mapper_location;@Value("${mybatis.config-location}")private String mybatis_config;private Logger logger = LoggerFactory.getLogger(DataSourceOneConfig.class);@Primary@Bean(name = "datasourceOne")@ConfigurationProperties(prefix = "spring.datasource.druid.one")public DataSource datasourceOne() {return DruidDataSourceBuilder.create().build();}@Beanpublic SqlSessionFactory sqlSessionFactoryOne(@Qualifier("datasourceOne") DataSource dataSource) throws Exception {logger.info("mapper文件地址：" + mapper_location);logger.info("mybatis配置文件地址：" + mybatis_config);//在基本的 MyBatis 中,session 工厂可以使用 SqlSessionFactoryBuilder 来创建。// 而在 MyBatis-spring 中,则使用SqlSessionFactoryBean 来替代：SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);//如果重写了 SqlSessionFactory 需要在初始化的时候手动将 mapper 地址 set到 factory 中，否则会报错：//org.apache.ibatis.binding.BindingException: Invalid bound statement (not found)bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapper_location));bean.setConfigLocation(new PathMatchingResourcePatternResolver().getResource(mybatis_config));return bean.getObject();}/*** SqlSessionTemplate 是 SqlSession接口的实现类，是spring-mybatis中的，实现了SqlSession线程安全** @param sqlSessionFactory* @return*/@Beanpublic SqlSessionTemplate sqlSessionTemplateOne(@Qualifier("sqlSessionFactoryOne") SqlSessionFactory sqlSessionFactory) {SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory);return template;}/*** 为选中的数据源 datasourceOne 添加事务管理* @param dataSource* @return transactionManagerOne service层@Transactional(value引用的就是这里的值)*/@Beanpublic DataSourceTransactionManager transactionManagerOne(@Qualifier("datasourceOne") DataSource dataSource){return new DataSourceTransactionManager(dataSource);}}
package com.sailing.springbootmybatis.config;import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;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.beans.factory.annotation.Value;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.core.io.support.PathMatchingResourcePatternResolver;import javax.sql.DataSource;/*** @author baibing* @project: springboot-mybatis* @package: com.sailing.springbootmybatis.config* @Description: two数据源配置类* @date /10/18 17：28*/@Configuration@MapperScan(basePackages = {"com.sailing.springbootmybatis.mapper.two"}, sqlSessionTemplateRef = "sqlSessionTemplateTwo")public class DataSourceTwoConfig {@Value("${mybatis.mapper-locations}")private String mapper_location;@Bean(name = "dataSourceTwo")@ConfigurationProperties(prefix = "spring.datasource.druid.two")public DataSource dataSourceTwo() {return DruidDataSourceBuilder.create().build();}@Beanpublic SqlSessionFactory sqlSessionFactoryTwo(@Qualifier("dataSourceTwo") DataSource dataSource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);//如果重写了 SqlSessionFactory 需要在初始化的时候手动将 mapper 地址 set到 factory 中，否则会报错：//org.apache.ibatis.binding.BindingException: Invalid bound statement (not found)bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapper_location));return bean.getObject();}@Beanpublic SqlSessionTemplate sqlSessionTemplateTwo(@Qualifier("sqlSessionFactoryTwo") SqlSessionFactory sqlSessionFactory) {SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory);return template;}/*** 为选中的数据源 dataSourceTwo 添加事务管理* @param dataSource* @return*/@Beanpublic DataSourceTransactionManager transactionManagerTwo(@Qualifier("dataSourceTwo") DataSource dataSource){return new DataSourceTransactionManager(dataSource);}}
注意事项：
两个数据源各自的 @ConfigurationProperties 中的 prefix 需要和配置文件中的一致。mapperScan 中扫描 mapper 接口的路径需要和各自接口的路径一致，sqlSessionTemplateRef 的值需要和各自配置类中实例化的 sqlSessionTemplate 实例名一样，如果没有指定实例名，那么默认就是方法名多数据源必须要使用 @Primary 指定一个主数据源因为我们手动创建了 SqlSessionFactory实例，所以需要将 mapper 文件的地址和 mybatis 配置文件的地址手动添加到 sqlSessionFactory 实例中去，这点是特别需要注意的，要不后面访问数据库的时候会报错：Invalid bound statement (not found)，另外：mapper文件必须在各自数据源中都要配置，但是mybatis配置文件只需要在一个里面配置就可以。多数据源访问的时候，访问主数据源只会初始化主数据源，访问非主数据源的话，会将主数据源一并初始化。因为有两个数据源，所以需要分别配置两个事务管理器来管理相应的事务，这样的话@Transactional就需要添加value属性分别应用不同的事务管理器来管理事务。例如@Transactional(value="transactionManagerOne") 和@Transactional(value="transactionManagerTwo")
三：编写代码
在 mapper 文件夹 one 和 two 包下创建个各自的mapper接口，注意和 mapper.xml中 namespace 对应起来，编写各自的service 和 serviceImpl 以及controller，最终目录如下：
四：启动项目进行测试：
@SpringBootApplicationpublic class SpringbootMybatisApplication implements CommandLineRunner{@Autowired@Qualifier("datasourceOne")private DataSource dataSource;public static void main(String[] args) {SpringApplication.run(SpringbootMybatisApplication.class, args);}@Overridepublic void run(String... strings) throws Exception {System.out.println(dataSource);}}
访问不同的mapper接口，自动调用相应的数据源。
五：最后我们登陆到druid监控系统查看，可以看到确实创建了两个数据源：
项目下载：下载地址
因csdn后台会自动修改积分，导致现在积分较高，可以去下面地址免费下载：/KingOfMonkey/springboot-mybatis，喜欢的给个star。
不对之处，希望大家指正。
