【多数据源切换】dynamic-datasource多数据源（动态数据源）使用及案例；多 ...

多数据源（动态数据源）的需求：

• 不同的业务分多个数据库场景，比方一个程序负责n个省份的db操作
  
• 一主多从的读写分离的场景（一主多从可以使用MyBatis插件的方式实现）
  

dynamic-datasource

dynamic-datasource 是一个开源的 Spring Boot 多数据源启动器，提供了丰富的功能，包罗数据源分组、敏感信息加密、独立初始化表结构等。
以下步骤在SpringBoot项目基础上实现：
1. 引入依靠：

1.         <dependency>
2.             <groupId>com.baomidou</groupId>
3.             <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
4.             <version>3.1.0</version>
5.         </dependency>

复制代码

2. 通过yml配置数据源：

默认数据源名为 master，可通过 spring.datasource.dynamic.primary 修改。

1. spring:
2.   datasource:
3.     dynamic:
4.       primary: master #设置默认的数据源或者数据源组,默认值即为master
5.       strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候回抛出异常,不启动会使用默认数据源.
6.       datasource:
7.         master:
8.               url: jdbc:mysql://xxxxa:3449/db1?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=utf8&useSSL=false&&serverTimezone=Asia/Shanghai&&zeroDateTimeBehavior=convertToNull
9.           username: 用户名
10.           password: 密码
11.           driver-class-name: com.mysql.cj.jdbc.Driver
12.         slave_1:
13.           url: jdbc:mysql://xxxxb:3449/db2?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=utf8&useSSL=false&&serverTimezone=Asia/Shanghai&&zeroDateTimeBehavior=convertToNull
14.           username: 用户名
15.           password: 密码
16.           driver-class-name: com.mysql.cj.jdbc.Driver
17.       

复制代码

3. 使用 @DS 切换数据源：

使用 @DS 注解来指定必要切换到的数据源，DS内部填写的值就是yml内里配置的key。
service层内里在想要切换数据源的方法上加上@DS注解就行了，也可以加在整个service层上，方法上的注解优先于类上注解。
注解结果没有@DS默认数据源@DS(“dsName”)dsName可以为组名也可以为具体某个库的名称；数据源名称即yml内里配置的key   本案例读取master数据库中的数据，写入到slave_1数据库的新表中。
  实体类上添加注解@DS("slave_1")指明当前类所使用的数据库。

1. @Data
2. @Accessors(chain = true)
3. @TableName("T_STUDENT")
4. @ApiModel(value="T_STUDENT", description="学生表")
5. @DS("slave_1")
6. public class StudentVerified {
8.     @ApiModelProperty(value = "主键")
9.     @TableField("id")
10.     private Long id;
12.     @ApiModelProperty(value = "姓名")
13.     @TableField("username")
14.     private String username;
16.     @ApiModelProperty(value = "身份证号")
17.     @TableField("idCardNumber")
18.     private String idCardNumber;
20. }

复制代码

假如要使用mybatisplus方法，需直接在Service类上直接添加注解

1. @Service
2. @RequiredArgsConstructor(onConstructor = @__(@Autowired))
3. @DS("slave_1")
4. public class StudentVerifiedServiceImpl extends ServiceImpl<StudentVerifiedMapper, StudentVerified> {
6. }

复制代码

1. public interface StudentVerifiedMapper extends BaseMapper<StudentVerified> {
2. }

复制代码

  使用master主数据源（​​不需做任何操作​​，和之前单数据库一样）
  启动项目时可以看到相关日志输出

4. 在测试方法中实现逻辑

1. @SpringBootTest
2. public class Multidata {
3.     @Autowired
4.     private IBusCertificationService certificationService;
6.     @Autowired
7.     private StudentVerifiedServiceImpl studentVerifiedService;
9.     /**
10.      * 将master的实名认证数据导入到slave的Student表中
11.      */
12.     @Test
13.     void mult(){
14.         List<BusCertification> userCertification = certificationService.list();
15.         List<StudentVerified> studentVerifiedList = new ArrayList<>();
16.         for (BusCertification busCertification : userCertification) {
17.             StudentVerified studentVerified = new StudentVerified();
18.             studentVerified.setId(busCertification.getId());
19.             studentVerified.setUsername(busCertification.getUsername());
20.             studentVerified.setIdCardNumber(busCertification.getIdCardNumber());
21.             studentVerifiedList.add(studentVerified);
22.         }
23.         //此处调用方法时会根据注解切换到slave数据库中
24.         studentVerifiedService.saveBatch(studentVerifiedList);
25.     }
26.    
27. }

复制代码

多数据源项目使用@DS切换数据库在事务中失效问题

假如在同一个方法内分别操作了主从库，而且方法上有事务注解，很有可能会导致从库查询失败。因为加入@Transitional注解后，数据源切换会失效，只会操作主库。
此时需将方法上注解修改为

1. @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
3. public void applyCheck(ApplyCheckPO po) {
4.         //······
5.         //调用从库方法
6. }

复制代码

同时，最好将从库相关操作放置从库serviceImpl的方法中，再由外层调用该方法并try…catch环绕，同时从库该方法上也加上注解

1. @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。