场景
若依前后端分离版本地搭建开发环境并运行项目的教程：
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/108465662
在上面的框架的使用基础上，需要在代码中获取某个表的建表语句，并根据业务
需求动态的建新的表。
比如在定时任务中执行固定的代码，在代码中获取某个表的建表语句，然后以时间
为后缀新建新的一个表。
比如新建表:
CREATE TABLE bus_badao_record (
id int NOT NULL AUTO_INCREMENT,
x varchar(255) DEFAULT NULL,
y varchar(255) DEFAULT NULL,
record_time datetime DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT charset=utf8mb3
需要每天新建一个表并以时间为后缀，比如明天需要新建一个表bus_badao_record20220805，后天需要新建一个表bus_badao_record20220806
注：
博客：
https://blog.csdn.net/badao_liumang_qizhi
关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。
实现
1、 首先按照上面的建表语句在Mysql中建立该表。
需要用到Mysql中的查看建表语句的sql
show create table bus_badao_record
后面跟的是表名。
在Navicat中执行的结果是
会返回两个字段，一个是table表名，一个是create table的内容。
所以针对返回的内容，在SpringBoot中新建实体类TableInfo
package com.ruoyi.quartz.domain;
public class TableInfo {
private String table;
private String createTable;
public String getTable() {
return table;
}
public void setTable(String table) {
this.table = table;
}
public String getCreateTable() {
return createTable;
}
public void setCreateTable(String createTable) {
this.createTable = createTable;
}
}
2、针对该实体类新建Mapper接口
package com.ruoyi.quartz.mapper;
import com.ruoyi.quartz.domain.TableInfo;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface BusTableMapper {
public int createTableSql(String sql);
public TableInfo showCreateTable(String sql);
}
对应mapper.xml的文件内容
"1.0" encoding="UTF-8"?> span>"-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">namespace="com.ruoyi.quartz.mapper.BusTableMapper"> "TableInfoResult" type="com.ruoyi.quartz.domain.TableInfo"> "table" column="Table"/> "createTable" column="Create Table"/> "createTableSql" parameterType="int"> ${sql} <select id="showCreateTable" resultMap="TableInfoResult" parameterType="string"> ${sql} select>
将Create Table字段的返回值映射到createTable字段。
3、这里定时任务使用的若依集成的quartz实现，在定时任务的具体实现类中
package com.ruoyi.quartz.task;
import com.ruoyi.quartz.constants.TableConstant;
import com.ruoyi.quartz.domain.TableInfo;
import com.ruoyi.quartz.mapper.BusTableMapper;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.Date;
//动态创建表定时任务
@Component("createTableTask")
public class CreateTableTask {
@Autowired
private BusTableMapper busTableMapper;
private static SimpleDateFormat simpleDateFormat = new SimpleDateFormat("YYYYMMdd");
public void creatTable(){
TableInfo tableInfo = busTableMapper.showCreateTable(TableConstant.SHOW_CREATE_TABLE_SQL + TableConstant.TABLE_EXAMPLE);
String createTableString = tableInfo.getCreateTable().replace("CREATE TABLE", "CREATE TABLE IF NOT EXISTS ").replace(TableConstant.TABLE_EXAMPLE, TableConstant.TABLE_EXAMPLE + simpleDateFormat.format(DateUtils.addDays(new Date(), 1)));
tableInfo.setCreateTable(createTableString);
busTableMapper.createTableSql(tableInfo.getCreateTable());
}
}
这里将表名和查看创建表的语句分别用常量替代
package com.ruoyi.quartz.constants;
public class TableConstant {
public static final String SHOW_CREATE_TABLE_SQL = "show create table ";
public static final String TABLE_EXAMPLE = "bus_badao_record";
}
然后配置定时任务的执行频率和开关可以通过若依自带的页面中配置和实现
然后执行第一步获取的tableInfo为
此时createTable中就是具体的建表语句，内容为
CREATE TABLE bus_badao_record (
id int NOT NULL AUTO_INCREMENT,
x varchar(255) DEFAULT NULL,
y varchar(255) DEFAULT NULL,
record_time datetime DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT charset=utf8mb3
然后将建表字符串中的CREATE TABLE替换成CREATE TABLE IF NOT EXISTS
确保在执行创建新的表之前是不存在的。
然后将表名替换成待明天的时间标识的表名。然后该建表语句就会变成
CREATE TABLE IF NOT EXISTS bus_badao_record20220805 (
id int NOT NULL AUTO_INCREMENT,
x varchar(255) DEFAULT NULL,
y varchar(255) DEFAULT NULL,
record_time datetime DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT charset=utf8mb3
这样就可以通过设置定时任务，让其指定一个时间比如12小时创建明天的表。
4、执行一遍该定时任务的效果
Original: https://www.cnblogs.com/badaoliumangqizhi/p/16550979.html
Author: 霸道流氓
Title: SpringBoot+Mybatis实现代码获取建表语句并实现动态建表
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/541023/
转载文章受原作者版权保护。转载请注明原作者出处！