Seata集成Mybatis-Plus解决多数据源事务问题

Seata整合Mybatis-Plus来处理多数据源事务问题，主要是通过以下几个步骤实现的：

1. 安装Mybatis-Plus与Seata插件：
确保你的Mybatis-Plus版本支持Seata插件。可以在`mybatis-plus-generator`的`pom.xml`或`build.gradle`文件中添加Seata的Mybatis-Plus插件依赖。

对于Maven：

<dependency>
    <groupId>com.baomidou.mybatisplus.extension</groupId>
    <artifactId>mybatis-plus-extension-boot-starter</artifactId>
    <!-- Add this if using with Seata -->
    <exclusions>
        <exclusion>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata-mybatisplus</artifactId>
</dependency>

对于Gradle：

implementation 'com.baomidou.mybatisplus.extension:mybatis-plus-extension-boot-starter'
implementation 'com.alibaba.cloud:spring-cloud-starter-alibaba-seata-mybatisplus'

2. 配置数据源和Seata：
在Spring Boot的配置文件中（通常是`application.properties`或`application.yml`），继续配置多个数据源以及Seata的相关参数，如RMS地址等。

3. 注册数据源工厂：
创建一个数据源工厂类，用于根据不同业务场景选择对应的数据源：

@Configuration
public class MultiDataSourceConfig {

    @Value("${spring.datasource.type}")
    private String dataSourceType;

    @Bean
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.${dataSourceType}.")
    public DataSource masterDataSource() {
        // ... 实例化主数据源
    }

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.secondary.")
    public DataSource secondaryDataSource() {
        // ... 实例化从数据源
    }

    @Bean
    public DataSourceSelector dataSourceSelector() {
        return () -> {
            DataSourceContextHolder.setDataSource(dataSourceType);
            return dataSourceType.equals("primary") ? primaryDataSource() : secondaryDataSource();
        };
    }
}

4. 配置事务管理器：
在`application.yml`或`application.properties`中指定Seata的全局事务管理器（Global Transaction Manager），并启用Mybatis-Plus的分库分表注解支持：

spring:
  cloud:
    alibaba:
      seata:
        global-tran-manager-type: JDBC
        registry-center-config:
          type: NAMESPACE
          address: localhost:9091
  mybatis-plus:
    db-config:
      default-split-sharding-condition-provider-type: TABLE

5. 开始事务：
在Service或Repository层中，使用`@GlobalTransactional`注解启动Seata全局事务，然后在需要操作多数据源的地方插入相应的数据源切换：

@Service
public class MyService {

    @Autowired
    private SeataTemplate seataTemplate;

    @GlobalTransactional(name = "transactionGroup", rollbackFor = Exception.class)
    public void multiDataSourceOperation() {
        // 切换到主数据源
        DataSourceContextHolder.setDataSource("primary");
        PrimaryDatabaseOperations primaryOps = new PrimaryDatabaseOperations(seataTemplate);
        // 执行主数据源操作

        // 切换到从数据源
        DataSourceContextHolder.setDataSource("secondary");
        SecondaryDatabaseOperations secondaryOps = new SecondaryDatabaseOperations(seataTemplate);
        // 执行从数据源操作
    }
}

当交易完成时，Seata会自动提交或回滚事务，确保跨数据源的事务一致性。