mysql--使用shardingsphere實現分表

一. 簡介

為什么要分表，無非就兩個原因，要么是並發太高，要么就是數據量太大。

所謂分表就是把傳統的單表擴展為多個數據結構一樣的表，通過分表策略確定操作哪一張表。

我使用的分表規則是通過主鍵id進行取模運算。

例如user表，假設分三個表：user_0 user_1 user_2

插入操作：

假設添加一個用戶主鍵id為1  1%3 = 1

該用戶將會插入到user_1表中

查詢操作：

查詢操作時shardingsphere會將個個表中的id進行排序后返回

手把手在springboot中通過shardingsphere實現mysql的分表操作。

ShardingSphere是一套開源的分布式數據庫中間件解決方案組成的生態圈。
它由Sharding-JDBC、Sharding-Proxy和Sharding-Sidecar（計划中）這3款相互獨立的產品組成，shardingSphere定位為關系型數據庫中間件。

 

該文章中我們主要對Sharding-JDBC做簡單的使用，更多更深入的內容鐵子們可以自行去深入了解。

二. 編碼階段

1. 依賴引入(主要依賴)

　　<dependency>
  　　<groupId>org.mybatis.spring.boot</groupId>
  　　<artifactId>mybatis-spring-boot-starter</artifactId>
  　　<version>2.2.0</version>
　　</dependency>
　　<!--druid數據源-->
 7 　　<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. 修改配置文件

 

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

Spring:
  shardingsphere:
    datasource:
      names: master #配置數據源
      master:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/test_1?serverTimezone=Asia/Shanghai&useSSL=false&allowMultiQueries=true
        username: lv1
        password: 123456
    #配置分表規則
    sharding:
      #指定所需分的表
      tables:
        #表user_
        user_:
          actual-data-nodes: master.user_$->{0..2} #需要分表的表 user_0 user_1 user_2
          table-strategy:
            inline:
              sharding-column: id #主鍵
              algorithm-expression: user_$->{id % 3} #分表規則
        #表order_
        order_:
          actual-data-nodes: master.order_$->{0..2} #需要分表的表
          table-strategy:
            inline:
              sharding-column: id #主鍵
              algorithm-expression: order_$->{id % 3} #分表規則
    props:
      sql:
        show: true

3. 測試

@RestController
@RequestMapping("/user")
@Api(tags = "用戶相關")
public class UserController {

    @Autowired
    private UserService userService;

    @PostMapping(value = "/create")
    @ApiOperation(value = "創建用戶")
    public Object create(){
        List<User> users = new ArrayList<>();
        User user1 = new User(1, "Echo", 1, 18, "貴陽");
        User user2 = new User(2, "Echo", 1, 18, "貴陽");
        User user3 = new User(3, "Echo", 1, 18, "貴陽");
        User user4 = new User(4, "Echo", 1, 18, "貴陽");
        User user5 = new User(5, "Echo", 1, 18, "貴陽");
        User user6 = new User(6, "Echo", 1, 18, "貴陽");
        users.add(user1);
        users.add(user2);
        users.add(user3);
        users.add(user4);
        users.add(user5);
        users.add(user6);
        return userService.insertForeach(users);
    }

    @GetMapping(value = "get")
    @ApiOperation(value = "獲取用戶信息")
    private Object list(){
        return userService.list();
    }
}

4. 測試結果

插入效果：

 

 

 

 查詢效果：