先来说下动态名表在什么场景下需要使用呢?
拿小编的实际项目来说,小编公司手里掌握着国内各个部分地区的医院患者数据,那么一个医院的患者的数据流量肯定是很大的,这个时候如果全部放在同一张表中,那么可想而知数据量的庞大。所以数据库设计的时候可以一家医院对应一张表,分开来存储,表中的列名都是一样的,只是表名不同。
或者还可以做日志的存储,日志数据量也是很大的,可以分一个月对应一张表,比如:log_201907, log_201908等等之类的。
动态表名SQL解析器也是基于议员分页插件来实现的,代码如下:
包com.example.demo.config;
进口com.baomidou.mybatisplus.core.parser.ISqlParser;
进口com.baomidou.mybatisplus.core.parser.ISqlParserFilter;
进口com.baomidou.mybatisplus.core.parser.SqlParserHelper;
进口com.baomidou.mybatisplus.extension.parsers.DynamicTableNameParser;
进口com.baomidou.mybatisplus.extension.parsers.ITableNameHandler;
进口com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
进口com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
进口com.baomidou.mybatisplus.extension.plugins.PerformanceInterceptor;
进口com.baomidou.mybatisplus.extension.plugins.tenant.TenantHandler;
进口com.baomidou.mybatisplus.extension.plugins.tenant.TenantSqlParser;
进口net.sf.jsqlparser.expression.Expression;
进口net.sf.jsqlparser.expression.StringValue;
进口org.apache.ibatis.mapping.MappedStatement;
进口org.apache.ibatis.reflection.MetaObject;
进口org.springframework.context.annotation.Bean;
进口org.springframework.context.annotation.Configuration;
进口org.springframework.context.annotation.Profile;
进口java.util。*;/* *
* @Auther:贱男
* @Date: 2019/6/12 15:06
* @Description: MybatisPlus配置类
*/@ configuration
公开课MyBatisPlusConfig {/* *
* 分页插件
*
* @return
*/@ bean
公共PaginationInterceptor PaginationInterceptor () {
PaginationInterceptor PaginationInterceptor=new PaginationInterceptor ();//创建SQL解析器集合
List,sqlParserList=new ArrayList<的在();//动态表名SQL解析器
DynamicTableNameParser DynamicTableNameParser=new DynamicTableNameParser ();
ITableNameHandler> Map<字符串;,tableNameHandlerMap=new HashMap<的在();//映射的键就是需要替换的原始表名
tableNameHandlerMap。把(“sys_user”,新的ITableNameHandler () {
@Override
公共字符串dynamicTableName (MetaObject MetaObject sql字符串,字符串表){//自定义表名规则,或者从配置文件,请求上下文中读?/假设这里的用户表根据年份来进行分表操作
日期日期=new日期();
字符串年=字符串。格式(“%泰”,日期);//返回最后需要操作的表名,sys_user_2019
返回“sys_user_”+一年;
}
});
dynamicTableNameParser.setTableNameHandlerMap (tableNameHandlerMap);
sqlParserList.add (dynamicTableNameParser);
paginationInterceptor.setSqlParserList (sqlParserList);
返回paginationInterceptor;
}
}
代码演示:议员会针对配置的表名做动态解析,从sql中可以看出表名已经替换成sys_user_2019了。
@Test
公共空间select () {
List用户=userMapper.selectList(包装。你们;User> lambdaQuery ()。eq(用户::getAge, 18));
users.forEach (system . out:: println);
}
INFOStarted UserMapperTest 3.409秒(4.233 JVM运行)
DEBUG==比;准备:选择id、login_name名、密码、电子邮件、盐、性别、年龄、电话、user_type,地位,organization_id, create_time, update_time,版本,tenant_id sys_user_2019 sys_user_2019的地方。tenant_id=癹iannan”和is_delete=' 0 '和年龄=& # 63;
DEBUG==比;参数:18(整数)
之前
细节一:如果自定义规则的表名返回为空,则会按照实际的表名来处理。
细节二:如果配置了多租户SQL解析器,过滤了特定的SQL,则也会按照实际表名来处理。
如下代码使用了@SqlParser注解来过滤这条sql不需要加租户ID,执行这条sql的时候同样也会把动态表名sql解析也会过滤掉,按照实际表名处理,议员可能后续版本会进行改进。
/* *
* & lt; p>
*用户Mapper接口
* & lt;/p>
*
* @author这贱男
* @since 2019-06-14
*/公共接口usermap延伸BaseMapper
