Mybatis-Plus+SpringBoot多数据源注解方式@DS

前言

最近接到一个新需求需要处理多数据源的问题，今天就来和大家一起学习一下。

一、使用步骤

1.引入库

代码如下（示例）：

  <!--配置多数据源--><dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>3.5.0</version></dependency>

2.Springboot的application.yml中进行配置

代码如下（示例）：

  datasource:dynamic:primary: master #设置默认的数据源或者数据源组,默认值即为masterstrict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源datasource:master:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://xxx:3306/demo?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true&allowPublicKeyRetrieval=trueusername: xxxpassword: xxxtest:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://xxx2:3306/test?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true&allowPublicKeyRetrieval=trueusername: xxxpassword: xxx

配置了两个数据源，master与test，其中选择master作为默认数据源（对应primary（主要的）配置）；

3. ServiceImpl层注解使用实例，可以注解在方法上或类上

1.类上注解

@Service
@Slf4j
@DS("test")//使用test数据源
public class TestServiceImpl implements TestService {@Resourceprivate TestMapper testMapper;@Overridepublic Integer saveTest(Test test) {return testMapper.insertTest(test);}
}

2.方法上注解（mapper上面也需要注解）

@Service
@Slf4j
public class TestServiceImpl implements TestService {@Resourceprivate TestMapper testMapper;@Override@DS("test")//使用test数据源public Integer saveTest(Test test) {return testMapper.insertTest(test);}
}

4. 配置启动类

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})

@EnableScheduling
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class Application {public static void main(String[] args) {SinoApplication.single(ModuleInfo.ModuleName, Application.class, args);}
}

5. 配置Dockerfile文件

   "-Dspring.datasource.dynamic.enabled=true",\

失效场景解决方案
使用动态数据源（@DS）时，@Transactional使用可能会照成@DS失效。
解决方案：

1.去掉事务（不建议）
2.@DS切换数据源的方法添加事务传播属性@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
3.去掉@DS切换数据源方法的事务，主方法用@DSTransactional注解。