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张不一样的表中，证实分表对批量插入有效。