您好,登錄后才能下訂單哦!
一、引言
先來說下動(dòng)態(tài)名表在什么場(chǎng)景下需要使用呢?
拿小編的實(shí)際項(xiàng)目來說,小編公司手里掌握著國內(nèi)各個(gè)部分地區(qū)的醫(yī)院患者數(shù)據(jù),那么一個(gè)醫(yī)院的患者的數(shù)據(jù)流量肯定是很大的,這個(gè)時(shí)候如果全部放在同一張表中,那么可想而知數(shù)據(jù)量的龐大。所以數(shù)據(jù)庫設(shè)計(jì)的時(shí)候可以一家醫(yī)院對(duì)應(yīng)一張表,分開來存儲(chǔ),表中的列名都是一樣的,只是表名不同。
或者還可以做日志的存儲(chǔ),日志數(shù)據(jù)量也是很大的,可以分一個(gè)月對(duì)應(yīng)一張表,比如:log_201907、log_201908等等之類的。
二、具體實(shí)現(xiàn)
動(dòng)態(tài)表名SQL解析器也是基于MP分頁插件來實(shí)現(xiàn)的,代碼如下:
package com.example.demo.config; import com.baomidou.mybatisplus.core.parser.ISqlParser; import com.baomidou.mybatisplus.core.parser.ISqlParserFilter; import com.baomidou.mybatisplus.core.parser.SqlParserHelper; import com.baomidou.mybatisplus.extension.parsers.DynamicTableNameParser; import com.baomidou.mybatisplus.extension.parsers.ITableNameHandler; import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor; import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor; import com.baomidou.mybatisplus.extension.plugins.PerformanceInterceptor; import com.baomidou.mybatisplus.extension.plugins.tenant.TenantHandler; import com.baomidou.mybatisplus.extension.plugins.tenant.TenantSqlParser; import net.sf.jsqlparser.expression.Expression; import net.sf.jsqlparser.expression.StringValue; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.reflection.MetaObject; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Profile; import java.util.*; /** * @Auther: IT賤男 * @Date: 2019/6/12 15:06 * @Description: MybatisPlus配置類 */ @Configuration public class MyBatisPlusConfig { /** * 分頁插件 * * @return */ @Bean public PaginationInterceptor paginationInterceptor() { PaginationInterceptor paginationInterceptor = new PaginationInterceptor(); // 創(chuàng)建SQL解析器集合 List<ISqlParser> sqlParserList = new ArrayList<>(); // 動(dòng)態(tài)表名SQL解析器 DynamicTableNameParser dynamicTableNameParser = new DynamicTableNameParser(); Map<String,ITableNameHandler> tableNameHandlerMap = new HashMap<>(); // Map的key就是需要替換的原始表名 tableNameHandlerMap.put("sys_user",new ITableNameHandler(){ @Override public String dynamicTableName(MetaObject metaObject, String sql, String tableName) { // 自定義表名規(guī)則,或者從配置文件、request上下文中讀取 // 假設(shè)這里的用戶表根據(jù)年份來進(jìn)行分表操作 Date date = new Date(); String year = String.format("%tY", date); // 返回最后需要操作的表名,sys_user_2019 return "sys_user_" + year; } }); dynamicTableNameParser.setTableNameHandlerMap(tableNameHandlerMap); sqlParserList.add(dynamicTableNameParser); paginationInterceptor.setSqlParserList(sqlParserList); return paginationInterceptor; } }
代碼演示:MP會(huì)針對(duì)配置的表名做動(dòng)態(tài)解析,從sql中可以看出表名已經(jīng)替換成sys_user_2019了。
@Test public void select(){ List<User> users = userMapper.selectList(Wrappers.<User>lambdaQuery().eq(User::getAge, 18)); users.forEach(System.out::println); } INFOStarted UserMapperTest in 3.409 seconds (JVM running for 4.233) DEBUG==> Preparing: SELECT id, login_name, name, password, email, salt, sex, age, phone, user_type, status, organization_id, create_time, update_time, version, tenant_id FROM sys_user_2019 WHERE sys_user_2019.tenant_id = 'jiannan' AND is_delete = '0' AND age = ? DEBUG==> Parameters: 18(Integer)
三、注意細(xì)節(jié)
細(xì)節(jié)一:如果自定義規(guī)則的表名返回為空,則會(huì)按照實(shí)際的表名來處理。
細(xì)節(jié)二:如果配置了多租戶SQL解析器,過濾了特定的sql,則也會(huì)按照實(shí)際表名來處理。
如下代碼使用了@SqlParser注解來過濾這條sql不需要加租戶ID,執(zhí)行這條sql的時(shí)候同樣也會(huì)把動(dòng)態(tài)表名SQL解析也會(huì)過濾掉,按照實(shí)際表名處理,MP可能后續(xù)版本會(huì)進(jìn)行改進(jìn)。
/** * <p> * 用戶 Mapper 接口 * </p> * * @author IT賤男 * @since 2019-06-14 */ public interface UserMapper extends BaseMapper<User> { /** * 自定Wrapper修改 * * @param userWrapper 條件構(gòu)造器 * @param user 修改的對(duì)象參數(shù) * @return */ @SqlParser(filter = true) int updateByMyWrapper(@Param(Constants.WRAPPER) Wrapper<User> userWrapper, @Param("user") User user); }
到此這篇關(guān)于MyBatis-Plus 動(dòng)態(tài)表名SQL解析器的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)MyBatis-Plus 動(dòng)態(tài)表名SQL解析器內(nèi)容請(qǐng)搜索億速云以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持億速云!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。