1. 概述
web項目使用 mybatis+mycat+mysql 的結(jié)構(gòu)颓鲜。
mycat作為中間件答倡，mysql 使用多庫分表
存在兩張表：t_table(表的元數(shù)據(jù)信息) 和 t_table_field(表的字段信息)。
邏輯上，t_table_field 是作為 t_table 的子表。
t_table_field 某業(yè)務(wù)需求，為了減少 mybatis <> mycat 之間的網(wǎng)絡(luò)IO失晴，考慮使用批量插入數(shù)據(jù)。
mycat要使用批量插入數(shù)據(jù)拘央，需要注意一下兩點：
- 在
schema.xml的<schema>配置中涂屁，只有<table>支持（<childTable>不支持）。 - 表的主鍵ID使用mycat的自增ID策略灰伟，需要配置
primaryKeyautoIncrement屬性拆又。
2. 示例
2.1. Pojo
@Setter
@Getter
public class TableField {
private Long id;
private Long pid; // t_table主鍵
private String fieldName;
private String fieldType;
private String isNull;
private String defaultValue;
private String expand;
private String comment;
private Integer position;
private Date createTime;
}
2.2. Mapper
/**
* 批量插入
*/
void insertByBatch(@Param("pid") Long pid, @Param("fieldList") List<TableField> fieldList);
sql需要指明 Catlet -> BatchInsertSequence
<insert id="insertByBatch" parameterType="map">
/*!mycat:catlet=io.mycat.route.sequence.BatchInsertSequence */
insert into t_table_field(pid,field_name,field_type,is_null,default_value,expand,comment,`position`,create_time)
values
<foreach collection="fieldList" item="item" index="index" separator=",">
(#{pid},#{item.fieldName},#{item.fieldType},#{item.isNull},#{item.defaultValue},#{item.expand},
#{item.comment},#{item.position},#{item.createTime})
</foreach>
</insert>
2.3. MyCat配置
sequence_db_conf.properties
這里使用 properties+表 配置sequence
T_TABLE=dn1
T_TABLE_FIELD=dn1
schema.xml
<schema ···>
<table name="mycat_sequence" dataNode="dn1"/>
<table name="t_table" dataNode="dn$8-9" rule="sharding-by-id-2"/>
<table name="t_table_field" primaryKey="id" autoIncrement="true" dataNode="dn$8-9" rule="sharding-by-id-2"/>
</schema>
t_table 和 t_table_field 表分了2個節(jié)點，rule 是根據(jù)ID取模（id % 2）分片栏账。
t_table_field 表的配置要聲明 primaryKey autoIncrement 屬性帖族。
2.4. 實際執(zhí)行SQL
MyCat實際發(fā)送到MySQL的SQL是組裝上 ID 字段的
2020/06/21 16:09:56.747 | jvm 1 | {INSERT INTO T_TABLE_FIELD (pid, field_name, field_type, is_null, default_value, expand, comment, `position`, create_time, ID)
2020/06/21 16:09:56.747 | jvm 1 | VALUES (20157, 'id', 'varchar(20)', '0', NULL, '', '主鍵id', 0, '2020-06-21 16:09:56.845'
2020/06/21 16:09:56.747 | jvm 1 | , 14086050),
2020/06/21 16:09:56.747 | jvm 1 | (20157, 'sub_inventory_code', 'varchar(32)', '0', NULL, '', '子盤點單號', 2, '2020-06-21 16:09:56.845'
2020/06/21 16:09:56.747 | jvm 1 | , 14086112)}, respHandler=io.mycat.backend.mysql.nio.handler.MultiNodeQueryHandler@3f60f0a6, ······
