快捷導(dǎo)航

MyBatis實(shí)現(xiàn)簡單的數(shù)據(jù)表分月存儲

更新時(shí)間：2023年03月17日 15:56:14 作者：Stephen GS

本文主要介紹了MyBatis實(shí)現(xiàn)簡單的數(shù)據(jù)表分月存儲，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前言

今天介紹的一個(gè)業(yè)務(wù)場景主要是數(shù)據(jù)表過大時(shí)，需要按月份進(jìn)行分月數(shù)據(jù)存儲。例如用戶操作記錄表 us_record，可以按月份進(jìn)行劃分，us_record_2022_11, us_record_2022_12 等。
以下內(nèi)容是基于 SpringBoot + MyBatis實(shí)現(xiàn)的

一、簡單的思路分析和代碼

進(jìn)行數(shù)據(jù)分月存儲時(shí)，先要判斷進(jìn)入程序時(shí)是否已存在記錄對應(yīng)的月度表。

若為第一次進(jìn)入需要根據(jù)對應(yīng)的區(qū)分字符創(chuàng)建數(shù)據(jù)表
若已創(chuàng)建記錄表，需要根據(jù)區(qū)分字符動態(tài)插入數(shù)據(jù)

1.1 判斷是否存在對應(yīng)的月度表

這里以年度_月份為區(qū)分

LocalDate now = LocalDate.now();
String tableName = new StringBuilder().append(" us_record").append("_").append(now.getYear()).append("_").append(now.getMonthValue()).toString();
if(usDataRecordMapper.countTableNum(DATABASE, tableName) == 0){ // 若數(shù)據(jù)庫中不存在,則新建對應(yīng)的表
      usDataRecordMapper.createTable(tableName);
}

如何判斷數(shù)據(jù)庫中是否存在某張表

編寫接口定義

// database：對應(yīng)的數(shù)據(jù)庫  table：對應(yīng)的表名
int countTableNum(@Param("database") String database, @Param("table") String table);

編寫sql 實(shí)現(xiàn) (對應(yīng)的數(shù)據(jù)庫下有多少個(gè)該名字的數(shù)據(jù)表)

<select id="countTableNum" resultType="java.lang.Integer">
    select count(*) from information_schema.TABLES t
    where t.TABLE_SCHEMA = #{database}
        and t.TABLE_NAME = #{table}
 </select>

1.2 根據(jù)月份區(qū)分創(chuàng)建表

編寫接口定義

// 按月份為后綴創(chuàng)建對應(yīng)的數(shù)據(jù)庫表
int createTable(@Param("tableName") String tableName);

編寫sql 實(shí)現(xiàn)

?<update id="createTable">
? ? ? CREATE TABLE us.${tableName}
? ? ? (
? ? ? ? ? `id` ? ? ? ? ? ? ?int(11) NOT NULL AUTO_INCREMENT,
? ? ? ? ? `app_type` ? ? ? ?int(4) NOT NULL COMMENT '來源 1:pc 3: 安卓 4: ios',
? ? ? ? ? `event_type` ? ? ?int(4) DEFAULT '1' COMMENT '事件類型 1：下載 2：視頻時(shí)長',
? ? ? ? ? `business_type` ? int(4) DEFAULT NULL COMMENT '業(yè)務(wù)類型: ?1：課程資料 2：復(fù)習(xí)資料 ?3：直播 4：錄播 5：回放',
? ? ? ? ? `online_duration` int(4) DEFAULT NULL,
? ? ? ? ? `mapping_id` ? ? ?varchar(255) NOT NULL DEFAULT '' COMMENT '關(guān)聯(lián)id',
? ? ? ? ? `user_id` ? ? ? ? varchar(150) NOT NULL DEFAULT '' COMMENT '用戶id',
? ? ? ? ? `create_time` ? ? datetime ? ? ? ? ? ? ?DEFAULT CURRENT_TIMESTAMP COMMENT '創(chuàng)建時(shí)間',
? ? ? ? ? `unit` ? ? ? ? ? ?int(4) DEFAULT NULL COMMENT '單位 : 1/次數(shù) 2/分鐘 3/秒',
? ? ? ? ? `learn_id` ? ? ? ?varchar(150) ? ? ? ? ?DEFAULT NULL,
? ? ? ? ? PRIMARY KEY (`id`)
? ? ? ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='用戶相關(guān)記錄表';

? </update>

1.3 根據(jù)月份插入數(shù)據(jù)表

編寫接口定義

// 根據(jù)月份插入對應(yīng)的用戶相關(guān)記錄表 UsDataRecord：對應(yīng)的用戶操作記錄
int insertData(@Param("record") UsDataRecord usDataRecord, @Param("tableName") String tableName);

編寫sql 實(shí)現(xiàn) (根據(jù)自己的業(yè)務(wù)補(bǔ)充插入語句)

<insert id="insertData">
      insert into us.${tableName}
      ..........
 </insert>

1.4 完整的使用流程

// Step1: 判斷是否存在對應(yīng)月度表
LocalDate now = LocalDate.now();
String tableName = new StringBuilder().append(TABLE_NAME).append("_").append(now.getYear()).append("_").append(now.getMonthValue()).toString();

if(usDataRecordMapper.countTableNum(DATABASE, tableName) == 0){ // 若數(shù)據(jù)庫中不存在,則新建對應(yīng)的表
? ?// Step2: 創(chuàng)建對應(yīng)數(shù)據(jù)的月度表?? ?
? ?usDataRecordMapper.createTable(tableName);
}

// Step3: 往對應(yīng)月度表插入數(shù)據(jù)
usDataRecordMapper.insertData(usDataRecord, tableName);

到此這篇關(guān)于MyBatis實(shí)現(xiàn)簡單的數(shù)據(jù)表分月存儲的文章就介紹到這了,更多相關(guān)MyBatis 數(shù)據(jù)表分月存儲內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: