springboot多数据源配置(springboot多数据源配置和切换苞米豆)

dynamic-datasource-spring-boot-starter多数据源配置

1、pom文件

2、配置文件

如果选择druid链接池要去除druid配置；还要配置一个默认数据源（spring.datasource.dynamic.primary）

3、数据源切换

当一个SpringBoot项目在配置了多个数据源,在编写Service层方法的时候,直接在service方法的上添加的@Transactional直接实现事务管理的方式是失效的.

以最近接触到的一个持久层框架使用的是Jpa的项目为例,该项目通过硬编码(配置类)的方式,在项目中配置了两个不同的数据源,所以这个项目分别根据两个数据源配置了各自的事务管理器PlatformTransactionManager,如下:

第一个数据源的事务管理器配置类:

第二个数据源事务管理器配置类:

可以看到第二个事务管理器的Bean方法上添加了@Primary注解,所以在通过PlatformTransactionManager类型注入事务管理器的bean时,默认是根据类型去注入,如果该类型有多个Bean,如不通过bean的名字去注入,则默认是会注入被@Primary标识的bean的;

所以在这个项目中,当在业务层方法添加@Transactional注解时,默认是调用了transactionManagerTwo这个bean,而我在编写service层的方法时,调用的是第一个数据源对应的Dao层方法,所以直接添加@Transactional是不能实现事务管理的,

需要在使用@Transactional注解时指定使用的事务管理器的bean的名字,比如我这里调用的是第一个数据源的dao层方法,所以需要指定对应的事务管理器:@Transactional(transactionManager="transactionManagerOne").

这里要排除DruidDataSourceAutoConfigure，因为DruidDataSourceAutoConfigure会注入一个DataSourceWrapper，其会在原生的spring.datasource下找url,username,password等。而我们动态数据源的配置路径是变化的。

@DS优先级：方法类

@DS可以注解在方法上和类上，同时存在方法注解优先于类上注解,mapper或者service都可以添加，建议只在一个方法上添加即可。

1、创建一个datasource包，新建DataSource1，DataSource2两个文件，通过注解来配置数据源

DataSource1：

DataSource2：

2、在application.properties文件配置两个数据源

3、两个测试的ServiceMapper

4、Controller调用

一个项目中使用多个数据源的需求，我们在日常工作中时常会遇到。

以商城系统为例，有一个MySQL的数据库负责存储交易数据。公司还有一套ERP企业信息化管理系统，要求订单信息同步录入ERP数据库，便于公司统一管理，而该ERP系统采用的数据库为SQLServer。

此时，就可以在SpringBoot项目中配置多个数据源。另外，使用多数据源后，需要采用分布式事务来保持数据的完整性。

本小节我们使用SpringBoot开发一个商城系统的订单生成功能，订单信息同时进入MySQL与SQLServer数据库。

首先创建MySQL数据库shop，并新建订单表order，表结构如下：

order表结构

然后创建SQLServer数据库erpshop，并新建订单表erp_order，表结构如下。注意id是自增长的唯一标识，out_id是对应订单在MySQL数据库中的唯一标识，以便在两个库中比对订单。

erp_order结构

接下来，我们开始实现SpringBoot后端项目，数据持久层采用MyBatis框架，同时访问两个数据源。

SpringBoot版本选择2.2.5，Group为com.imooc，Artifact为spring-boot-multidb，生成项目后导入Eclipse开发环境。

我们引入热部署依赖、Web依赖、数据库访问相关依赖及测试相关依赖，具体如下：

实例：

由于我们要同时访问两个数据库，所以需要在配置文件中添加两个数据源的配置信息。注意配置多数据源时，url配置需要使用spring.datasource.db1.jdbc-url=xxx的形式。

实例：

多个数据源的情况下，我们需要通过配置类，将数据源注册为组件放入Spring容器中。

实例：

通过这个配置类，Spring容器中就有两个数据源组件，这两个组件分别采用spring.datasource.db1和spring.datasource.db2开头的配置信息。所以通过这两个组件，就能分别操作MySQL数据源1和SQLSever数据源2。

多数据源情况下，MyBatis中的关键组件SqlSessionFactory和SqlSessionTemplate也需要单独配置，我们需要为两个数据源分别配置一套组件。

实例：

通过上面的配置类，com.imooc.springbootmultidb.mapper1包中的DAO数据访问接口会自动调用sqlSessionTemplate1组件实现具体数据库操作，而sqlSessionTemplate1操作的数据源已经通过配置类设置为db1。同时，DAO数据访问接口对应的映射文件已经指定到classpath:mapper1/目录去寻找。这样数据源–DAO数据访问接口–映射文件三者的对应关系就建立起来了。

数据源2的配置方法是一样的，com.imooc.springbootmultidb.mapper2包中的DAO数据访问接口会自动调用sqlSessionTemplate2组件，其操作的数据源即为db2，其对应的映射文件指定到classpath:mapper2/目录去寻找。

实例：

数据访问接口的位置已经在配置类指定，首先在com.imooc.springbootmultidb.mapper1创建OrderDao，操作的是数据源1中的order表。

实例：

然后在com.imooc.springbootmultidb.mapper2创建ErpOrderDao，操作的是数据源2中的erporder表。

实例：

这两个接口中使用的数据对象比较简单，代码如下：

实例：

分别针对OrderDao、ErpOrderDao编写对应的映射文件，然后按照配置类指定的位置，两个文件分别放到resources/mapper1和resources/mapper2目录下。

实例：

实例：

数据操作接口与对应的映射文件均已编写完毕，现在可以通过测试类进行多数据源测试了，我们在测试类中同时向两个库插入记录。

实例：

运行测试方法后，两个数据库表中均新增数据成功，这样我们就成功的使用SpringBoot同时操作了两个数据源。

采用多数据源之后，事务的实现方式也随之发生变化。当某个数据源操作出现异常时，该数据源和其他数据源的事务都需要回滚。这种涉及多个数据源的事务，称为分布式事务，接来下我们就来具体实现一下。

在pom.xml引入Atomikos事务管理器相关的依赖项，Atomikos是一个开源的事务管理器，支持分布式事务。

实例：

需要将默认的数据源更换为支持分布式事务的数据源，MySQL对应的数据源为MysqlXADataSource，SQLServer对应的数据源为SQLServerXADataSource。

实例：

继续修改DataSourceConfig类，在其中配置分布式事务管理器组件。当项目中使用事务时，会通过配置的分布式事务管理器管理分布式事务操作。

实例：

在测试方法上添加@Transactional开启事务，然后在两个数据源操作中间模拟抛出异常。

实例：

此时运行测试类，可以发现数据源1的事务已回滚，验证成功！

在开发SpringBoot项目时，如果默认配置满足不了我们的需求，可以通过手工配置组件实现我们需要的功能。这些组件可能是各个公司提供的，我们根据相应文档，为其配置各个属性即可。