Spring Boot多数据源事务@DSTransactional的使用

ゝ一纸荒年。 2023-10-09 17:41 8阅读 0赞

## 项目场景： ##

`Spring Boot`集成com.baomidou，引入dynamic-datasource依赖，实现多数据源，这里说下事务问题：

1、一个方法中使用同一个数据源；

2、一个方法中使用了多个数据源；

--------------------

## 解决方案： ##

> 这里把dao、service列出来

#### 1、dao层 ####

package com.test.mapper;
    
    import com.baomidou.dynamic.datasource.annotation.DS;
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Param;
    import org.apache.ibatis.annotations.Update;
    
    //数据源1
    @DS("db1")
    @Mapper
    public interface Test1Dao {
    	@Update("update test1 set name = #{name} where id = #{id}")
    	void updateById(@Param("id")Integer id, @Param("name")String name);
    }

package com.test.mapper;
    
    import com.baomidou.dynamic.datasource.annotation.DS;
    import com.test.datasources.DataSourceNames;
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Param;
    import org.apache.ibatis.annotations.Update;
    
    //数据源2
    @DS(“db2”)
    @Mapper
    public interface Test2Dao {
    	@Update("update test2 set name = #{name} where id = #{id}")
    	void updateById(@Param("id")Integer id, @Param("name")String name);
    }

#### 2、service层 ####

package com.test.service;
    
    import com.baomidou.dynamic.datasource.annotation.DS;
    import com.baomidou.dynamic.datasource.annotation.DSTransactional;
    import com.test.mapper.Test1Dao;
    import com.test.mapper.Test2Dao;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    @Service
    public class TestService {
    
        @Autowired
        private Test1Dao test1Dao;
        @Autowired
        private Test2Dao test2Dao;
        /**
         * 同一个数据源中的事务，都是数据源2
         * 这里用的是spring的事务注解Transactional
         * 这里必须加上注解多数据源注解@DS("db2")，否则使用的是默认数据源
         */
        @DS("db2")
        @Transactional
        public void theSame() {
            test2Dao.updateById(2,"第一次修改");
            test2Dao.updateById(2,"第二次修改");
            //这里报错回滚
            int i = 1/0;
        }
    
        /**
         * 多数据源中的事务，同时使用数据源1、2
         * 如果这里用spring的事务注解Transactional，那么使用的是默认数据源
         * 这里不需要加上注解@DS
         */
        @DSTransactional
        public void notAlike() {
            test1Dao.updateById(1,"第一次修改");
            test2Dao.updateById(2,"第二次修改");
            //这里报错回滚
            int i = 1/0;
        }
    }

spring boot实现多数据源：[Spring Boot集成Druid实现多数据源的两种方式\_涛哥是个大帅比的博客-CSDN博客][Spring Boot_Druid_-CSDN]

[Spring Boot_Druid_-CSDN]: https://blog.csdn.net/u011974797/article/details/130109195