一、前言

本次实际应用中，使用到了如下几个要点：

mysql的动态建表;

mysql的多表插入;

mysql的多表更新;

mysql的多表删除;

二、使用场景

2.1 动态建表

要求建立多个表，例如电压、电流等表，这些表的字段是完全一样的，只有表名不一样，那么我们就可以把表名等字段放在基准表中，然后从基准表中获得所有的表名字段，以list的形式传入mybatis中，进行循环动态拼接创建。

void createTelemetryTable(List list);

复制代码

CREATE TABLE if not exists `${item}` (

sys_id bigint NOT NULL,

mpnt_id bigint NOT NULL,

data_date DATE NOT NULL,

data_point int NOT NULL,

data_item_id bigint NOT NULL,

val DECIMAL(10,2) NOT NULL,

KEY `${item}_sys_id` (`sys_id`),

KEY `${item}_mpnt_id` (`mpnt_id`),

KEY `${item}_data_date` (`data_date`),

KEY `${item}_data_point` (`data_point`),

KEY `${item}_data_item_id` (`data_item_id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

复制代码

部分截图如下：

2.2 多表批量插入

应用场景就是实际使用中，拿到一批数据，然后这批数据对应到多个不同表，那么最好的方式就是通过map映射，例如：Map>。那么这时候就需要自己来写动态sql了。

其中需要了解的两个mybatis注解就是：@Insert 和@InsertProvider 都是用来在实体类的Mapper类中的注解保存方法的SQL语句。区别就是@Insert是直接配置sql语句，而@InsertProvider则是通过sql工厂类及对应的方法生产sql语句，这种方法的好处就是可以写出更为复杂的sql。

@InsertProvider的注解方式为：

@InsertProvider(type = BaseMapperEnhanceImpl.class,method = "insertCalBatchTable")

void insertBatch(@Param("tables") Map> ycTable);

复制代码

说明：type指明sql工厂类，method是工厂类里对应的方法。

多表批量插入的代码如下：

/**

* 计算服务的批量插入：参数名称必须传 list ，例 @Param("list")

**/

public String insertCalBatchTable(Map map){

Map table = (Map) map.get("tables");

String sql = table.keySet().stream().map(i -> insertBatch((Collection) table.get(i),i)).collect(Collectors.joining());

return sql;

}

/**

* 计算服务批量插入

**/

private String insertBatch(Collection col,String table){

if(CollectionUtil.isEmpty(col)){

throw new RuntimeException("saveAll parameter size is zero or null");

}

Object t = null;

ArrayList list;

if(col instanceof List){

list = (ArrayList) col;

t = list.get(0);

}else{

throw new RuntimeException("Only list or set types are allowed");

}

Class cls = t.getClass();

Field[] fields = cls.getDeclaredFields();

StringBuffer sql = new StringBuffer();

sql.append("INSERT INTO `"+table+"` ");

sql.append("(");

for (Field field :fields) {

field.setAccessible(true);

TableField tableField = field.getAnnotation(TableField.class);

if(ObjectUtil.isNotNull(tableField)){

sql.append(tableField.value()+",");

}

}

sql.delete(sql.length()-1,sql.length());

sql.append(") VALUES ");

for (int i = 0; i < list.size(); i++) {

sql.append(list.get(i).toString());

if (i < list.size() - 1) {

sql.append(",");

}

}

sql.append(";");

return sql.toString();

}

复制代码

说明：可以看下这个插入对象的实体类：需要在待插入的字段上加上@TableField注解，然后通过重写toString来获取sql的插入语句：然后sql会自动把这些值给拼接上去。最后通过这个注解将这条动态语句插入到数据库中。

@Override

public String toString() {

return "("+this.getSysId()+","+this.getMpntId()+",'"+this.getDataDate()+"',"+this.getDataPoint()+","+ this.getDataItemId()+","+ this.getVal()+")";

}

复制代码

2.3 多表批量更新

应用场景与上同理，对多个表进行批量更新。传参形式依旧为如下：Map>。同理，在实体类中写了个获取update sql的方法：

@Data

@NoArgsConstructor

public class CalcDateCurve {

@TableField(value = "sys_id")

private long sysId;

@TableField(value = "mpnt_id")

private long mpntId;

@TableField(value = "data_date")

private Date dataDate;

@TableField(value = "data_point")

private Integer dataPoint;

@TableField(value = "data_item_id")

private long dataItemId;

@TableField(value = "val")

private BigDecimal val;

private String key;

@Override

public String toString() {

return "("+this.getSysId()+","+this.getMpntId()+",'"+this.getDataDate()+"',"+this.getDataPoint()+","+ this.getDataItemId()+","+ this.getVal()+")";

}

public String updateSql() {

return "val ="+this.getVal()+" where sys_id="+this.getSysId() +" and mpnt_id="+this.getMpntId() +" and data_date = '"+this.getDataDate()+"' and data_point="+this.getDataPoint()+" and data_item_id="+this.getDataItemId() ;

}

}

复制代码

mapper 层：

@UpdateProvider(type = BaseMapperEnhanceImpl.class,method = "updateCalBatchTable")

void updateBatch(@Param("tables") Map> ycTable);

复制代码

工厂类方法：

/**

* 计算服务的批量更新

**/

private String updateBatch(Collection col,String table) {

if(CollectionUtil.isEmpty(col)){

throw new RuntimeException("saveAll parameter size is zero or null");

}

Object t = null;

ArrayList list;

if(col instanceof List){

list = (ArrayList) col;

t = list.get(0);

}else{

throw new RuntimeException("Only list or set types are allowed");

}

Class cls = t.getClass();

Field[] fields = cls.getDeclaredFields();

StringBuffer sql = new StringBuffer();

for (int i = 0; i < list.size(); i++) {

try {

sql.append("UPDATE `"+table+"` SET ");

sql.append(list.get(i).getClass().getDeclaredMethod("updateSql").invoke(t));

} catch (NoSuchMethodException e) {

e.printStackTrace();

} catch (IllegalAccessException e) {

e.printStackTrace();

} catch (InvocationTargetException e) {

e.printStackTrace();

}

}

sql.append(";");

return sql.toString();

}

复制代码

说明：这块用到了反射该类来获取该类的某个方法，也是自己在项目中第一次用到反射的东西。

2.4 批量删除表

这个小玩意也记录下来，手动去清除表：查出所有语句遍历执行也是可以改进的。

Select CONCAT( 'drop table ', table_name, ';' )

FROM information_schema.tables

Where table_name LIKE 'calc%';

复制代码