文档章节

使用hibernate 分表做增删改查

王春-海子
 王春-海子
发布于 2016/05/13 14:16
字数 668
阅读 115
收藏 3

公司项目有一张表的数据量特别大、而且时间越长累积的数据量就越大、

 

后来DBA决定分表来解决性能问题、

 

分表是指   一个母体表  一群子表(结构和字段与母体表完全一样) 我们程序对母表操作其实就是对子表操作、让其无法感知有分表这个动作、

 

而使用hibernate如何分表呢?

 

难道我要写N个子表类Domain吗?那累屎我算了、

 

呵呵、我们这里需要hibernate一个拦截器类  org.hibernate.EmptyInterceptor

 

这个拦截器做了什么呢?

 

hibernate最终会将我们写的HQL语句转换成SQL语句、而当转换SQL且没放如数据库执行的时候、被拦截器就拦住啦、我们就可以偷偷的"使坏"啦、

 

我们需要一个自己的类来继承org.hibernate.EmptyInterceptor

 

 

[java] view plain copy

  1. package cn.test;  
  2.   
  3. import org.hibernate.EmptyInterceptor;  
  4.   
  5. public class MyInterceptor extends EmptyInterceptor {  
  6.   
  7.     private String targetTableName;// 目标母表名  
  8.     private String tempTableName;// 操作子表名  
  9.   
  10.     public MyInterceptor() {}//为其在spring好好利用 我们生成公用无参构造方法  
  11.   
  12.     public java.lang.String onPrepareStatement(java.lang.String sql) {  
  13.         sql = sql.replaceAll(targetTableName, tempTableName);  
  14.         return sql;  
  15.   
  16.     }  
  17.   
  18.     public String getTargetTableName() {  
  19.         return targetTableName;  
  20.     }  
  21.   
  22.     public void setTargetTableName(String targetTableName) {  
  23.         this.targetTableName = targetTableName;  
  24.     }  
  25.   
  26.     public String getTempTableName() {  
  27.         return tempTableName;  
  28.     }  
  29.   
  30.     public void setTempTableName(String tempTableName) {  
  31.         this.tempTableName = tempTableName;  
  32.     }  
  33.   
  34. }  


 

 

hibernate的session会获取吧?本文就不多做介绍了、

 

比如我们有个Test 实体类  对应的数据库的母表名称 为 test   而我们要保存到子表的 test_01要怎么做呢?

 

 

 

 

[java] view plain copy

  1. public void saveTest(Test test){  
  2.   
  3.     SessionFactory sf = super.getHibernateTemplate().getSessionFactory();//获取session工厂  
  4.       
  5.     MyInterceptor interceptor = new MyInterceptor();//我们的拦截器  
  6.       
  7.     interceptor.setTargetTableName("test");//要拦截的目标表名  
  8.       
  9.     interceptor.setTempTableName("test_01");  //要替换的子表名  
  10.       
  11.     Session session = sf.openSession(interceptor);//当前的session使用这个拦截器  
  12.          
  13.        try{  
  14.           
  15.         Transaction tx =  session.beginTransaction();//获取事务  
  16.         tx.begin();//开启事务  
  17.         session.saveOrUpdate(test);//保存和更新  
  18.         tx.commit();//提交  
  19.           
  20.        }catch(Exception e){  
  21.         e.printStackTrace();  
  22.        }finally{  
  23.         session.close();  
  24.        }  
  25.       
  26.    }  


 

 

这样就能把信息存到子表test_01里啦、而且根本没人察觉我们的"使坏"、hibernate还老老实实的本份的做自己的工作呢、

 

CURD动作就这样被我们"使坏"着、

 

那我们总是new 出来 我们的拦截器 多么费劲啊、如果我还需要其他的地方还需要分表的地方、难道我还要再次new出来给多个地方用?

 

这样我们就在spring里多加一个bean 指向我们的class类

 

 

[plain] view plain copy

  1. <bean id="MyInterceptor" class="cn.test.MyInterceptor"/>  


 

 

然后拦截器从spring拿就可以了、在setter进去目标表名和替换表名、

 

 我们项目是web.xml加载了一个实现ApplicationContextAware类的一个类 

 

static 的 ApplicationContext applicationContext  从里面getBean 就能拿到了

 

这样就ok啦、

© 著作权归作者所有

王春-海子
粉丝 7
博文 49
码字总数 11981
作品 0
江北
技术主管
私信 提问
BeetlSQL 2.11.1 发布,Java Dao 工具

果然小数位是0的版本发布都会有问题,2.11.1 修复了上一个版本新增自定义注解功能的bug,建议更新到新的版本 自定义注解可以辅助BeetlSQL序列化或者反序列化特殊属性,如下 @Jackson 使用了S...

闲大赋
03/05
0
0
BeetlSQL 2.11.2 发布,Java Dao 工具

BeetlSQL 2.11.2 发布了,改进记录包括: #ITMW3 修复:最新版本2.11.1在翻页sql语句中使用use函数,执行sql时会多传同样的值进来 IS9UJ 修复:TemplatePageAmi.java里的else是不是永远执行不到...

闲大赋
03/19
0
0
beetlsql 1.3.0 发布,mybatis 的 beetl 实现

beetlsql 1.3.0 发布,本次发布在功能上做了一些改善 #26 加载jar包里的sql文件 #23 允许设定翻页统一从0开始还是从1开始,既兼容了各种数据库,又照顾了使用单一数据的习惯 #21 提供一个简单...

闲大赋
2015/11/10
2.1K
7
BeetlSQL 2.11.0 发布,Java Dao 工具

这次是在2.10.x迭代45个版本后,更新到2.11.0,主要是调整BeetlSQL内部代码,以提供更强的定制性 2.11.0 增强了属性自定义注解,使用者在Bean和数据库之间 通过BeetlSQL提供的序列化和反序列...

闲大赋
02/28
0
0
Action、Dao、Service三层的功能划分

原文地址 Action是管理业务(Service)调度和管理跳转的。 Service是管理具体的功能的。 Action只负责管理,而Service负责实施。 DAO只完成增删改查,虽然可以1-n,n-n,1-1关联,模糊、动态...

木木侠
2017/05/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Jenkins系列_插件安装及报错处理

进入Jenkins之后我们可以进行插件的安装,插件管理位于以下模块: 发现上面报了一堆错误,是因为插件的依赖没有安装好,那么这一节,就先把这些错误解决掉吧。解决完成后,也就基本会使用插件...

shzwork
今天
2
0
mysql mysql的所有查询语句和聚合函数(整理一下,忘记了可以随时看看)

查询所有字段 select * from 表名; 查询自定字段 select 字段名 from 表名; 查询指定数据 select * from 表名 where 条件; 带关键字IN的查询 select * from 表名 where 条件 [not] in(元素...

edison_kwok
昨天
9
0
多线程同时加载缓存实现

import com.google.common.cache.Cache;import com.google.common.cache.CacheBuilder;import java.util.concurrent.ExecutionException;import java.util.concurrent.ExecutorServi......

暗中观察
昨天
3
0
利用VisualVM 内存查看

准备工作,建几个测试类。等下就是要查看这几个类里面的属性 package visualvm;public class MultiObject { private String str; private int i; MultiObject(String str...

冷基
昨天
2
0
组装一台工作游戏两用机

一、配置清单如下: 分类 项目 价格(元) 主板 华硕(ASUS)TUF Z370-PLUS GAMING II 电竞特工 Z370二代 支持9代CPU 1049 CPU 英特尔(Intel) i7 8700K 酷睿六核 盒装CPU处理器 2640 风扇 九...

mbzhong
昨天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部