SQL數(shù)據(jù)分表Mybatis?Plus動態(tài)表名優(yōu)方案
一、應(yīng)用場景
大家在使用Mybatis進行開發(fā)的時候,經(jīng)常會遇到一種情況:按照月份month將數(shù)據(jù)放在不同的表里面,查詢數(shù)據(jù)的時候需要跟不同的月份month去查詢不同的表。
但是我們都知道,Mybatis是ORM持久層框架,即:實體關(guān)系映射,實體Object與數(shù)據(jù)庫表之間是存在一一對應(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 實體類與student表是一一對應(yīng)的關(guān)系,如果我們希望將學(xué)員表按照月份進行分表,比如:student_202206、student_202207、student_202208,即產(chǎn)生了**「一個實體類及其Mapper需要操作多個數(shù)據(jù)庫分月表,這種情況在Mybatis plus下我們該如何操作數(shù)據(jù)呢?」** 其實方法有很多,我將我實踐中總結(jié)出的最優(yōu)方案給大家進行說明。
二、動態(tài)表名處理器接口實現(xiàn)
為了處理上述類似的問題,mybatis plus提供了動態(tài)表名處理器接口TableNameHandler
,我們只需要實現(xiàn)這個接口,并將這個接口應(yīng)用配置生效,即可實現(xiàn)動態(tài)表名。
需要注意的是:
- 在mybatis plus 3.4版本之前,動態(tài)表名處理器接口是
ITableNameHandler
, 需要配合mybatis plus分頁插件一起使用才能生效。我們這里只介紹3.4版本之后的實現(xiàn)方式。- 在mybatis plus 3.4.3.2 作廢該的方式:dynamicTableNameInnerInterceptor.setTableNameHandlerMap(map); 大家如果見到這種方式實現(xiàn)的動態(tài)表名,也是過時的實現(xiàn)方法,新版本中該方法已經(jīng)刪除。
經(jīng)過我一段時間的實踐總結(jié),我的實現(xiàn)類如下(基于mybatis plus 3.4.3.2之后的版本):
import?com.baomidou.mybatisplus.extension.plugins.handler.TableNameHandler; import?java.util.Arrays; import?java.util.List; /** ?*?按月份參數(shù),組成動態(tài)表名 ?*/ public?class?MonthTableNameHandler?implements?TableNameHandler?{ ????//用于記錄哪些表可以使用該月份動態(tài)表名處理器(即哪些表按月分表) ????private?List<String>?tableNames; ????//構(gòu)造函數(shù),構(gòu)造動態(tài)表名處理器的時候,傳遞tableNames參數(shù) ????public?MonthTableNameHandler(String?...tableNames)?{ ????????this.tableNames?=?Arrays.asList(tableNames); ????} ????//每個請求線程維護一個month數(shù)據(jù),避免多線程數(shù)據(jù)沖突。所以使用ThreadLocal ????private?static?final?ThreadLocal<String>?MONTH_DATA?=?new?ThreadLocal<>(); ????//設(shè)置請求線程的month數(shù)據(jù) ????public?static?void?setData(String?month)?{ ????????MONTH_DATA.set(month); ????} ????//刪除當前請求線程的month數(shù)據(jù) ????public?static?void?removeData()?{ ????????MONTH_DATA.remove(); ????} ????//動態(tài)表名接口實現(xiàn)方法 ????@Override ????public?String?dynamicTableName(String?sql,?String?tableName)?{ ????????if?(this.tableNames.contains(tableName)){ ????????????return?tableName?+?"_"?+?MONTH_DATA.get();??//表名增加月份后綴 ????????}else{ ????????????return?tableName;???//表名原樣返回 ????????} ????} }
大家先對上面的代碼有一個基礎(chǔ)了解,看了下面的測試過程,再回頭看上面的代碼中的注釋,就比較好理解了。表名處理器寫好了之后,我們要讓它生效,還需要做如下的配置。配置內(nèi)容照葫蘆畫瓢就可以了。需要關(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( ????????????????//可以傳多個表名參數(shù),指定哪些表使用MonthTableNameHandler處理表名稱 ????????????????new?MonthTableNameHandler("student","teacher")? ????????); ????????//以攔截器的方式處理表名稱 ????????interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor); ????????//可以傳遞多個攔截器,即:可以傳遞多個表名處理器TableNameHandler ????????//interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor); ????????return?interceptor; ????} }
三、測試實現(xiàn)效果
首先創(chuàng)建一個StudentMapper ,默認情況下StudentMapper 只能操作student表,不能操作student_YYYYMM表。
@Mapper public?interface?StudentMapper?extends?BaseMapper<Student>?{}
下面我們來寫一個單元測試用例,該測試用例test函數(shù)模擬一次請求訪問的Controller或者service函數(shù)。
@SpringBootTest class?DynamicTableNameTest?{ ????@Resource ????private?StudentMapper?studentMapper; ????@Test ????void?test()?{ ????????//執(zhí)行數(shù)據(jù)操作之前設(shè)置月份(實際場景下該參數(shù)從請求參數(shù)中解析) ????????MonthTableNameHandler.setData("202208"); ????????studentMapper.selectById(1);?//以id=2查詢student_202208這張表 ????????//閱后即焚,將ThreadLocal當前請求線程的數(shù)據(jù)移除 ????????MonthTableNameHandler.removeData(); ????} }
當我們執(zhí)行這個單元測試用例的時候,我們發(fā)現(xiàn)控制臺打印出如下信息,注意看SQL的部分,真的是去查詢student_202208這張表了,而不是student表。這說明我們的動態(tài)表名實現(xiàn)是成功的。
到此這篇關(guān)于SQL數(shù)據(jù)分表Mybatis Plus動態(tài)表名優(yōu)方案的文章就介紹到這了,更多相關(guān)Mybatis Plus優(yōu)化內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- MyBatis實現(xiàn)Mysql數(shù)據(jù)庫分庫分表操作和總結(jié)(推薦)
- 簡單易懂的MyBatis分庫分表方案分享
- Spring Boot 集成 Sharding-JDBC + Mybatis-Plus 實現(xiàn)分庫分表功能
- Mybatis-plus使用TableNameHandler分表詳解(附完整示例源碼)
- Mybatis實現(xiàn)分表插件
- springboot+mybatis-plus基于攔截器實現(xiàn)分表的示例代碼
- 詳解mybatis如何實現(xiàn)進行分表
- Mybatis-Plus集成Sharding-JDBC與Flyway實現(xiàn)多租戶分庫分表實戰(zhàn)
- Mybatis攔截器實現(xiàn)一種百萬級輕量分表方案
相關(guān)文章
詳解MySQL誤操作后怎樣進行數(shù)據(jù)恢復(fù)
在大家日常操作數(shù)據(jù)庫時候難免會因為“大意”而誤操作,那么誤操作后怎樣進行數(shù)據(jù)恢復(fù)呢,下面跟著小編一起來學(xué)習(xí)學(xué)習(xí)。2016-08-08使用xshell實現(xiàn)代理功能并navicat?for?MySQL?進行測試
本文介紹使用xshell實現(xiàn)代理功能并使用navicat?for?MySQL進行測試,文章主要利用SSH連接工具xshell就可以實現(xiàn)簡單的代理功能,下面實現(xiàn)過程,需要的小伙伴可以參考一下2022-02-02HeidiSQL工具導(dǎo)出導(dǎo)入MySQL數(shù)據(jù)
這篇文章主要為大家詳細介紹了HeidiSQL工具導(dǎo)出導(dǎo)入MySQL數(shù)據(jù),具有一定的參考價值,感興趣的小伙伴們可以參考一下2019-05-05MySQL數(shù)據(jù)庫存儲引擎和分支現(xiàn)狀分析
在MySQL經(jīng)歷了2008年Sun的收購和2009年Oracle收購Sun的過程中,基本處于停滯發(fā)展的情況,在可以預(yù)見的未來,MySQL是肯定會被Oracle擱置并且逐步雪藏消滅掉的。2011-03-03