<dependencies>
    <!-- ShardingSphere JDBC 核心依賴 -->
     <dependency>
         <groupId>org.apache.shardingsphere</groupId>
         <artifactId>shardingsphere-jdbc</artifactId>
         <version>5.5.2</version>
     </dependency>

    <!-- Druid 數(shù)據(jù)源 -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-3-starter</artifactId>
        <version>1.2.27</version>
    </dependency>

    <!-- MySQL 驅(qū)動(dòng) -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-j</artifactId>
        <version>8.4.0</version>
    </dependency>
    
     <!-- springboot -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>3.5.5</version>
    </dependency>
</dependencies>

server:
  port: 9090

spring:
  datasource:
    driver-class-name: org.apache.shardingsphere.driver.ShardingSphereDriver # 指定了ShardingSphereDriver 為數(shù)據(jù)庫驅(qū)動(dòng)
    url: jdbc:shardingsphere:classpath:sharding-datasource.yml # 指定classpath的sharding-datasource.yml文件

mode:
  type: Standalone       # ShardingSphere 運(yùn)行模式，Standalone 表示單機(jī)模式，不是集群模式
  repository:
    type: MEMORY         # 元數(shù)據(jù)存儲(chǔ)類型，MEMORY 表示元數(shù)據(jù)存儲(chǔ)在內(nèi)存中（也可用 JDBC 存儲(chǔ)）
dataSources:
  master:                # master名字可以自定義 數(shù)據(jù)庫主庫（普通表 寫庫）
    dataSourceClassName: com.alibaba.druid.pool.DruidDataSource  # 使用 Druid 作為真實(shí)數(shù)據(jù)源
    driverClassName: com.mysql.cj.jdbc.Driver                   # MySQL 驅(qū)動(dòng)
    url: jdbc:mysql://localhost:3306/tsuki-chat?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true
    username: root
    password: 123456
  slave:                 #slave名字可以自定義 數(shù)據(jù)庫從庫（普通表 從庫）
    dataSourceClassName: com.alibaba.druid.pool.DruidDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3307/tsuki-chat?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true
    username: root
    password: 123456
  users_master:          # users表數(shù)據(jù)庫主庫（用于 users 表分庫分表寫入操作）
    dataSourceClassName: com.alibaba.druid.pool.DruidDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/tsuki-users?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true
    username: root
    password: 123456

  users_slave:          # users表數(shù)據(jù)庫從庫（用于 users 表分庫分表讀取操作）
    dataSourceClassName: com.alibaba.druid.pool.DruidDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3307/tsuki-users?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true
    username: root
    password: 123456

rules:
  # 1?? 全局表（除了 users 表）讀寫分離規(guī)則
  - !READWRITE_SPLITTING
    dataSourceGroups: # 必須用dataSourceGroups，用官網(wǎng)的dataSources會(huì)報(bào)錯(cuò)
      readwrite_ds:                     # 邏輯數(shù)據(jù)源名（可自定義）
        writeDataSourceName: master     # 寫庫
        readDataSourceNames:            # 讀庫集合
          - slave
        transactionalReadQueryStrategy: PRIMARY  # 事務(wù)讀策略，PRIMARY 表示事務(wù)中讀主庫
        loadBalancerName: random        # 讀庫負(fù)載均衡策略
    loadBalancers:
      random:                           # 負(fù)載均衡算法配置
        type: RANDOM                    # 隨機(jī)選擇讀庫

  # 2?? 針對(duì)users 表讀寫分離規(guī)則
  - !READWRITE_SPLITTING
    dataSourceGroups:
      users_group:                      # users 表邏輯數(shù)據(jù)源名（可自定義）
        writeDataSourceName: users_master  # 寫庫
        readDataSourceNames:
          - users_slave # 讀庫
        transactionalReadQueryStrategy: PRIMARY  # 事務(wù)讀策略，PRIMARY 表示事務(wù)中讀主庫
        loadBalancerName: random        # 讀庫負(fù)載均衡策略
    loadBalancers:
      random:
        type: RANDOM                    # 隨機(jī)負(fù)載均衡

  # 3?? users 表分表規(guī)則
  - !SHARDING
    tables:
      users:
        actualDataNodes: users_group.users_${0..1}   # 物理表名列表，users_0 和 users_1
        tableStrategy:
          standard:
            shardingColumn: id                 # 分表字段
            shardingAlgorithmName: user_algo   # 使用分片算法 user_algo
    shardingAlgorithms:
      user_algo:
        type: INLINE
        props:
          algorithm-expression: users_${id % 2}  # 簡單取模算法，將 id % 2 決定插入到 users_0 或 users_1

  # 4?? 其他非分片表（比如 Test、Message 等）走默認(rèn)讀寫分離數(shù)據(jù)源
  - !SINGLE
    tables:
      - "*.*"                             # 匹配所有其他表
    defaultDataSource: readwrite_ds       # 使用邏輯數(shù)據(jù)源 readwrite_ds（即 tsuki-chat 的讀寫分離）

props:
  sql-show: true                         # 打印 SQL，便于調(diào)試
  check-table: false                      # 不檢查表是否存在，防止啟動(dòng)報(bào)錯(cuò)
  default-data-source-name: readwrite_ds  # 默認(rèn)邏輯數(shù)據(jù)源

    @Test
    public void test3() {
        DbTest dbTest = new DbTest(1);
        testMapper.insert(dbTest);
    }

    @Test
    public void test4() {
        DbTest dbTest = testMapper.selectById(114514);
        log.info(dbTest.toString());
    }

    @Test
    public void test() {
        List<User> users = generateUsers(10); // 生成10條users數(shù)據(jù)
        List<BatchResult> insert = userMapper.insert(users);
        log.info("插入成功");
    }

    @Test
    public void test2() {
        Page<User> userPage = new Page<User>(1, 8);
        Page<User> selectedPage = userMapper.selectPage(userPage, null);
        selectedPage.getRecords().forEach(user -> log.info(String.valueOf(user.getId())));
    }