Mybatis-plus Springboot 多数据源实现指南

要实现 Mybatis-plus Springboot 多数据源，你需要进行以下步骤：

添加依赖：在你的 Springboot 项目中，添加 Mybatis-plus 和多数据源相关的依赖。例如，可以在 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>latest_version</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jta-atomikos</artifactId>
</dependency>

配置数据源：在 application.properties 或 application.yml 文件中配置多个数据源。例如，可以配置两个数据源分别为 db1 和 db2：

spring.datasource.db1.url=jdbc:mysql://localhost:3306/db1
spring.datasource.db1.username=root
spring.datasource.db1.password=123456
spring.datasource.db1.driver-class-name=com.mysql.jdbc.Driver

spring.datasource.db2.url=jdbc:mysql://localhost:3306/db2
spring.datasource.db2.username=root
spring.datasource.db2.password=123456
spring.datasource.db2.driver-class-name=com.mysql.jdbc.Driver

创建数据源配置类：创建一个类，用于配置多个数据源。例如，可以创建一个类名为 DataSourceConfig 的 Java 类，并使用 @Configuration 注解标记该类为配置类：

@Configuration
public class DataSourceConfig {

    @Bean('db1DataSource')
    @ConfigurationProperties(prefix = 'spring.datasource.db1')
    public DataSource db1DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean('db2DataSource')
    @ConfigurationProperties(prefix = 'spring.datasource.db2')
    public DataSource db2DataSource() {
        return DataSourceBuilder.create().build();
    }

}

配置 Mybatis-plus：创建一个类，用于配置 Mybatis-plus。例如，可以创建一个类名为 MybatisPlusConfig 的 Java 类，并使用 @Configuration 注解标记该类为配置类：

@Configuration
@MapperScan(basePackages = {'com.example.mapper'})
public class MybatisPlusConfig {

    @Autowired
    @Qualifier('db1DataSource')
    private DataSource db1DataSource;

    @Autowired
    @Qualifier('db2DataSource')
    private DataSource db2DataSource;

    @Bean
    public MybatisSqlSessionFactoryBean sqlSessionFactory() throws Exception {
        MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
        sessionFactory.setDataSource(roundRobinDataSourceProxy());
        return sessionFactory;
    }

    @Bean
    public AbstractRoutingDataSource roundRobinDataSourceProxy() {
        Map<Object, Object> targetDataSources = new HashMap<>();
        targetDataSources.put('db1', db1DataSource);
        targetDataSources.put('db2', db2DataSource);

        RoutingDataSourceProxy proxy = new RoutingDataSourceProxy();
        proxy.setDefaultTargetDataSource(db1DataSource);
        proxy.setTargetDataSources(targetDataSources);
        return proxy;
    }
}

创建 Mapper 接口和 Mapper.xml 文件：创建 Mapper 接口和对应的 Mapper.xml 文件。例如，可以创建一个名为 UserMapper 的 Mapper 接口和对应的 UserMapper.xml 文件。
测试多数据源：编写测试代码，测试多数据源的功能。例如，可以编写一个测试类，调用 UserMapper 的方法，分别访问两个数据源：

@RunWith(SpringRunner.class)
@SpringBootTest
public class MybatisPlusMultiDataSourceTest {

    @Autowired
    private UserMapper userMapper;

    @Test
    public void testMultiDataSource() {
        List<User> userList1 = userMapper.selectList(new QueryWrapper<User>().eq('db', 'db1'));
        List<User> userList2 = userMapper.selectList(new QueryWrapper<User>().eq('db', 'db2'));

        System.out.println('db1: ' + userList1);
        System.out.println('db2: ' + userList2);
    }
}

以上是实现 Mybatis-plus Springboot 多数据源的基本步骤，你可以根据自己的需求进行配置和扩展。