SQL數(shù)據(jù)分表Mybatis?Plus動(dòng)態(tài)表名優(yōu)方案
一、應(yīng)用場(chǎng)景
大家在使用Mybatis進(jìn)行開(kāi)發(fā)的時(shí)候,經(jīng)常會(huì)遇到一種情況:按照月份month將數(shù)據(jù)放在不同的表里面,查詢(xún)數(shù)據(jù)的時(shí)候需要跟不同的月份month去查詢(xún)不同的表。
但是我們都知道,Mybatis是ORM持久層框架,即:實(shí)體關(guān)系映射,實(shí)體Object與數(shù)據(jù)庫(kù)表之間是存在一一對(duì)應(yīng)的映射關(guān)系。
比如:
@Data
public?class?Student?{
????private?Integer?id;
????private?String?stuName;
????private?Integer?age;
}表結(jié)構(gòu):
CREATE?TABLE?`student`?( ????`id`?INT(11)?NOT?NULL?AUTO_INCREMENT, ????`stu_name`?VARCHAR(64)?NOT?NULL?DEFAULT?'0'?COMMENT?'姓名', ????`age`?INT(11)?NOT?NULL?COMMENT?'年齡', ????PRIMARY?KEY?(`id`) ) COMMENT='學(xué)生表' COLLATE='utf8_general_ci' ENGINE=InnoDB ;
Student 實(shí)體類(lèi)與student表是一一對(duì)應(yīng)的關(guān)系,如果我們希望將學(xué)員表按照月份進(jìn)行分表,比如:student_202206、student_202207、student_202208,即產(chǎn)生了**「一個(gè)實(shí)體類(lèi)及其Mapper需要操作多個(gè)數(shù)據(jù)庫(kù)分月表,這種情況在Mybatis plus下我們?cè)撊绾尾僮鲾?shù)據(jù)呢?」** 其實(shí)方法有很多,我將我實(shí)踐中總結(jié)出的最優(yōu)方案給大家進(jìn)行說(shuō)明。
二、動(dòng)態(tài)表名處理器接口實(shí)現(xiàn)
為了處理上述類(lèi)似的問(wèn)題,mybatis plus提供了動(dòng)態(tài)表名處理器接口TableNameHandler,我們只需要實(shí)現(xiàn)這個(gè)接口,并將這個(gè)接口應(yīng)用配置生效,即可實(shí)現(xiàn)動(dòng)態(tài)表名。
需要注意的是:
- 在mybatis plus 3.4版本之前,動(dòng)態(tài)表名處理器接口是
ITableNameHandler, 需要配合mybatis plus分頁(yè)插件一起使用才能生效。我們這里只介紹3.4版本之后的實(shí)現(xiàn)方式。- 在mybatis plus 3.4.3.2 作廢該的方式:dynamicTableNameInnerInterceptor.setTableNameHandlerMap(map); 大家如果見(jiàn)到這種方式實(shí)現(xiàn)的動(dòng)態(tài)表名,也是過(guò)時(shí)的實(shí)現(xiàn)方法,新版本中該方法已經(jīng)刪除。
經(jīng)過(guò)我一段時(shí)間的實(shí)踐總結(jié),我的實(shí)現(xiàn)類(lèi)如下(基于mybatis plus 3.4.3.2之后的版本):
import?com.baomidou.mybatisplus.extension.plugins.handler.TableNameHandler;
import?java.util.Arrays;
import?java.util.List;
/**
?*?按月份參數(shù),組成動(dòng)態(tài)表名
?*/
public?class?MonthTableNameHandler?implements?TableNameHandler?{
????//用于記錄哪些表可以使用該月份動(dòng)態(tài)表名處理器(即哪些表按月分表)
????private?List<String>?tableNames;
????//構(gòu)造函數(shù),構(gòu)造動(dòng)態(tài)表名處理器的時(shí)候,傳遞tableNames參數(shù)
????public?MonthTableNameHandler(String?...tableNames)?{
????????this.tableNames?=?Arrays.asList(tableNames);
????}
????//每個(gè)請(qǐng)求線程維護(hù)一個(gè)month數(shù)據(jù),避免多線程數(shù)據(jù)沖突。所以使用ThreadLocal
????private?static?final?ThreadLocal<String>?MONTH_DATA?=?new?ThreadLocal<>();
????//設(shè)置請(qǐng)求線程的month數(shù)據(jù)
????public?static?void?setData(String?month)?{
????????MONTH_DATA.set(month);
????}
????//刪除當(dāng)前請(qǐng)求線程的month數(shù)據(jù)
????public?static?void?removeData()?{
????????MONTH_DATA.remove();
????}
????//動(dòng)態(tài)表名接口實(shí)現(xiàn)方法
????@Override
????public?String?dynamicTableName(String?sql,?String?tableName)?{
????????if?(this.tableNames.contains(tableName)){
????????????return?tableName?+?"_"?+?MONTH_DATA.get();??//表名增加月份后綴
????????}else{
????????????return?tableName;???//表名原樣返回
????????}
????}
}大家先對(duì)上面的代碼有一個(gè)基礎(chǔ)了解,看了下面的測(cè)試過(guò)程,再回頭看上面的代碼中的注釋?zhuān)捅容^好理解了。表名處理器寫(xiě)好了之后,我們要讓它生效,還需要做如下的配置。配置內(nèi)容照葫蘆畫(huà)瓢就可以了。需要關(guān)注的部分,我都已經(jīng)給大家添加了注釋。
@Configuration
@MapperScan("com.zimug")
public?class?MybatisPlusConfig?{
????@Bean
????public?MybatisPlusInterceptor?mybatisPlusInterceptor()?{
????????MybatisPlusInterceptor?interceptor?=?new?MybatisPlusInterceptor();
????????DynamicTableNameInnerInterceptor?dynamicTableNameInnerInterceptor?=?new?DynamicTableNameInnerInterceptor();
????????dynamicTableNameInnerInterceptor.setTableNameHandler(
????????????????//可以傳多個(gè)表名參數(shù),指定哪些表使用MonthTableNameHandler處理表名稱(chēng)
????????????????new?MonthTableNameHandler("student","teacher")?
????????);
????????//以攔截器的方式處理表名稱(chēng)
????????interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);
????????//可以傳遞多個(gè)攔截器,即:可以傳遞多個(gè)表名處理器TableNameHandler
????????//interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);
????????return?interceptor;
????}
}三、測(cè)試實(shí)現(xiàn)效果
首先創(chuàng)建一個(gè)StudentMapper ,默認(rèn)情況下StudentMapper 只能操作student表,不能操作student_YYYYMM表。
@Mapper
public?interface?StudentMapper?extends?BaseMapper<Student>?{}下面我們來(lái)寫(xiě)一個(gè)單元測(cè)試用例,該測(cè)試用例test函數(shù)模擬一次請(qǐng)求訪問(wèn)的Controller或者service函數(shù)。
@SpringBootTest
class?DynamicTableNameTest?{
????@Resource
????private?StudentMapper?studentMapper;
????@Test
????void?test()?{
????????//執(zhí)行數(shù)據(jù)操作之前設(shè)置月份(實(shí)際場(chǎng)景下該參數(shù)從請(qǐng)求參數(shù)中解析)
????????MonthTableNameHandler.setData("202208");
????????studentMapper.selectById(1);?//以id=2查詢(xún)student_202208這張表
????????//閱后即焚,將ThreadLocal當(dāng)前請(qǐng)求線程的數(shù)據(jù)移除
????????MonthTableNameHandler.removeData();
????}
}當(dāng)我們執(zhí)行這個(gè)單元測(cè)試用例的時(shí)候,我們發(fā)現(xiàn)控制臺(tái)打印出如下信息,注意看SQL的部分,真的是去查詢(xún)student_202208這張表了,而不是student表。這說(shuō)明我們的動(dòng)態(tài)表名實(shí)現(xiàn)是成功的。

到此這篇關(guān)于SQL數(shù)據(jù)分表Mybatis Plus動(dòng)態(tài)表名優(yōu)方案的文章就介紹到這了,更多相關(guān)Mybatis Plus優(yōu)化內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- MyBatis實(shí)現(xiàn)Mysql數(shù)據(jù)庫(kù)分庫(kù)分表操作和總結(jié)(推薦)
- 簡(jiǎn)單易懂的MyBatis分庫(kù)分表方案分享
- Spring Boot 集成 Sharding-JDBC + Mybatis-Plus 實(shí)現(xiàn)分庫(kù)分表功能
- Mybatis-plus使用TableNameHandler分表詳解(附完整示例源碼)
- Mybatis實(shí)現(xiàn)分表插件
- springboot+mybatis-plus基于攔截器實(shí)現(xiàn)分表的示例代碼
- 詳解mybatis如何實(shí)現(xiàn)進(jìn)行分表
- Mybatis-Plus集成Sharding-JDBC與Flyway實(shí)現(xiàn)多租戶(hù)分庫(kù)分表實(shí)戰(zhàn)
- Mybatis攔截器實(shí)現(xiàn)一種百萬(wàn)級(jí)輕量分表方案
相關(guān)文章
詳解MySQL誤操作后怎樣進(jìn)行數(shù)據(jù)恢復(fù)
在大家日常操作數(shù)據(jù)庫(kù)時(shí)候難免會(huì)因?yàn)椤按笠狻倍`操作,那么誤操作后怎樣進(jìn)行數(shù)據(jù)恢復(fù)呢,下面跟著小編一起來(lái)學(xué)習(xí)學(xué)習(xí)。2016-08-08
使用xshell實(shí)現(xiàn)代理功能并navicat?for?MySQL?進(jìn)行測(cè)試
本文介紹使用xshell實(shí)現(xiàn)代理功能并使用navicat?for?MySQL進(jìn)行測(cè)試,文章主要利用SSH連接工具xshell就可以實(shí)現(xiàn)簡(jiǎn)單的代理功能,下面實(shí)現(xiàn)過(guò)程,需要的小伙伴可以參考一下2022-02-02
HeidiSQL工具導(dǎo)出導(dǎo)入MySQL數(shù)據(jù)
這篇文章主要為大家詳細(xì)介紹了HeidiSQL工具導(dǎo)出導(dǎo)入MySQL數(shù)據(jù),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-05-05
MySQL數(shù)據(jù)庫(kù)存儲(chǔ)引擎和分支現(xiàn)狀分析
在MySQL經(jīng)歷了2008年Sun的收購(gòu)和2009年Oracle收購(gòu)Sun的過(guò)程中,基本處于停滯發(fā)展的情況,在可以預(yù)見(jiàn)的未來(lái),MySQL是肯定會(huì)被Oracle擱置并且逐步雪藏消滅掉的。2011-03-03
深入分析MySQL Sending data查詢(xún)慢問(wèn)題
給大家深入分析一下MySQL Sending data表查詢(xún)慢的問(wèn)題,并給出了詳細(xì)的解決方案,一起來(lái)參考下。2017-12-12

