<!-- jpa持久化工具 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
    <version>2.7.6</version>
</dependency>
<!-- 必須引入的包 mysql -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.31</version>
</dependency>
<!-- 必須引入的包 ShardingSphere -->
<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId>
    <version>5.2.0</version>
</dependency>

spring:
  shardingsphere:
    # 數(shù)據(jù)源配置
    datasource:
      # 數(shù)據(jù)源名稱，多數(shù)據(jù)源以逗號分隔
      names: db0,db1
      db0:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://127.0.0.1:3306/shardingsphere-db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
        username: root
        password: 123456
      db1:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://127.0.0.1:3306/shardingsphere-db0?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
        username: root
        password: 123456
    # 分片規(guī)則配置
    rules:
      sharding:
        # 分片算法配置
        sharding-algorithms:
          database-inline:
            # 分片算法類型
            type: INLINE
            props:
              # 分片算法的行表達式（算法自行定義，此處為方便演示效果）
              algorithm-expression: db$->{order_id > 4?1:0}
          table-inline:
            # 分片算法類型
            type: INLINE
            props:
              # 分片算法的行表達式
              algorithm-expression: t_order_$->{order_id % 4}
        tables:
          # 邏輯表名稱
          t_order:
            # 行表達式標識符可以使用 ${...} 或 $->{...}，但前者與 Spring 本身的屬性文件占位符沖突，因此在 Spring 環(huán)境中使用行表達式標識符建議使用 $->{...}
            actual-data-nodes: db${0..1}.t_order_${0..3}
            # 分庫策略
            database-strategy:
              standard:
                # 分片列名稱
                sharding-column: order_id
                # 分片算法名稱
                sharding-algorithm-name: database-inline
            # 分表策略
            table-strategy:
              standard:
                # 分片列名稱
                sharding-column: order_id
                # 分片算法名稱
                sharding-algorithm-name: table-inline
    # 屬性配置
    props:
      # 展示修改以后的sql語句
      sql-show: true

spring:
  shardingsphere:
    # 數(shù)據(jù)源配置
    datasource:
      # 數(shù)據(jù)源名稱，多數(shù)據(jù)源以逗號分隔
      names: db0,db1
      db0:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://127.0.0.1:3306/shardingsphere-db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
        username: root
        password: 123456
      db1:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://127.0.0.1:3306/shardingsphere-db0?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
        username: root
        password: 123456

spring:
  shardingsphere:
    # 規(guī)則配置
    rules:
      sharding:
        # 分片算法配置
        sharding-algorithms:
          database-inline:
            # 分片算法類型
            type: INLINE
            props:
              # 分片算法的行表達式（算法自行定義，此處為方便演示效果）
              algorithm-expression: db$->{order_id % 2}
          table-inline:
            # 分片算法類型
            type: INLINE
            props:
              # 分片算法的行表達式
              algorithm-expression: t_order_$->{order_id % 3}

spring:
  shardingsphere:
    # 規(guī)則配置
    rules:
      sharding:
        tables:
          # 邏輯表名稱
          t_order:
            # 行表達式標識符可以使用 ${...} 或 $->{...}，但前者與 Spring 本身的屬性文件占位符沖突，因此在 Spring 環(huán)境中使用行表達式標識符建議使用 $->{...}
            actual-data-nodes: db${0..1}.t_order_${0..3}
            # 分庫策略
            database-strategy:
              standard:
                # 分片列名稱
                sharding-column: order_id
                # 分片算法名稱
                sharding-algorithm-name: database-inline
            # 分表策略
            table-strategy:
              standard:
                # 分片列名稱
                sharding-column: order_id
                # 分片算法名稱
                sharding-algorithm-name: table-inline

spring:
  shardingsphere:
    # 屬性配置
    props:
      # 展示修改以后的sql語句
      sql-show: true

@Configuration
public class ShardingConfiguration {
    /**
     * 配置分片數(shù)據(jù)源
     * 公眾號：程序員小富
     */
    @Bean
    public DataSource getShardingDataSource() throws SQLException {
        Map<String, DataSource> dataSourceMap = new HashMap<>();
        dataSourceMap.put("db0", dataSource1());
        dataSourceMap.put("db1", dataSource2());
        // 分片rules規(guī)則配置
        ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
        shardingRuleConfig.setShardingAlgorithms(getShardingAlgorithms());
        // 配置 t_order 表分片規(guī)則
        ShardingTableRuleConfiguration orderTableRuleConfig = new ShardingTableRuleConfiguration("t_order", "db${0..1}.t_order_${0..2}");
        orderTableRuleConfig.setTableShardingStrategy(new StandardShardingStrategyConfiguration("order_id", "table-inline"));
        orderTableRuleConfig.setDatabaseShardingStrategy(new StandardShardingStrategyConfiguration("order_id", "database-inline"));
        shardingRuleConfig.getTables().add(orderTableRuleConfig);
        // 是否在控制臺輸出解析改造后真實執(zhí)行的 SQL
        Properties properties = new Properties();
        properties.setProperty("sql-show", "true");
        // 創(chuàng)建 ShardingSphere 數(shù)據(jù)源
        return ShardingSphereDataSourceFactory.createDataSource(dataSourceMap, Collections.singleton(shardingRuleConfig), properties);
    }
    /**
     * 配置數(shù)據(jù)源1
     * 公眾號：程序員小富
     */
    public DataSource dataSource1() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/shardingsphere-db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true");
        dataSource.setUsername("root");
        dataSource.setPassword("123456");
        return dataSource;
    }
    /**
     * 配置數(shù)據(jù)源2
     * 公眾號：程序員小富
     */
    public DataSource dataSource2() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/shardingsphere-db0?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true");
        dataSource.setUsername("root");
        dataSource.setPassword("123456");
        return dataSource;
    }
    /**
     * 配置分片算法
     * 公眾號：程序員小富
     */
    private Map<String, AlgorithmConfiguration> getShardingAlgorithms() {
        Map<String, AlgorithmConfiguration> shardingAlgorithms = new LinkedHashMap<>();
        // 自定義分庫算法
        Properties databaseAlgorithms = new Properties();
        databaseAlgorithms.setProperty("algorithm-expression", "db$->{order_id % 2}");
        shardingAlgorithms.put("database-inline", new AlgorithmConfiguration("INLINE", databaseAlgorithms));
        // 自定義分表算法
        Properties tableAlgorithms = new Properties();
        tableAlgorithms.setProperty("algorithm-expression", "t_order_$->{order_id % 3}");
        shardingAlgorithms.put("table-inline", new AlgorithmConfiguration("INLINE", tableAlgorithms));
        return shardingAlgorithms;
    }
}

@Getter
@Setter
public final class ShardingRuleConfiguration implements DatabaseRuleConfiguration, DistributedRuleConfiguration {
    // 分表配置配置
    private Collection<ShardingTableRuleConfiguration> tables = new LinkedList<>();
    // 自動分片規(guī)則配置
    private Collection<ShardingAutoTableRuleConfiguration> autoTables = new LinkedList<>();
    // 綁定表配置
    private Collection<String> bindingTableGroups = new LinkedList<>();
    // 廣播表配置
    private Collection<String> broadcastTables = new LinkedList<>();
    // 默認的分庫策略配置
    private ShardingStrategyConfiguration defaultDatabaseShardingStrategy;
    // 默認的分表策略配置
    private ShardingStrategyConfiguration defaultTableShardingStrategy;
    // 主鍵生成策略配置
    private KeyGenerateStrategyConfiguration defaultKeyGenerateStrategy;
    private ShardingAuditStrategyConfiguration defaultAuditStrategy;
    // 默認的分片鍵
    private String defaultShardingColumn;
    // 自定義的分片算法
    private Map<String, AlgorithmConfiguration> shardingAlgorithms = new LinkedHashMap<>();
    // 主鍵生成算法
    private Map<String, AlgorithmConfiguration> keyGenerators = new LinkedHashMap<>();
    private Map<String, AlgorithmConfiguration> auditors = new LinkedHashMap<>();
}

spring:
  shardingsphere:
    # 數(shù)據(jù)源配置
    datasource:
      # 數(shù)據(jù)源名稱，多數(shù)據(jù)源以逗號分隔
      names: db2 , db1 , db0