Springboot2使用shardingsphere分表攻略

假設咱們有一個table_data表，如今要將其分紅5個分表table_data0、table_data一、table_data二、table_data三、table_data4

表內字段大體以下,id爲主鍵

咱們要使用的是shardingsphere的shardingjdbc模塊，添加pom以下（該版本爲Apache最新孵化版本）

<dependency>
   <groupId>org.apache.shardingsphere</groupId>
   <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
   <version>4.0.0-RC1</version>
</dependency>

由於我使用的是mysql8的版本，配置文件以下

spring:
  shardingsphere:
    datasource:
      names: ds0
      ds0:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://xx.xx.xx.xx:3306/database?useSSL=FALSE&serverTimezone=GMT%2B8
        username: root
        password: *****
        type: com.alibaba.druid.pool.DruidDataSource
        filters: stat
        maxActive: 20
        initialSize: 1
        maxWait: 60000
        minIdle: 1
        timeBetweenEvictionRunsMillis: 60000
        minEvictableIdleTimeMillis: 300000
        validationQuery: select 'x'
        testWhileIdle: true
        testOnBorrow: false
        testOnReturn: false
        poolPreparedStatements: true
        maxOpenPreparedStatements: 20
    sharding:
      tables:
        table_data:
          actual-data-nodes: ds0.table_data$->{0..4}
          table-strategy:
            inline:
              sharding-column: id
              algorithm-expression: table_data$->{id % 5}

以上配置中table_data爲邏輯表,若是要修改爲其餘的邏輯表，必定要將tables下的table_data改爲新的邏輯表。

在SpringBootApplication標籤中添加以下值

@SpringBootApplication(exclude = JtaAutoConfiguration.class)

咱們在mybatis的配置文件中添加一個批量插入

@Mapper
public interface TableDataDao {
    int insert(List<TableData> tableDataList);
}

<insert id="insert" parameterType="java.util.List">
    insert into table_data (id,table_id,table_model_id,table_name,vehicle_id,
    vehicle_start_date,vehicle_brand,vehicle_no,vehicle_type,table_date,user_id,
    user_name,check_item_id,check_item_important,check_item_name,item_id,
    item_check_content,item_check_name,item_declared,item_ok,item_ok_url,
    item_problem_description,item_problem_url) values 
    <foreach collection="list" item="item" index="index" separator=",">
        (#{item.id,jdbcType=BIGINT},
         #{item.tableId,jdbcType=BIGINT},
         #{item.tableModelId,jdbcType=BIGINT},
         #{item.tableName,jdbcType=VARCHAR},
         #{item.vehicleId,jdbcType=INTEGER},
         #{item.vehicleStartDate,jdbcType=TIMESTAMP},
         #{item.vehicleBrand,jdbcType=VARCHAR},
         #{item.vehicleNo,jdbcType=VARCHAR},
         #{item.vehicleType,jdbcType=VARCHAR},
         #{item.tableDate,jdbcType=TIMESTAMP},
         #{item.userId,jdbcType=BIGINT},
         #{item.userName,jdbcType=VARCHAR},
         #{item.checkItemId,jdbcType=INTEGER},
         #{item.checkItemImportant,jdbcType=INTEGER},
         #{item.checkItemName,jdbcType=VARCHAR},
         #{item.itemId,jdbcType=INTEGER},
         #{item.itemCheckContent,jdbcType=VARCHAR},
         #{item.itemCheckName,jdbcType=VARCHAR},
         #{item.itemDeclared,jdbcType=INTEGER},
         #{item.itemOk,jdbcType=INTEGER},
         #{item.itemOkUrl,jdbcType=VARCHAR},
         #{item.itemProblemDescription,jdbcType=VARCHAR},
         #{item.itemProblemUrl,jdbcType=VARCHAR})
    </foreach>
</insert>

以上批量插入的爲邏輯表data_table

在Controller中對其進行插入

public void insertTableDataBatch(List<TableData> tableDataList) {
    tableDataDao.insert(tableDataList);
}

測試以下

成功執行後，咱們來查看各個分表

table_data0中以下

table_data1中以下

table_data2中以下

table_data3中以下

table_data4中以下

咱們可見這些數據被很好的分配到了5張不一樣的表中，證實分表對批量插入有效。