jeecgboot按字段分表_jeecgboot 分表-程序员宅基地

技术标签: jeecgboot分表  javaWeb知识  mybatis分表  mysql分表实现  

在jeecgboot 使用mybatis框架,mybatis-plus3.1.1后支持分表,以下是在jeecg项目中实行分表
一、修改mybatis-plus版本后,必须要在3.1.1版本后

 <dependency>
    <groupId>com.baomidou</groupId>
     <artifactId>mybatis-plus-core</artifactId>
     <version>3.1.2</version>
 </dependency>
<dependency>
	<groupId>com.baomidou</groupId>
	<artifactId>mybatis-plus-extension</artifactId>
	<version>3.1.2</version>
</dependency>

二、修改entity实体把@TableName注释掉

@Data
//@TableName("empss_visual_meter_usage_hour")
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value="empss_visual_meter_usage_hour对象", description="表具每小时用量")
public class UsageHour{
    
/**统计时间*/
	@Excel(name = "统计时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "统计时间")
	private java.util.Date statTime;
	/**表具编号*/
	@Excel(name = "表具编号", width = 15)
    @ApiModelProperty(value = "表具编号")
	private java.lang.String code;
}

其他的controller、service、mapperd类等不需要改变

三、修改MybatisPlusConfig配置类paginationInterceptor()方法

@Bean
    public PaginationInterceptor paginationInterceptor() {
    
//        return new PaginationInterceptor();
    	PaginationInterceptor paginationInterceptor = new PaginationInterceptor();
        DynamicTableNameParser dynamicTableNameParser = new DynamicTableNameParser();
        dynamicTableNameParser.setTableNameHandlerMap(new HashMap<String, ITableNameHandler>(2) {
    {
    
           //实现entity中usageHour类分表,这里按statTime,statTime为Date类型,分表时要转为年和类,注意usage_hour对应usageHour类的类名
        	put("usage_hour", (metaObject, sql, tableName) -> {
    
                // 通过metaObject 可以获取传入参数,这里实现你自己的动态规则
            	//获取参数
                Object originalObject = metaObject.getOriginalObject();
                JSONObject originalObjectJSON = JSON.parseObject(JSON.toJSONString(originalObject));
                JSONObject boundSql = originalObjectJSON.getJSONObject("boundSql");
                JSONObject parameterObject = boundSql.getJSONObject("parameterObject");
                String valueOf = String.valueOf(parameterObject);
                Long statTime=0L;
                if(valueOf.contains("{\"ew\":{")) {
    
                	statTime=getTimeByEw(parameterObject);
                }else if(valueOf.contains("{\"et\":{")){
    
                	statTime=getTimeByEt(parameterObject);
                }else {
    
                	statTime = parameterObject.getLong("statTime");
                }
                String formatDate = DateUtils.formatDate(statTime);
                String year=formatDate.substring(0, 4);
                //表名
                return "empss_visual_meter_usage_hour_"+year;
            });
        	 //多个entity分表,实现entity中usageDay类分表,
            put("usage_day", (metaObject, sql, tableName) -> {
    
            	//获取参数
            	Object originalObject = metaObject.getOriginalObject();
            	JSONObject originalObjectJSON = JSON.parseObject(JSON.toJSONString(originalObject));
            	JSONObject boundSql = originalObjectJSON.getJSONObject("boundSql");
            	JSONObject parameterObject = boundSql.getJSONObject("parameterObject");
            	String valueOf = String.valueOf(parameterObject);
                Long statTime=0L;
                if(valueOf.contains("{\"ew\":{")) {
    
                	statTime=getTimeByEw(parameterObject);
                }else if(valueOf.contains("{\"et\":{")){
    
                	statTime=getTimeByEt(parameterObject);
                }else {
    
                	// save ,update
                	statTime = parameterObject.getLong("statTime");
                }
                String formatDate = DateUtils.formatDate(statTime);
                String year=formatDate.substring(0, 4);
                return "empss_visual_meter_usage_day_"+year;
            });
            
        }
        	/**
        	   * 使用QueryWrapper<T> query 查询时获取stat_time参数
        	 * @param parameterObject
        	 * @return
        	 */
        	private Long getTimeByEw(JSONObject parameterObject) {
     
        		JSONObject ew=parameterObject.getJSONObject("ew");
            	String sqlSegment = ew.getString("sqlSegment");
            	JSONObject paramNameValuePairs=ew.getJSONObject("paramNameValuePairs");
            	int indexOf = sqlSegment.indexOf("stat_time = #{ew.paramNameValuePairs.");
            	String substring = sqlSegment.substring(indexOf+37, indexOf+37+9);
            	Long statTime = paramNameValuePairs.getLong(substring);
        		return statTime; 
        	}
        	/**
	      	   * 使用saveOrUpdateBatch 批量更新时时获取statTime参数
	      	 * @param parameterObject
	      	 * @return
	      	 */
        	private Long getTimeByEt(JSONObject parameterObject) {
     
        		JSONObject et=parameterObject.getJSONObject("et");
        		Long statTime = et.getLong("statTime");
        		return statTime; 
        	}
			 
        });
        paginationInterceptor.setSqlParserList(Collections.singletonList(dynamicTableNameParser));
        return paginationInterceptor;
    }

四、分表时,应该要按某个字段分表,在增删改查时必须要带了了改字段信息,如果要实行更新ID进行修改和查询,可以在保存实现时加上分表字段信息,例如我按statTime(统计时间分表),我在save方法时,在ID前加上统计时间信息

Date statTime = usageHour.getStatTime();
SimpleDateFormat shortDateFormat = new SimpleDateFormat("yyyy");
String format = shortDateFormat.format(statTime);
usageHour.setId(format+UUID.fastUUID().toString());
usageHourService.save(usageHour);

在queryById或增删改时,更加传入的ID获取不同的表。

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/eakom/article/details/104951373

智能推荐

开源项目,毕业设计_本科毕业设计拿别人的开源代码修改-程序员宅基地

文章浏览阅读1.5w次,点赞35次,收藏385次。自己在网上找的开源项目,比较好分享给大家热门开源项目(包含小四轴、智能手环、光立方、智能车、防丢器等项目)号外!号外!(搞四轴,有这套就足够了!)科研级别的小四轴STM32F4芯片支持WIFI且android手机控制自适应控制就是牛掰!该飞机面向有科研和强烈学习意向的小伙伴们使用,如果只是想玩的话你肯定不会喜欢这套四轴的,主要设计思想是提供一个高性能的控制和姿态算法验证平台,因此..._本科毕业设计拿别人的开源代码修改

Java快速开发框架_若依——Ruoyi添加自己的业务模块_ruoyi java17-程序员宅基地

文章浏览阅读1w次,点赞2次,收藏26次。QQ 1274510382Wechat JNZ_aming商业联盟 QQ群538250800技术搞事 QQ群599020441解决方案 QQ群152889761加入我们 QQ群649347320共享学习 QQ群674240731纪年科技aming网络安全 ,深度学习,嵌入式,机器强化,生物智能,生命科学。叮叮叮:产品已上线 —>关注 官方-微信公众号——济南纪年信息科技有限公司民生项目:商城加盟/娱乐交友/创业商圈/外包兼职开发-项目发布/安全项目:态势感.._ruoyi java17

CISCO 交换机配置 Web浏览器的方式-程序员宅基地

文章浏览阅读9k次,点赞2次,收藏3次。 当利用Console口为交换机设置好IP地址信息并启用HTTP服务后,即可通过支持JAVA的Web浏览器访问交换机,并可通过Web通过浏览器修 改交换机的各种参数并对交换机进行管理。事实上,通过Web界面,可以对交换机的许多重要参数进行修改和设置,并可实时查看交换机的运行状态。不过在利用 Web浏览器访问交换机之前,应当确认已经做好以下准备工作:·在用于管理的计算机中安装T..._思科交换机2960s有web配置吗

ERROR - file: tracker_proto.c, line: 48, server: 127.0.0.1:22122, response status 2 != 0-程序员宅基地

文章浏览阅读2.5w次,点赞2次,收藏6次。报错信息: [2018-09-09 20:33:12] ERROR - file: tracker_proto.c, line: 48, server: 127.0.0.1:22122, response status 2 != 0 [2018-09-09 20:33:12] ERROR - file: tracker_proto.c, line: 48, server: 127.0.0.1:..._error - file: tracker_proto.c, line: 48, server: 172.17.0.1:22122, response

使用matplotlib显示图片(《深度学习入门:基于Python的理论与实现》实践笔记)_matplotlib展示图片-程序员宅基地

文章浏览阅读3.9k次。使用matplotlib显示图片(《深度学习入门:基于Python的理论与实现》实践笔记)一、安装matplotlib库二、导入matplotlib.pyplot库和matplotlib.image库里的imread函数三、实例:显示图片一、安装matplotlib库在命令行使用下面的命令即可:pip install matplotlib二、导入matplotlib.pyplot库和matplotlib.image库里的imread函数在程序开头使用:import matplotlib.pyp_matplotlib展示图片

Subversion实践案例——客户现场模式的分布式开发_开发去客户现场的案例-程序员宅基地

文章浏览阅读1.2k次。基本信息 用户单位:某应用软件研发企业 用户规模:100人以上 组织过程水平:中等 CMMI评审等级:无 Subversion使用时间:1年 客户需求 由于公司每次向新客户提交软件的时候都需要派出一个小规模的团队到客户现场进行一段时间的软件定制和维护。此外,老客户系统的重大升级和功能扩展也需要一个小团队在客户现场进行一段时间的开发。因此,异地开发的配置管理就是一_开发去客户现场的案例

随便推点

(基于matlab自写代码)语音信号的短时分析,计算平均能量,短时过零数_matlab求语音信号短时过零率的函数-程序员宅基地

文章浏览阅读3.2k次。一定时宽的语音信号,其能量的大小随时间有明显的变化。清音段能量比浊音段小得多。短时过零数也可用于语音信号分析中,发浊音时,其语音能量约集中于3kHz以下,而发清音时,多数能量出现在较高频率上。可认为浊音时具有较低的平均过零数,而清音时具有较高的平均过零数,故对一短时语音段计算其短时平均能量及短时平均过零数,就可以区分其中的清音段和浊音段,从而可判别句中清、浊音转变时刻,声母韵母的分界以及无声与有声的分界。这在语音识别中有重要意义。自己编写的matlab代码,对一段语音,取帧长为240个点,计算其平均能_matlab求语音信号短时过零率的函数

Ubuntu服务器创建新用户及解决新用户登录Access denied问题

默认情况下,在Ubuntu上,sudo组的成员被授予sudo访问权限。如果您希望新创建的用户具有管理权限,需要将将用户添加到sudo组。命令将向你询问一系列的问题。密码是必需的,其他字段都是可选的。最后,输入Y确认信息是否正确。执行完上述步骤后需要重启ssh服务,否则新创建的用户连接服务器时会出现。

项目组织战略管理及组织结构_项目组织的具体形态的是战略管理层-程序员宅基地

文章浏览阅读1.7k次。组织战略是组织实施各级项目管理,包括项目组合管理、项目集管理和项目管理的基础。只有从组织战略的高度来思考,思考各个层次项目管理在组织中的位置,才能够理解各级项目管理在组织战略实施中的作用。同时战略管理也为项目管理提供了具体的目标和依据,各级项目管理都需要与组织的战略保持一致。..._项目组织的具体形态的是战略管理层

图像质量评价及色彩处理_图像颜色质量评价-程序员宅基地

文章浏览阅读1k次。目录基本统计量色彩空间变换亮度变换函数白平衡图像过曝的评价指标多视影像因曝光条件不一而导致色彩差异,人眼可以快速区分影像质量,如何利用图像信息辅助算法判断影像优劣。基本统计量灰度均值方差梯度均值方差梯度幅值直方图图像熵p·log(p)色彩空间变换RGB转单通道灰度图像 mean = 225.7 stddev = 47.5mean = 158.5 stddev = 33.2转灰度梯度域gradMean = -0.0008297 / -0.000157461gr_图像颜色质量评价

MATLAB运用规则,利用辛普森规则进行数值积分-程序员宅基地

文章浏览阅读1.4k次。Simpson's rule for numerical integrationZ = SIMPS(Y) computes an approximation of the integral of Y via the Simpson's method (with unit spacing). To compute the integral for spacing different from one..._matlab利用幸普生计算积分

【AI之路】使用huggingface_hub优雅解决huggingface大模型下载问题-程序员宅基地

文章浏览阅读1.2w次,点赞28次,收藏61次。Hugging face 资源很不错,可是国内下载速度很慢,动则GB的大模型,下载很容易超时,经常下载不成功。很是影响玩AI的信心。经过多次测试,终于搞定了下载,即使超时也可以继续下载。真正实现下载无忧!究竟如何实现?且看本文分解。_huggingface_hub