多数据源

dynamic-datasource-spring-boot-starter 是一个基于springboot的快速集成多数据源的启动器。这是一个第三方 mybatis 扩展库，与 mybatis-plus 本身无关，属于参与者小锅盖个人发起的项目。和MP结合的很好，而且操作多数据源时使用很方便。所以这里来介绍下使用。

DS文档地址：https://www.kancloud.cn/tracy5546/dynamic-datasource/2398947

文档是收费，基本使用本文档介绍的内容即可。

@DS的使用

1.springboot三板斧之添加依赖

<!-- 动态数据源最新版本 -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>3.5.1</version>
</dependency>

2.springboot三板斧之多数据源配置

# 配置数据源
spring:
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    dynamic:
      # 设置默认的数据源或者数据源组,默认值即为master
      primary: master
      # 严格匹配数据源,默认false.true未匹配到指定数据源时抛异常,false使用默认数据源
      strict: false
      datasource:
        master:
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://masterip:3306/masterdb?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true
          username: root
          password: 123456
        slave:
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://slaveip:3306/slavedb?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai
          username: root
          password: 123456

• 每个数据源都有一个type来指定连接池。

• 每个数据源甚至可以使用不同的连接池，如无特殊需要并不建议。

• type 不是必填字段 ，在没有设置type的时候系统会自动按以下顺序查找并使用连接池。

​ Druid>HikariCp>BeeCp>DBCP2>Spring Basic。

3.使用@DS切换数据源

@DS 可以注解在方法上或类上，同时存在就近原则 方法上注解 优先于 类上注解。

注解	结果
没有@DS	默认数据源
@DS("dsName")	dsName可以为组名也可以为具体某个库的名称

这里一般@DS是注解到serviceImpl的方法上，如事务注解一样。但是当你一个service要操作多个数据源时，

可以把@DS注解到Mapper上。如：

@DS("slave")
@Mapper
public interface NotifyMessageMapper extends BaseMapper<NotifyMessage>  {

}

@DSTransactional的使用

此注解是处理多数据源事务的。这个比seata等在使用上简单很多，只要在方法上加上这个注解，多数据源的数据库操作均能回滚。如下例子：

@Override
@DSTransactional
public void testTransactional() {
    User user = this.userMapper.selectById(5L);
    user.setName(user.getName()+"55555");
    this.userMapper.updateById(user);
    NotifyMessage notifyMessage = this.messageMapper.selectById(315747L);
    notifyMessage.setMessage(notifyMessage.getMessage()+"6666");
    this.messageMapper.updateById(notifyMessage);
    double i = 5/0;
}

注意：

@DSTransactional在@Test方法中不生效的。应该说所有aop的操作在test类中都不生效；springboot中的之所以能支持

@Transactional是做了特殊的处理。

​