`
snoopy7713
  • 浏览: 1161351 次
  • 性别: Icon_minigender_2
  • 来自: 火星郊区
博客专栏
Group-logo
OSGi
浏览量：0
社区版块
存档分类
最新评论

Spring+Hibernate实现动态SessionFactory切换(改进版)

springhibernateSpring+Hibernate动态SessionFactory切换 
阅读更多

前面写了一篇关于动态切换Hibernate SessionFactory的文章，原文地址：http://tangyanbo.iteye.com/admin/blogs/1717402

发现存在一些问题：
需要配置多个HibernateTransactionManager和多个Spring 切面
这样带来两个问题
1. 程序效率降低，因为Spring进行多次Advice的拦截
2. 如果其中一个SessionFactory连接出现问题，会导致整个系统无法工作

今天研究出一种新的方法来解决此类问题
1. 数据源及Hibernate SessionFactory配置：

 

<?xml version="1.0" encoding="UTF-8"?>  
<beans xmlns="http://www.springframework.org/schema/beans"  
    xmlns:p="http://www.springframework.org/schema/p"  
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"  
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"  
    xsi:schemaLocation="  
            http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd  
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd  
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">  
    <!-- FOR SqlServer-->  
    <bean id="SqlServer_DataSource"  
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">  
        <property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />  
        <property name="url"  
            value="url" />  
        <property name="username" value="username" />  
        <property name="password" value="password" />  
    </bean>  
    <bean id="SqlServer_SessionFactory"  
        class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"  
        p:mappingLocations="classpath:/com/entity/*.hbm.xml">  
        <property name="dataSource" ref="SqlServer_DataSource" />       
        <property name="hibernateProperties">  
            <props>                 
                <prop key="hibernate.query.factory_class">org.hibernate.hql.ast.ASTQueryTranslatorFactory</prop>  
                <prop key="hibernate.dialect">org.hibernate.dialect.SQLServer2008Dialect</prop>               
                <prop key="hibernate.show_sql">true</prop>  
                <prop key="hibernate.format_sql">true</prop>  
            </props>  
        </property>  
    </bean>  
   
      
    <!-- FOR Oracle -->  
    <bean id="Oracle _DataSource"  
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">       
        <property name="driverClassName" value="oracle.jdbc.OracleDriver" />  
        <property name="url" value="jdbc:oracle:thin:@localhost:1521/orcl" />  
        <property name="username" value="username" />  
        <property name="password" value="password" />  
    </bean>  
    <bean id="Oracle_SessionFactory"  
        class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"   
        p:mappingLocations="classpath:/com/entity/*.hbm.xml">  
        <property name="dataSource" ref="Oracle_DataSource" />          
        <property name="hibernateProperties">  
            <props>  
                <prop key="hibernate.query.factory_class">org.hibernate.hql.ast.ASTQueryTranslatorFactory</prop>  
                <prop key="hibernate.dialect">org.hibernate.dialect.Oracle10gDialect</prop>               
                <prop key="hibernate.show_sql">true</prop>  
                <prop key="hibernate.format_sql">true</prop>  
            </props>  
        </property>  
    </bean>        
</beans>
 

 

2. 定义扩展接口DynamicSessionFactoryInf继承SessionFactory

 

 

Java代码  收藏代码
  1. import  org.hibernate.SessionFactory;  
  2.   
  3. public   interface  DynamicSessionFactoryInf  extends  SessionFactory {  
  4.   
  5.     public  SessionFactory getHibernateSessionFactory();  
  6. }  

 

3. 定义DynamicSessionFactory实现DynamicSessionFactoryInf

 

Java代码  收藏代码
  1. public   class  DynamicSessionFactory  implements  DynamicSessionFactoryInf ,ApplicationContextAware{  
  2.       
  3.     private   static   final   long  serialVersionUID = 1L;  
  4.   
  5.     private  ApplicationContext applicationContext;  
  6.     //动态调用SessionFactory   
  7.     private  SessionFactory getHibernateSessionFactory(String name) {  
  8.         return  (SessionFactory) applicationContext.getBean(name);  
  9.     }  
  10.         //实现DynamicSessionFactoryInf 接口的方法   
  11.     public  SessionFactory getHibernateSessionFactory() {  
  12.         return  getHibernateSessionFactory(ThreadLocalUtil.getCurrentITAsset()  
  13.                 .getSessionFactoryName());  
  14.     }  
  15.       
  16.        //以下是实现SessionFactory接口的方法，并对当前的SessionFactory实体进行代理   
  17.     public  Reference getReference()  throws  NamingException {  
  18.         return  getHibernateSessionFactory().getReference();  
  19.     }  
  20.   
  21.       
  22.   
  23.     public  Session openSession()  throws  HibernateException {  
  24.         return  getHibernateSessionFactory().openSession();  
  25.     }  
  26.   
  27.     public  Session openSession(Interceptor interceptor)  
  28.             throws  HibernateException {  
  29.         return  getHibernateSessionFactory().openSession(interceptor);  
  30.     }  
  31.   
  32.     public  Session openSession(Connection connection) {  
  33.         return  getHibernateSessionFactory().openSession(connection);  
  34.     }  
  35.   
  36.     public  Session openSession(Connection connection, Interceptor interceptor) {  
  37.         return  getHibernateSessionFactory().openSession(connection,interceptor);  
  38.     }  
  39.   
  40.     public  Session getCurrentSession()  throws  HibernateException {  
  41.         return  getHibernateSessionFactory().getCurrentSession();  
  42.     }  
  43.   
  44.     public  StatelessSession openStatelessSession() {  
  45.         return  getHibernateSessionFactory().openStatelessSession();  
  46.     }  
  47.   
  48.     public  StatelessSession openStatelessSession(Connection connection) {  
  49.         return  getHibernateSessionFactory().openStatelessSession(connection);  
  50.     }  
  51.   
  52.     public  ClassMetadata getClassMetadata(Class entityClass) {  
  53.         return  getHibernateSessionFactory().getClassMetadata(entityClass);  
  54.     }  
  55.   
  56.     public  ClassMetadata getClassMetadata(String entityName) {  
  57.         return  getHibernateSessionFactory().getClassMetadata(entityName);  
  58.     }  
  59.   
  60.     public  CollectionMetadata getCollectionMetadata(String roleName) {  
  61.         return  getHibernateSessionFactory().getCollectionMetadata(roleName);  
  62.     }  
  63.   
  64.     public  Map getAllClassMetadata() {  
  65.         return  getHibernateSessionFactory().getAllClassMetadata();  
  66.     }  
  67.   
  68.     public  Map getAllCollectionMetadata() {  
  69.         return  getHibernateSessionFactory().getAllCollectionMetadata();  
  70.     }  
  71.   
  72.     public  Statistics getStatistics() {  
  73.         return  getHibernateSessionFactory().getStatistics();  
  74.     }  
  75.   
  76.     public   void  close()  throws  HibernateException {  
  77.         getHibernateSessionFactory().close();  
  78.     }  
  79.   
  80.     public   boolean  isClosed() {  
  81.         return  getHibernateSessionFactory().isClosed();  
  82.     }  
  83.   
  84.     public  Cache getCache() {  
  85.         return  getHibernateSessionFactory().getCache();  
  86.     }  
  87.   
  88.     public   void  evict(Class persistentClass)  throws  HibernateException {  
  89.         getHibernateSessionFactory().evict(persistentClass);  
  90.     }  
  91.   
  92.     public   void  evict(Class persistentClass, Serializable id)  
  93.             throws  HibernateException {  
  94.         getHibernateSessionFactory().evict(persistentClass, id);  
  95.     }  
  96.   
  97.     public   void  evictEntity(String entityName)  throws  HibernateException {  
  98.         getHibernateSessionFactory().evictEntity(entityName);  
  99.     }  
  100.   
  101.     public   void  evictEntity(String entityName, Serializable id)  
  102.             throws  HibernateException {  
  103.         getHibernateSessionFactory().evictEntity(entityName, id);  
  104.     }  
  105.   
  106.     public   void  evictCollection(String roleName)  throws  HibernateException {  
  107.         getHibernateSessionFactory().evictCollection(roleName);  
  108.     }  
  109.   
  110.     public   void  evictCollection(String roleName, Serializable id)  
  111.             throws  HibernateException {  
  112.         getHibernateSessionFactory().evictCollection(roleName, id);  
  113.     }  
  114.   
  115.     public   void  evictQueries(String cacheRegion)  throws  HibernateException {  
  116.         getHibernateSessionFactory().evictQueries(cacheRegion);  
  117.     }  
  118.   
  119.     public   void  evictQueries()  throws  HibernateException {  
  120.         getHibernateSessionFactory().evictQueries();  
  121.     }  
  122.   
  123.     public  Set getDefinedFilterNames() {  
  124.         return  getHibernateSessionFactory().getDefinedFilterNames();  
  125.     }  
  126.   
  127.     public  FilterDefinition getFilterDefinition(String filterName)  
  128.             throws  HibernateException {  
  129.         return  getHibernateSessionFactory().getFilterDefinition(filterName);  
  130.     }  
  131.   
  132.     public   boolean  containsFetchProfileDefinition(String name) {  
  133.         return  getHibernateSessionFactory().containsFetchProfileDefinition(name);  
  134.     }  
  135.   
  136.     @Override   
  137.     public   void  setApplicationContext(ApplicationContext applicationContext)  
  138.             throws  BeansException {  
  139.         this .applicationContext = applicationContext;  
  140.     }  
  141.   
  142.       
  143.   
  144. }  

 

4. 配置动态SessionFactory

 

Xml代码  收藏代码
  1. < bean   id = "sessionFactory"   class = "com.hp.it.qdpadmin.common.DynamicSessionFactory" />    
 

 

5. 定义DynamicTransactionManager继承HibernateTransactionManager

 

Java代码  收藏代码
  1. public   class  DynamicTransactionManager  extends  HibernateTransactionManager {  
  2.   
  3.     private   static   final   long  serialVersionUID = 1047039346475978451L;  
  4.     //重写getDataSource方法，实现动态获取   
  5.     public  DataSource getDataSource() {  
  6.         DataSource sfds = SessionFactoryUtils.getDataSource(getSessionFactory());  
  7.         return  sfds;  
  8.     }  
  9.        //重写getSessionFactory方法，实现动态获取SessionFactory   
  10.     public  SessionFactory getSessionFactory() {  
  11.         DynamicSessionFactoryInf dynamicSessionFactory = (DynamicSessionFactoryInf) super   
  12.                 .getSessionFactory();  
  13.         SessionFactory hibernateSessionFactory = dynamicSessionFactory  
  14.                 .getHibernateSessionFactory();  
  15.         return  hibernateSessionFactory;  
  16.     }  
  17.     //重写afterPropertiesSet，跳过数据源的初始化等操作   
  18.     public   void  afterPropertiesSet() {  
  19.         return ;  
  20.     }  
  21.   
  22. }  

 

6. 配置dynamicTransactionManager

 

<bean id="dynamicTransactionManager"
		class="com.hp.it.qdpadmin.common.DynamicTransactionManager">
		<property name="sessionFactory" ref="sessionFactory"/>
</bean>

 

 

7. 为SessionFactory配置事务切面 

<tx:advice id="dynamicTxAdvice" transaction-manager="dynamicTransactionManager">  
        <tx:attributes>  
            <tx:method name="get*" read-only="true" />  
            <tx:method name="find*" read-only="true" />  
            <tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />  
        </tx:attributes>  
    </tx:advice>  
      
      
    <aop:config proxy-target-class="true">    
        <aop:pointcut id="txPointcut" expression="execution(* com.service.*.*(..))"/>          
        <aop:advisor advice-ref="dynamicTxAdvice" pointcut-ref="txPointcut" /> 
    </aop:config>
 
分享到：
| Illegal mix of collations (utf8_general_ ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    spring4+hibernate4+jpa 附有jar包

    在Spring4中集成Hibernate4和JPA，可以实现强大的数据持久化能力。Spring通过其声明式事务管理，使得事务处理变得简单。同时，Spring的JPA支持提供了Repository接口，使得数据访问如同操作普通的Java对象一样方便。...

    Spring之Spring2.5集成Hibernate3.6

    在实际集成过程中，开发者需要配置Spring的Hibernate模板或JPA支持，创建SessionFactory或EntityManagerFactory，然后定义数据访问对象（DAO），并利用Spring的依赖注入将它们注入到业务服务（Service）中。...

    ssh+frameset 简单实例

    在权限管理系统中，frameset常用来分割页面，如顶部导航、左侧菜单和主要内容区域，通过改变不同框架的内容来实现动态页面切换。 在本实例中，"purview_control"可能代表权限控制相关的类或配置文件。这通常涉及到...

    hibernate 3.2.6架包（包括所有jar，eg，api）

    7. 兼容性：Hibernate 3.2.6版本兼容Java 5及更高版本，并且可以与Spring框架等其他Java企业级开发工具集成，以实现更复杂的应用场景。 8. 性能优化：在3.2.6版本中，Hibernate已经进行了大量的性能优化，包括查询...

    sblim-gather-provider-2.2.8-9.el7.x64-86.rpm.tar.gz

    1、文件内容：sblim-gather-provider-2.2.8-9.el7.rpm以及相关依赖 2、文件形式：tar.gz压缩包 3、安装指令： #Step1、解压 tar -zxvf /mnt/data/output/sblim-gather-provider-2.2.8-9.el7.tar.gz #Step2、进入解压后的目录，执行安装 sudo rpm -ivh *.rpm 4、更多资源/技术支持：公众号禅静编程坊

    基于pringboot框架的图书进销存管理系统的设计与实现（Java项目编程实战+完整源码+毕设文档+sql文件+学习练手好项目）.zip

    本图书进销存管理系统管理员功能有个人中心，用户管理，图书类型管理，进货订单管理，商品退货管理，批销订单管理，图书信息管理，客户信息管理，供应商管理，库存分析管理，收入金额管理，应收金额管理，我的收藏管理。 用户功能有个人中心，图书类型管理，进货订单管理，商品退货管理，批销订单管理，图书信息管理，客户信息管理，供应商管理，库存分析管理，收入金额管理，应收金额管理。因而具有一定的实用性。 本站是一个B/S模式系统，采用Spring Boot框架，MYSQL数据库设计开发，充分保证系统的稳定性。系统具有界面清晰、操作简单，功能齐全的特点，使得图书进销存管理系统管理工作系统化、规范化。本系统的使用使管理人员从繁重的工作中解脱出来，实现无纸化办公，能够有效的提高图书进销存管理系统管理效率。 关键词：图书进销存管理系统；Spring Boot框架；MYSQL数据库

    2024中国在人工智能领域的创新能力如何研究报告.pdf

    2024中国在人工智能领域的创新能力如何研究报告.pdf

    安全生产_人脸识别_移动目标跟踪_智能管控平台技术实现与应用_1741777778.zip

    人脸识别项目实战

    人脸识别_TF2_Facenet_训练预测应用仓库_1741778670.zip

    人脸识别项目实战

    安全人脸识别_对抗攻击_多模型集成_减少扰动_竞赛方案_Ne_1741779504.zip

    人脸识别项目实战

    Python实现基于CEEMDAN完全自适应噪声集合经验模态分解时间序列信号分解的详细项目实例（含完整的程序，GUI设计和代码详解）

    内容概要：本文档详细介绍了基于CEEMDAN（完全自适应噪声集合经验模态分解）的方法实现时间序列信号分解的具体项目。文中涵盖项目背景介绍、主要目标、面临的挑战及解决方案、技术创新点、应用领域等多方面内容。项目通过多阶段流程（数据准备、模型设计与构建、性能评估、UI设计），并融入多项关键技术手段（自适应噪声引入、并行计算、机器学习优化等）以提高非线性非平稳信号的分析质量。同时，该文档包含详细的模型架构描述和丰富的代码样例（Python代码），有助于开发者直接参考与复用。 适合人群：具有时间序列分析基础的科研工作者、高校教师与研究生，从事信号处理工作的工程技术人员，或致力于数据科学研究的从业人员。 使用场景及目标：此项目可供那些面临时间序列数据中噪声问题的人群使用，尤其适用于需从含有随机噪音的真实世界信号里提取有意义成分的研究者。具体场景包括但不限于金融市场趋势预测、设备故障预警、医疗健康监控以及环境质量变动跟踪等，旨在提供一种高效的信号分离和分析工具，辅助专业人士进行精准判断和支持决策。 其他说明：本文档不仅限于理论讲解和技术演示，更着眼于实际工程项目落地应用，强调软硬件资源配置、系统稳定性测试等方面的细节考量。通过完善的代码实现说明以及GUI界面设计指南，使读者能够全面理解整个项目的开发流程，同时也鼓励后续研究者基于已有成果继续创新拓展，探索更多的改进空间与发展机遇。此外，针对未来可能遇到的各种情况，提出了诸如模型自我调整、多模态数据融合等发展方向，为长期发展提供了思路指导。

    监护人，小孩和玩具数据集 4647张原始图片 监护人 食物 孩子 玩具 精确率可达85.4% pasical voc xml格式

    监护人，小孩和玩具数据集 4647张原始图片 监护人 食物 孩子 玩具 精确率可达85.4% pasical voc xml格式

    根据提供的内容可以构建以下_1741777949.zip

    人脸识别项目实战

    `计算机视觉_人脸识别_Python_OpenCV_树莓派毕业设计`.zip

    人脸识别项目实战

    智慧生产企业园区解决方案PPT(54页).pptx

    在智慧园区建设的浪潮中，一个集高效、安全、便捷于一体的综合解决方案正逐步成为现代园区管理的标配。这一方案旨在解决传统园区面临的智能化水平低、信息孤岛、管理手段落后等痛点，通过信息化平台与智能硬件的深度融合，为园区带来前所未有的变革。 首先，智慧园区综合解决方案以提升园区整体智能化水平为核心，打破了信息孤岛现象。通过构建统一的智能运营中心（IOC），采用1+N模式，即一个智能运营中心集成多个应用系统，实现了园区内各系统的互联互通与数据共享。IOC运营中心如同园区的“智慧大脑”，利用大数据可视化技术，将园区安防、机电设备运行、车辆通行、人员流动、能源能耗等关键信息实时呈现在拼接巨屏上，管理者可直观掌握园区运行状态，实现科学决策。这种“万物互联”的能力不仅消除了系统间的壁垒，还大幅提升了管理效率，让园区管理更加精细化、智能化。 更令人兴奋的是，该方案融入了诸多前沿科技，让智慧园区充满了未来感。例如，利用AI视频分析技术，智慧园区实现了对人脸、车辆、行为的智能识别与追踪，不仅极大提升了安防水平，还能为园区提供精准的人流分析、车辆管理等增值服务。同时，无人机巡查、巡逻机器人等智能设备的加入，让园区安全无死角，管理更轻松。特别是巡逻机器人，不仅能进行360度地面全天候巡检，还能自主绕障、充电，甚至具备火灾预警、空气质量检测等环境感知能力，成为了园区管理的得力助手。此外，通过构建高精度数字孪生系统，将园区现实场景与数字世界完美融合，管理者可借助VR/AR技术进行远程巡检、设备维护等操作，仿佛置身于一个虚拟与现实交织的智慧世界。 最值得关注的是，智慧园区综合解决方案还带来了显著的经济与社会效益。通过优化园区管理流程，实现降本增效。例如，智能库存管理、及时响应采购需求等举措，大幅减少了库存积压与浪费；而设备自动化与远程监控则降低了维修与人力成本。同时，借助大数据分析技术，园区可精准把握产业趋势，优化招商策略，提高入驻企业满意度与营收水平。此外，智慧园区的低碳节能设计，通过能源分析与精细化管理，实现了能耗的显著降低，为园区可持续发展奠定了坚实基础。总之，这一综合解决方案不仅让园区管理变得更加智慧、高效，更为入驻企业与员工带来了更加舒适、便捷的工作与生活环境，是未来园区建设的必然趋势。

    第八届全国大学生创新创业年会-创新创业展示项目集

    本届年会的主题是“青春梦想创新创业”。通过学术论文报告、创新创业项目展示、创业项目推介、工作研讨、联谊活动、大会报告等活动，全面展示大学生最新的创新创业成果。年会共收到491所高校推荐的学术论文756篇、创新创业展示项目721项、创业推介项目156项，合计1633项，为历届年会数量最高。经过36所“985”高校相关学科专家的初评以及国家级大学生创新创业训练计划专家组的复选，最终遴选出可参加本次年会的学术论文180篇，创新创业展示项目150个，创业推介项目45项，共计375项，涉及30个省市的236所高校。年会还收到了来自澳门特别行政区、俄罗斯的13项学术论文及参展项目。这些材料集中反映了各高校最新的创新创业教育成果，也直接体现了当代大学生的创新思维和实践能力。

    人脸识别_实时_ArcFace_多路识别技术_JavaScr_1741771263.zip

    人脸识别项目实战

    6ES7215-1AG40-0XB0-V04.04.01固件4.5

    6ES7215-1AG40-0XB0_V04.04.01固件4.5

    在无人机上部署SchurVins的yaml配置文件

    在无人机上部署SchurVins的yaml配置文件

    uniapp实战商城类app和小程序源码​​​​​​.rar

    uniapp实战商城类app和小程序源码，包含后端API源码和交互完整源码。

Magicbox
Global site tag (gtag.js) - Google Analytics