sprintboot + mybatis plus + dynamic-datasource 多数据切换以及保证多数据源的事务的一致性

左手的ㄟ右手 2023-10-15 20:18 6阅读 0赞

# 前言： #

>  **这个项目是一个单体项目，并没有涉及到分布式事务，需求也比较直接，就是在一个请求方法里面，同时查询两个数据库的数据，并且往两个数据库插入数据的时候，要保证事务的一致性**

# **1.多数据源依赖** #

>     <dependency>
>                 <groupId>com.baomidou</groupId>
>                 <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
>                 <version>3.3.5</version>
>             </dependency>

# 2.配置文件 #

>     
>     
>     server:
>       port: 8080
>     
>     spring:
>       datasource:
>         dynamic:
>           primary: master #设置默认的数据源或者数据源组,默认值即为master
>           strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
>           datasource:
>             master:
>               url: xxx
>               username: xxx
>               password: xxx
>               driver-class-name: com.mysql.cj.jdbc.Driver
>               druid:
>                 pool-prepared-statements: true
>                 max-pool-prepared-statement-per-connection-size: 20
>                 validation-query: SELECT 1 FROM DUAL
>                 test-on-borrow: false
>                 test-on-return: false
>                 test-while-idle: true
>                 time-between-eviction-runs-millis: 60000000
>                 filters: stat,wall
>             slave_1:
>               url: xxx
>               username: xxx
>               password: xxx
>               driver-class-name: com.mysql.cj.jdbc.Driver
>               druid:
>                 pool-prepared-statements: true
>                 max-pool-prepared-statement-per-connection-size: 20
>                 validation-query: SELECT 1 FROM DUAL
>                 test-on-borrow: false
>                 test-on-return: false
>                 test-while-idle: true
>                 time-between-eviction-runs-millis: 60000000
>                 filters: stat,wall
>     
>     
>     
>     
> 
> **注意：配置文件中的 master 是主要的数据源，slave\_1 是从数据源（说是从数据源而已，实际上我这个项目并没有主从复制，读写分离这些，实际上就是另外的一个数据源）**

# 3.项目结构： #

> ![dad8f6a1d84441a9a11e3035af4f569c.png][]
> 
>   
> **nk\_jewel\_applet 数据库 用的是 数master 的据源：Test1Model 对应 nk\_jewel\_applet里 里面的 test1 表**
> 
> **而 nk\_product\_pro 数据库 用的是 slave\_1 的数据源：Test2Model 对应 nk\_product\_pro 里面的 test2 表**
> 
> **对应关系：**  
>  **master ------> nk\_jewel\_applet ------> Test1Model** 
> 
>  **slave\_1 ------> nk\_product\_pro ------> Test2Model**  
>

# 4.@DS注解（重点） #

>  **@DS 注解是用于切换数据源的，可用于指定的类用的是那一个数据源，可用于mapper接口的类上，也可以用于service的实现类上，也可以用于service的实现类的方法上，如下图：**
> 
>  *  **用于mapp接口：**
> 
> ![25af2229d9044942bd4c5d7bfe1b6ba9.png][]
> 
>  *  **用于service的实现类：**
> 
> ![be6fb01bece74c96908ecb5515ce9df8.png][]
> 
>  *  **用于service的实现类中的方法：**
> 
> **这个往下看，会讲解到的  
>   
>   
> 注意：@DS的本质就是通过aop去实现的**

# **5.测试** #

>  **先把 @DS("slave\_1") 注解写到 Test2Mapper 以及 Test2ServiceImpl 的类上先（表示这两个类中的所有请求数据库的操作，都会被切换成 'slave\_1' 数据源中的数据库 ），例如：**  
> ![f7b944405f2744cbb838187e6675223d.png][]
> 
>   
> ![12c51db0fde14c06ad80ddb8a9e49c54.png][]
> 
>  *  **表中的数据：**
> 
> ![828b2a696dae4f699f50d35fb75ddb1c.png][]  
>   
> ![3e0423d036d54757822e3216d4237895.png][]

*  # 在同一个请求中，获取到两个表的数据 #

> ![b848dcb23a174e66afe82bfdde678f35.png][]
> 
>   
> **对应的service：**  
> ![f3c7bd8e1bf54524927939bcd5a85f26.png][]  
>   
>   
> **发请求：**  
> ![0e19f946bd1e4cd28d583798ac976dd2.png][]  
>   
> **可以看到已经成功了各自的数据**

*  # 在同一个请求中，对两个数据库同时插入数据，并查询出来： #

> ![079db960c1494c5c81a5de3582ec6320.png][]  
>   
>   
> **对应的service：**  
> ![5dcc40a89a0f41809e04c82fb610794e.png][]  
>   
> **请求：**  
> ![5416f4fc70f94d0fa896491076f7d96d.png][]

*  # 保证多数据原的事务一致性（@DSTransactional注解） #

>  **还是上面的添加例子，只要加入 @DSTransactional 注解，即可保证事务的一致性**
> 
>   
> **修改了以下代码：**
> 
> ![e88e6ad8e753491e9f1799952fd90792.png][]
> 
>   
> **执行代码：**  
> ![d7d250e7e8144c9b887790879cf47d52.png][]
> 
> **可以看到报错了，然后去看下数据库，test1 表是否有添加数据**  
>   
> ![db7d0f4407b8450abbfff0a754a26295.png][]
> 
> **test1 表并没有插入数据，说明多数据事务已经成功**

#  #

[dad8f6a1d84441a9a11e3035af4f569c.png]: https://img-blog.csdnimg.cn/dad8f6a1d84441a9a11e3035af4f569c.png
[25af2229d9044942bd4c5d7bfe1b6ba9.png]: https://img-blog.csdnimg.cn/25af2229d9044942bd4c5d7bfe1b6ba9.png
[be6fb01bece74c96908ecb5515ce9df8.png]: https://img-blog.csdnimg.cn/be6fb01bece74c96908ecb5515ce9df8.png
[f7b944405f2744cbb838187e6675223d.png]: https://img-blog.csdnimg.cn/f7b944405f2744cbb838187e6675223d.png
[12c51db0fde14c06ad80ddb8a9e49c54.png]: https://img-blog.csdnimg.cn/12c51db0fde14c06ad80ddb8a9e49c54.png
[828b2a696dae4f699f50d35fb75ddb1c.png]: https://img-blog.csdnimg.cn/828b2a696dae4f699f50d35fb75ddb1c.png
[3e0423d036d54757822e3216d4237895.png]: https://img-blog.csdnimg.cn/3e0423d036d54757822e3216d4237895.png
[b848dcb23a174e66afe82bfdde678f35.png]: https://img-blog.csdnimg.cn/b848dcb23a174e66afe82bfdde678f35.png
[f3c7bd8e1bf54524927939bcd5a85f26.png]: https://img-blog.csdnimg.cn/f3c7bd8e1bf54524927939bcd5a85f26.png
[0e19f946bd1e4cd28d583798ac976dd2.png]: https://img-blog.csdnimg.cn/0e19f946bd1e4cd28d583798ac976dd2.png
[079db960c1494c5c81a5de3582ec6320.png]: https://img-blog.csdnimg.cn/079db960c1494c5c81a5de3582ec6320.png
[5dcc40a89a0f41809e04c82fb610794e.png]: https://img-blog.csdnimg.cn/5dcc40a89a0f41809e04c82fb610794e.png
[5416f4fc70f94d0fa896491076f7d96d.png]: https://img-blog.csdnimg.cn/5416f4fc70f94d0fa896491076f7d96d.png
[e88e6ad8e753491e9f1799952fd90792.png]: https://img-blog.csdnimg.cn/e88e6ad8e753491e9f1799952fd90792.png
[d7d250e7e8144c9b887790879cf47d52.png]: https://img-blog.csdnimg.cn/d7d250e7e8144c9b887790879cf47d52.png
[db7d0f4407b8450abbfff0a754a26295.png]: https://img-blog.csdnimg.cn/db7d0f4407b8450abbfff0a754a26295.png