【多数据源动态切换】Spring Boot中实现多数据源动态切换效果（1）：通过继承AbstractRoutingDataSource类实现

男娘i 2024-03-31 17:41 23阅读 0赞

在Spring Boot中，可以通过多种方式实现多数据源的动态切换效果，本篇介绍第一种实现方案。

## 一 AbstractRoutingDataSource ##

`Spring Boot`提供了`org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource` 这个类，其中`#determineCurrentLookupKey`方法可以让用户根据自己定义的规则在某一个SQL执行之前动态地选择想要的数据源。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> /** * Determine the current lookup key. This will typically be * implemented to check a thread-bound transaction context. * &lt;p&gt;Allows for arbitrary keys. The returned key needs * to match the stored lookup key type, as resolved by the * {@link #resolveSpecifiedLookupKey} method. */ @Nullable protected abstract Object determineCurrentLookupKey(); </td> 
 </tr> 
 </tbody> 
</table>

因此，我们的整体实现逻辑就很清晰了，具体分为以下几个步骤：

1.  定义`DynamicRoutingDataSource`类，继承`AbstractRoutingDataSource`类并实现`#determineCurrentLookupKey`方法（具体逻辑是从当前线程的`ThreadLocal`中获取我们在某一个SQL执行之前通过AOP切面动态指定的数据源名称）；
2.  在`application.yml`中配置多个数据源；
3.  解析在`application.yml`中配置的多个数据源，然后生成`DynamicRoutingDataSource`实例，并设置默认数据源（`defaultTargetDataSource`）和其他数据源（`targetDataSources`）；
4.  调用`AbstractRoutingDataSource`的`#getConnection`的方法的时候，会先调用`#determineTargetDataSource`方法获取具体的数据源，而在这个方法中会进一步调用我们在`DynamicRoutingDataSource`类中自定义的`#determineCurrentLookupKey`方法，最后在返回`DataSource`后再进行`#getConnection`的调用。显然，剩下就是具体的SQL逻辑执行了。

## 二 具体实现 ##

### （1）测试使用的数据库 ###

这里我们创建3个数据库，分别是：`db01`、`db02`、`db03`，然后这3个数据库都有一张名为`user_info`的表，表结构一样，只是数据不同。

### （2）动态切换数据源的上下文 ###

### （3）定义`DynamicRoutingDataSource`类 ###

主要是继承`AbstractRoutingDataSource`类并实现`#determineCurrentLookupKey`方法，其具体逻辑是从当前线程的`ThreadLocal`中获取我们在某一个SQL执行之前通过AOP切面动态指定的数据源名称。

### （4）新增`application-datasource.yml`配置文件 ###

新建这个用于测试的配置文件，主要配置了接下来需要用到的多个数据源，其关键配置如下：

### （5）解析在`application-datasource.yml`中配置的多个数据源 ###

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 </td> 
 <td> package cn.zifangsky.example.webexercise.dataSource; import com.zaxxer.hikari.HikariDataSource; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.MutablePropertyValues; import org.springframework.beans.factory.support.BeanDefinitionRegistry; import org.springframework.beans.factory.support.GenericBeanDefinition; import org.springframework.boot.context.properties.bind.Bindable; import org.springframework.boot.context.properties.bind.Binder; import org.springframework.boot.context.properties.source.ConfigurationPropertyName; import org.springframework.boot.context.properties.source.ConfigurationPropertyNameAliases; import org.springframework.boot.context.properties.source.MapConfigurationPropertySource; import org.springframework.context.EnvironmentAware; import org.springframework.context.annotation.ImportBeanDefinitionRegistrar; import org.springframework.core.env.Environment; import org.springframework.core.type.AnnotationMetadata; import org.springframework.util.StringUtils; import javax.sql.DataSource; import java.util.HashMap; import java.util.List; import java.util.Map; /** * 动态数据源注册 * &lt;p&gt;实现{@link <a href="mailto:" rel="nofollow">[email&nbsp;protected]</a>�&lt;/p&gt; * &lt;p&gt;实现{@link EnvironmentAware}目的是读取 application-datasource.yml 配置&lt;/p&gt; * */ @Slf4j public class DynamicDataSourceRegister implements ImportBeanDefinitionRegistrar, EnvironmentAware { &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp; * 别名 &nbsp;&nbsp;&nbsp;&nbsp; */ &nbsp;&nbsp;&nbsp;&nbsp;private final static ConfigurationPropertyNameAliases ALIASES = new ConfigurationPropertyNameAliases(); &nbsp;&nbsp;&nbsp;&nbsp;//由于部分数据源配置不同，所以在此处添加别名，避免切换数据源出现某些参数无法注入的情况 &nbsp;&nbsp;&nbsp;&nbsp;static { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ALIASES.addAliases("url", "jdbc-url"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ALIASES.addAliases("username", "user"); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp; * 参数绑定工具 &nbsp;&nbsp;&nbsp;&nbsp; */ &nbsp;&nbsp;&nbsp;&nbsp;private Binder binder; &nbsp;&nbsp;&nbsp;&nbsp;@Override &nbsp;&nbsp;&nbsp;&nbsp;public void setEnvironment(Environment environment) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;this.binder = Binder.get(environment); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;@Override &nbsp;&nbsp;&nbsp;&nbsp;public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.info("开始注册多个数据源"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//1. 注册默认数据源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//1.1 获取默认数据源参数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Map defaultDataSourceProperties = this.binder.bind("spring.datasource.master", Map.class).get(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//1.2 获取默认数据源类型 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String defaultDataSourceType = defaultDataSourceProperties.get("type").toString(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Class&lt;? extends DataSource&gt; defaultDataSourceClazz = this.getDataSourceType(defaultDataSourceType); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//1.3 绑定默认数据源参数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DataSource defaultDataSource = this.bind(defaultDataSourceClazz, defaultDataSourceProperties); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//1.4 将其添加到「动态切换数据源的上下文」中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DynamicDataSourceContext.addDataSourceKey("master", true); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.info("注册默认数据源「master」成功"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//2. 注册其他数据源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Map&lt;String, DataSource&gt; targetDataSources = new HashMap&lt;&gt;(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;List&lt;Map&gt; slaveDataSourcePropertiesList = this.binder.bind("spring.datasource.cluster", Bindable.listOf(Map.class)).get(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(slaveDataSourcePropertiesList != null &amp;&amp; slaveDataSourcePropertiesList.size() &gt; 0){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//2.1 获取某一数据源参数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;for(Map dataSourceProperties : slaveDataSourcePropertiesList){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//2.2 获取数据源类型 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String dataSourceType = dataSourceProperties.get("type").toString(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Class&lt;? extends DataSource&gt; dataSourceClazz = this.getDataSourceType(dataSourceType); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//2.3 绑定数据源参数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DataSource dataSource = this.bind(dataSourceClazz, dataSourceProperties); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//2.4 获取数据源的KEY，并将其添加到「动态切换数据源的上下文」和「targetDataSources」中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String dataSourceKey = dataSourceProperties.get("key").toString(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DynamicDataSourceContext.addDataSourceKey(dataSourceKey, false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;targetDataSources.put(dataSourceKey, dataSource); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.info("注册数据源「{}」成功", dataSourceKey); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//3. 实例化 DynamicRoutingDataSource Bean &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//3.1 bean定义 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;GenericBeanDefinition definition = new GenericBeanDefinition(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;definition.setBeanClass(DynamicRoutingDataSource.class); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//3.2 注入需要的参数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;MutablePropertyValues propertyValues = definition.getPropertyValues(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;propertyValues.add("defaultTargetDataSource", defaultDataSource); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;propertyValues.add("targetDataSources", targetDataSources); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//3.3 将该bean注册为datasource，不使用springboot自动生成的datasource &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;registry.registerBeanDefinition("datasource", definition); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.info("注册数据源成功，一共注册「{}」个数据源", targetDataSources.keySet().size() + 1); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp; * 通过数据源字符串获取数据源Class对象 &nbsp;&nbsp;&nbsp;&nbsp; */ &nbsp;&nbsp;&nbsp;&nbsp;private Class&lt;? extends DataSource&gt; getDataSourceType(String dataSourceType){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Class&lt;? extends DataSource&gt; type; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(!StringUtils.isEmpty(dataSourceType)){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果字符串不为空，则通过反射获取class对象 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;type = (Class&lt;? extends DataSource&gt;) Class.forName(dataSourceType); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}else { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//否则设置为默认的 HikariCP 连接池 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;type = HikariDataSource.class; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return type; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} catch (Exception e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;throw new IllegalArgumentException("can not resolve class with type: " + dataSourceType); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp; * 通过类型绑定参数并获得实例对象 &nbsp;&nbsp;&nbsp;&nbsp; */ &nbsp;&nbsp;&nbsp;&nbsp;private &lt;T extends DataSource&gt; T bind(Class&lt;T&gt; clazz, Map properties){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;MapConfigurationPropertySource propertySource = new MapConfigurationPropertySource(properties); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Binder binder = new Binder(propertySource.withAliases(ALIASES)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//通过类型绑定参数并获得实例对象 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return binder.bind(ConfigurationPropertyName.EMPTY, Bindable.of(clazz)).get(); &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

### （6）通过`AOP+注解`实现数据源的动态切换 ###

i）在`pom.xml`文件中添加切面需要的依赖：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 </td> 
 <td> &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;groupId&gt;org.springframework.boot&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;artifactId&gt;spring-boot-starter-aop&lt;/artifactId&gt; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

ii）新增一个用于切换数据源的注解：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 </td> 
 <td> package cn.zifangsky.example.webexercise.dataSource; import java.lang.annotation.*; /** * 用于动态切换数据源的注解（优先级：方法级别 &gt; 类级别） */ @Target({ElementType.METHOD, ElementType.TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface DataSource { &nbsp;&nbsp;&nbsp;&nbsp;String value() default "master"; } </td> 
 </tr> 
 </tbody> 
</table>

iii）定义一个AOP的通知类：

iv）定义一个`Advisor`，将通知注入到指定的切点：

v）导入上面的数据源配置，以及启动切面：

## 三 效果测试 ##

### （1）新建两个测试使用的Mapper ###

`UserInfoMapper`为插件自动生成，没有添加我们自定义的`@DataSource`注解，用于测试不添加注解的情况下默认使用的数据源。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 </td> 
 <td> package cn.zifangsky.example.webexercise.mapper; import cn.zifangsky.example.webexercise.model.UserInfo; public interface UserInfoMapper { &nbsp;&nbsp;&nbsp;&nbsp;int deleteByPrimaryKey(Integer id); &nbsp;&nbsp;&nbsp;&nbsp;int insert(UserInfo record); &nbsp;&nbsp;&nbsp;&nbsp;int insertSelective(UserInfo record); &nbsp;&nbsp;&nbsp;&nbsp;UserInfo selectByPrimaryKey(Integer id); &nbsp;&nbsp;&nbsp;&nbsp;int updateByPrimaryKeySelective(UserInfo record); &nbsp;&nbsp;&nbsp;&nbsp;int updateByPrimaryKey(UserInfo record); } </td> 
 </tr> 
 </tbody> 
</table>

`UserInfoDynamicMapper`为手动新建的几个方法，用于测试数据源的动态切换效果。

其对应的`UserInfoDynamicMapper.xml`文件是：

### （2）使用单元测试测试「动态切换数据源」的效果 ###

> 注：以上测试代码基于Junit5 测试框架编写，需要的依赖如下：
> 
> <table> 
> <tbody> 
> <tr> 
> <td> 1 2 3 4 5 6 7 8 9 10 11 </td> 
> <td> &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;groupId&gt;org.springframework.boot&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;artifactId&gt;spring-boot-starter-test&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;scope&gt;test&lt;/scope&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;exclusions&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;exclusion&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;groupId&gt;org.junit.vintage&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;artifactId&gt;junit-vintage-engine&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/exclusion&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;/exclusions&gt; &lt;/dependency&gt; </td> 
> </tr> 
> </tbody> 
> </table>

运行单元测试后，测试效果如下：

![b6e2b37fe8b745fd88d2e9abed46a8a7.png][]

可以发现，除了最后手动抛出一个异常的方法，其他几个方法都测试通过了。然后，通过查询数据库中的数据还可以发现，事务做了我们预期效果的回滚，因此本篇文章介绍的「多数据源动态切换」方案是可行的。

[b6e2b37fe8b745fd88d2e9abed46a8a7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/31/414475992c1043c3974951bef86b3c47.png