sharding整合dynamic-datasource-spring-boot-starter

ShardingSphere是一款开源的分布式数据库中间件，可以实现对关系型数据库的分库分表、读写分离、分布式事务等功能。而dynamic-datasource-spring-boot-starter是一个基于Spring Boot的动态数据源组件，可以动态地切换数据源。如果需要将这两个组件整合起来使用，可以按照以下步骤进行操作：

1. 引入依赖

在项目的pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>${sharding-sphere-version}</version>
</dependency>

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

其中，${sharding-sphere-version}为ShardingSphere的版本号，${dynamic-datasource-version}为dynamic-datasource-spring-boot-starter的版本号。

2. 配置数据源

在application.yml中配置数据源信息，包括ShardingSphere的分库分表规则和动态数据源的配置信息。

spring:
  shardingsphere:
    datasource:
      names: ds0,ds1
      ds0:
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://localhost:3306/db0?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
        username: root
        password: root
      ds1:
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://localhost:3306/db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
        username: root
        password: root
    sharding:
      tables:
        user:
          actual-data-nodes: ds${0..1}.user_${0..1}
          table-strategy:
            inline:
              sharding-column: id
              algorithm-expression: user_${id % 2}
          key-generator:
            column: id
            type: SNOWFLAKE

其中，names为数据源名称，actual-data-nodes为ShardingSphere的分库分表规则，table-strategy为分表策略，key-generator为主键生成策略。

3. 配置动态数据源

在DynamicDataSourceAutoConfiguration中配置动态数据源。

@Configuration
public class DynamicDataSourceAutoConfiguration {

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.ds0")
    public DataSource ds0() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.ds1")
    public DataSource ds1() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @Primary
    public DynamicDataSource dataSource(DataSource ds0, DataSource ds1) {
        Map<Object, Object> targetDataSources = new HashMap<>();
        targetDataSources.put("ds0", ds0);
        targetDataSources.put("ds1", ds1);
        return new DynamicDataSource(ds0, targetDataSources);
    }
}

其中，ds0和ds1分别对应于ShardingSphere中的ds0和ds1数据源，DynamicDataSource是动态数据源的实现类。

4. 测试

在测试类中使用@Autowired注解注入DataSource，并使用JdbcTemplate进行数据操作。

@SpringBootTest
public class ShardingTest {

    @Autowired
    private DataSource dataSource;

    @Test
    public void test() {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        jdbcTemplate.update("insert into user (name, age) values (?, ?)", "张三", 20);
        jdbcTemplate.update("insert into user (name, age) values (?, ?)", "李四", 30);
        List<Map<String, Object>> userList = jdbcTemplate.queryForList("select * from user");
        System.out.println(userList);
    }
}

运行测试类，可以看到数据成功插入到两个库的两张表中，并且查询结果也正确。