SpringBoot+MyBatis-Plus多数据源@DS注解失效的解决方法

SpringBoot+MyBatis-Plus多数据源@DS失效的解决方法

  • 多数据源的使用
    • 失效场景
    • 解决方法

多数据源的使用

引入 dynamic-datasource:

        
            com.baomidou
            dynamic-datasource-spring-boot-starter
            3.3.2
        

application.yml 数据源配置:

spring:
  datasource:
    dynamic:
      primary: master #设置默认的数据源或者数据源组,默认值即为master
      strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
      datasource:
        master:
          url: jdbc:postgresql://ip:port,ip2:port2/rwddb?binaryTransfer=False&forceBinary=False&reWriteBatchedInserts=true&loadBalanceHosts=true&targetServerType=master
          username: ***
          password: ****
          driver-class-name: org.postgresql.Driver
        slave_1:
          url: jdbc:postgresql://ip:port,ip2:port/rwddb?binaryTransfer=False&forceBinary=False&reWriteBatchedInserts=true&loadBalanceHosts=true&targetServerType=master
          username: ****
          password: ***
          driver-class-name: org.postgresql.Driver

详细使用请看 MyBatis-Plus官网

失效场景

这种场景还是比较常见,比如在一个为master数据源的调用slave数据源就会失效

  • slave数据源Service方法
    @DS("slave_1") //切换数据源
    @Override
    public boolean update(User user) {
        UserMapper.update(user);
        return true;
    }
  • mater数据源Service方法调用slave数据源Service方法
    @Override
    public boolean save(User user) {
    	this.saveBatch(user.getRoles());//没有指定数据源,走primary配置的数据源master
        userService.update(user);//走从数据源
        ...
        return true;
    }

这里会出现没有走slave_1,依然还是master数据源

解决方法

需要在salve数据源上另起一个事务,比如:

	@DS("slave_1") //切换数据源
	@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
    @Override
    public boolean update(User user) {
        UserMapper.update(user);
        return true;
    }

本文来自网络,不代表协通编程立场,如若转载,请注明出处:https://net2asp.com/a9517e09e8.html