分享

在Junit中实现类似OpenSessionInViewFilter保持session的功能

 kekokeko 2013-05-31

Spring为我们解决Hibernate的Session的关闭与开启问题。 
Hibernate 允许对关联对象、属性进行延迟加载,但是必须保证延迟加载的操作限于同一个 Hibernate Session 范围之内进行。如果 Service 层返回一个启用了延迟加载功能的领域对象给 Web 层,当 Web 层访问到那些需要延迟加载的数据时,由于加载领域对象的 Hibernate Session 已经关闭,这些导致延迟加载数据的访问异常

(eg: org.hibernate.LazyInitializationException:(LazyInitializationException.java:42) 
 - failed to lazily initialize a collection of role: cn.easyjava.bean.product.ProductType.childtypes, no session or session was closed
org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: cn.easyjava.bean.product.ProductType.childtypes, no session or session was closed)。

用来把一个Hibernate Session和一次完整的请求过程对应的线程相绑定。目的是为了实现"Open Session in View"的模式。例如: 它允许在事务提交之后延迟加载显示所需要的对象。


而Spring为我们提供的OpenSessionInViewFilter过滤器为我们很好的解决了这个问题。OpenSessionInViewFilter的主要功能是用来把一个Hibernate Session和一次完整的请求过程对应的线程相绑定。目的是为了实现"Open Session in View"的模式。例如: 它允许在事务提交之后延迟加载显示所需要的对象。
 OpenSessionInViewFilter 过滤器将 Hibernate Session 绑定到请求线程中,它将自动被 Spring 的事务管理器探测到。所以 OpenSessionInViewFilter 适用于 Service 层使用HibernateTransactionManager 或 JtaTransactionManager 进行事务管理的环境,也可以用于非事务只读的数据操作中。

<filter>
        <filter-name>Spring OpenSessionInViewFilter</filter-name>
        <filter-class>org.springframework.orm.hibernate3.support.OpenSessionInViewFilter</filter-class>
     <init-param>
    
<!-- 
指定org.springframework.orm.hibernate3.LocalSessionFactoryBean在spring配置文件中的名称,默认值为sessionFactory
     如果LocalSessionFactoryBean在spring中的名称不是sessionFactory,该参数一定要指定,否则会出现找不到sessionFactory的例外
-->
     <param-name>sessionFactoryBean</param-name>
   <param-value>sessionFactory</param-value>
  </init-param> 
    </filter>
    <filter-mapping>
        <filter-name>Spring OpenSessionInViewFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>




  1. private SessionFactory sessionFactory;  
  2.   
  3.       //重写setUp方法  
  4.     protected void setUp() throws Exception {  
  5.         super.setUp();  
  6.         sessionFactory = (SessionFactory) SpringContext.getInstance().getBean(  
  7.                 "sessionFactory");//SpringContext是自己创建spring工具类  
  8.   
  9.         Session s = sessionFactory.openSession();  
  10.         TransactionSynchronizationManager.bindResource(sessionFactory,  
  11.                 new SessionHolder(s));  
  12.   
  13.     }  
  14.   
  15.     protected void tearDown() throws Exception {  
  16.         super.tearDown();  
  17.         SessionHolder holder = (SessionHolder) TransactionSynchronizationManager  
  18.                 .getResource(sessionFactory);  
  19.         Session s = holder.getSession();  
  20.         try {  
  21.             s.flush();  
  22.         } catch (Throwable e) {  
  23.             e.printStackTrace();  
  24.         }  
  25.   
  26.         TransactionSynchronizationManager.unbindResource(sessionFactory);  
  27.         SessionFactoryUtils.closeSession(s);  
  28.     }  

  SpringContext.class

Java代码  收藏代码
  1. public class SpringContext {  
  2.   
  3.     private static SpringContext m_instance;  
  4.   
  5.     private static String[] contextFiles = new String[] { "applicationContext.xml" };  
  6.   
  7.     private ApplicationContext ctx;  
  8.   
  9.     public SpringContext() {  
  10.         ctx = new ClassPathXmlApplicationContext(contextFiles);  
  11.     }  
  12.   
  13.     public SpringContext(String[] setting) {  
  14.         ctx = new ClassPathXmlApplicationContext(setting);  
  15.     }  
  16.   
  17.     public synchronized static SpringContext getInstance() {  
  18.         if (m_instance == null) {  
  19.             m_instance = new SpringContext(contextFiles);  
  20.         }  
  21.         return m_instance;  
  22.     }  
  23.   
  24.     public Object getBean(String beanId) {  
  25.         Object o = ctx.getBean(beanId);  
  26.         if (o instanceof TransactionProxyFactoryBean) {  
  27.             TransactionProxyFactoryBean factoryBean = (TransactionProxyFactoryBean) o;  
  28.             o = factoryBean.getObject();  
  29.         }  
  30.         return o;  
  31.     }  
  32.   
  33. }  
 
@Before

public void openSession() throws Exception {

dsContext = new FileSystemXmlApplicationContext(configStr);

        sessionFactory = (SessionFactory) dsContext.getBean("sessionFactory");  

        session = SessionFactoryUtils.getSession(sessionFactory, true);  

        session.setFlushMode(FlushMode.MANUAL);  

        TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session)); 

}

 

@After

public void closeSession() throws Exception {

TransactionSynchronizationManager.unbindResource(sessionFactory);  

        SessionFactoryUtils.releaseSession(session, sessionFactory);  

}

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多