mysql--使用shardingsphere實現分庫分表

一.簡介

本節將繼續通過ShardingSphere實現分庫分表

上一節的分表中已經介紹過了使用的分表策略，接下來介紹一下分庫策略

ShardingSphere提供如下四種分庫策略：

1. standard: #用於單分片鍵的標准分片場景

2. complex: #用於多分片鍵的復合分片場景

3. inline: #行表達式分片策略

4. hint: #Hint分片策略

本篇文章使用的是inline行表達式分片策略

關於各種分片策略，可以到手冊進行查看

 二.數據庫設計

本篇文章使用兩個數據庫，每個數據庫兩張表進行簡單的演示。

ds0庫：

 

 ds1庫於ds0兩個庫數據結構一致

三.編碼階段

1. 引入主要依賴

<dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.0</version>
        </dependency>
        <!--druid數據源-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.1</version>
        </dependency>
        <!--shardingsphere-->
        <dependency>
            <groupId>org.apache.shardingsphere</groupId>
            <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
            <version>4.0.0-RC1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.shardingsphere</groupId>
            <artifactId>sharding-jdbc-spring-namespace</artifactId>
            <version>4.0.0-RC1</version>
        </dependency>
        <!--jdbc-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.22</version>
        </dependency>

2. 配置文件

本篇文章數據庫分片策略中使用了inline行表達式分片策略

對age字段進行了hash取模運算來進行分片；

數據表分片策略同分庫策略

分表需要指定表節點：

actualDataNodes: #由數據源名 + 表名組成，以小數點分隔。多個表以逗號分隔，支持inline表達式。缺省表示使用已知數據源與邏輯表名稱生成數據節點，用於廣播表（即每個庫中都需要一個同樣的表用於關聯查詢，多為字典表）或只分庫不分表且所有庫的表結構完全一致的情況

server:
  port: 8083

#mybatis信息
mybatis:
  mapper-locations: classpath:mapping/*Mapper.xml
  type-aliases-package: com.example.demo.entity

Spring:
  shardingsphere:
    datasource:
      names: ds0,ds1 #配置數據源 分庫分表配置
      #ds0庫
      ds0:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/ds0?serverTimezone=Asia/Shanghai&useSSL=false&allowMultiQueries=true
        username: root
        password: 123456
      #ds1庫
      ds1:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/ds1?serverTimezone=Asia/Shanghai&useSSL=false&allowMultiQueries=true
        username: root
        password: 123456
    sharding:
      #默認數據庫分片策略  根據年齡分庫
      default-database-strategy:
        #行表達式分片策略
        inline:
          #分片字段名稱
          sharding-column: age
          #分片算法表達式 age 對 2 進行取模運算
          algorithm-expression: ds$->{age % 2}
      #數據表分片規則
      tables:
        #表名
        tab_user:
          #由數據源名 + 表名組成，以小數點分隔。表節點
          actual-data-nodes: ds$->{0..1}.tab_user$->{0..1}
          #分表策略
          table-strategy:
            inline:
              #通過id分表
              sharding-column: id
              #分片算法表達式
              algorithm-expression: tab_user$->{id % 2}
    props:
      sql:
        show: true
swagger:
  enable: true

3. 測試

/**
 * 分庫分表測試
 * @author Lv de yin
 * @Date 2021/9/3
 */
@RequestMapping("pareDaAndTab/")
@RestController
public class PartDatabaseAndPartTableController {

    @Autowired
    private TabUserServiceImpl tabUserService;

    /**
     * 模擬插入數據
     */
    List<TabUser> userList = new ArrayList<TabUser>();

    @PostConstruct
    private void getData(){
        userList.add(new TabUser(1,"小小", "女", 3));
        userList.add(new TabUser(2,"爸爸", "男", 30));
        userList.add(new TabUser(3,"媽媽", "女", 28));
        userList.add(new TabUser(4,"爺爺", "男", 64));
        userList.add(new TabUser(5,"奶奶", "女", 62));
    }

    @PostMapping("save-user")
    public Object saveUser(){
        return tabUserService.saveForeach(userList);
    }

    @GetMapping("list-user")
    public Object listUser(){
        return tabUserService.list();
    }

    @GetMapping("list-user-order")
    public Object listUserByOrder(@RequestParam(value = "column") String column,@RequestParam(value = "sort") String sort){
        return tabUserService.listBySort(column, sort);
    }
}

4. 測試結果

插入測試：

• 第一條數據小小，通過age字段對2取模得到1，被分到ds1庫，通過id字段對2取模得到1，分到tab_user1表。

ds0庫：

　　tab_user0:

　　

 　　tab_user1:

　　

 ds1庫:

　　tab_user0:

　　

 　　tab_user1: