SpringBoot切换数据源

news2025/1/17 21:44:14

基本使用

添加依赖

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

数据源配置

spring:
  datasource:
    dynamic:
      primary: first #设置默认的数据源或者数据源组,默认值即为master
      strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
      datasource:
        first:
          url: jdbc:mysql://localhost:3306/xxx?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&userSSL=false
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: xxx
          password: xxx
        second:
          url: jdbc:mysql://localhost:3306/xxx?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&userSSL=false
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: xxx
          password: xxx

测试源码

@Select("select * from sms_send_bak limit 10")
@DS("second")
//@Transactional(propagation = Propagation.REQUIRES_NEW)
List<SmsSendBak> list();

@DS("first")
//@Transactional(propagation = Propagation.REQUIRES_NEW)
List<Member> queryMemberByRealName(@Param("realName") String realName);

@Override
//@Transactional(propagation = Propagation.REQUIRES_NEW)
public void testService() {
    List<SmsSendBak> smsSendBaks = smsSendBakMapper.list();
    log.info("smsSendBaks: {}", smsSendBaks);
    List<Member> members = memberMapper.queryMemberByRealName("");
    log.info("members: {}", members);
}

spring事务引起数据源切换失效

失效场景

@Transactional
public void fun() {
 //调用数据源A
 //...
 //调用数据源B
 //...
}//结果：全部调了默认数据源A

原因分析

经查明资料，@Transactional开启会使用默认数据源。事务内切换数据源失效是因为spring检测到事务开启，会将Connection缓存起来，执行每个sql的时候用缓存好的connection，导致数据源切换失效。

解决方案

外层去掉事务，sql独立使用事务（如果一定要事务）;

public void fun() {
    //@Transactional
    //调用数据源A
    //...
    
    //@Transactional
    //调用数据源B
    //...
}

外层使用默认，里层sql事务设置传播行为：@Transactional(propagation = Propagation.REQUIRES_NEW)

@Transactional
public void fun() {
    //@Transactional(propagation = Propagation.REQUIRES_NEW)
    //调用数据源A
    //...
    
    //@Transactional(propagation = Propagation.REQUIRES_NEW)
    //调用数据源B
    //...
}

由于设置REQUIRES_NEW传播行为，使得每个阶段使用独立的事务来处理，不会使用外层的事务，走外层的数据源。

里层事务将外层事务挂起（不使用事务，不走外层数据源）

@Transactional
public void fun() {
    //@Transactional(propagation = Propagation.NOT_SUPPORTED)
    //调用数据源A
    //...
    
    //@Transactional(propagation = Propagation.NOT_SUPPORTED)
    //调用数据源B
    //...
}