如何使用带有休眠功能的spring在我的班级中获取会话工厂

Question

这里我面临一个问题，我在 application.xml 文件中配置了休眠 sessionfactory，之后我如何在我的 HibDao 类（用户定义的类）中获取 sessionFactory 以启用像 begin()、commit() 这样的用户友好性,rollback() 扩展 HibernateDaoSupport 类..

这是我的 application-hibernate.xml 文件：

  <beans>   

<bean id="sessionFactory"       class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">     
    <property name="configLocation" value="/WEB-INF/hibernate.cfg.xml" />
</bean>



<!-- Transaction manager for a single Hibernate SessionFactory (alternative 
    to JTA) -->
<bean id="transactionManager"
    class="org.springframework.orm.hibernate3.HibernateTransactionManager">
    <property name="sessionFactory">
        <ref local="sessionFactory" />
    </property>
</bean>


<!-- ========================= BUSINESS OBJECT DEFINITIONS ========================= -->

<!-- Data access object: Hibernate implementation. -->

<bean id="HibernateSpringDaoTarget" class="com.netprofit.dao.HibernateSpringDAOImpl">
    <property name="sessionFactory">
        <ref local="sessionFactory" />
    </property>
</bean>

<!-- - Transactional proxy for Application's central data access object. 
    - - Defines specific transaction attributes with "readOnly" markers, - which 
    is an optimization that is particularly valuable with Hibernate - (to suppress 
    unnecessary flush attempts for read-only operations). - - Note that in a 
    real-life app with multiple transaction proxies, - you will probably want 
    to use parent and child bean definitions - as described in the manual, to 
    reduce duplication. -->

<bean id="SpringHibernateDao"
    class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
    <property name="transactionManager">
        <ref local="transactionManager" />
    </property>
    <property name="target">
        <ref local="HibernateSpringDaoTarget" />
    </property>
    <property name="transactionAttributes">
        <props>
            <prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
            <prop key="find*">PROPAGATION_REQUIRED,readOnly</prop>
            <prop key="load*">PROPAGATION_REQUIRED,readOnly</prop>
            <prop key="store*">PROPAGATION_REQUIRED</prop>
            <prop key="add*">PROPAGATION_REQUIRED</prop>
        </props>
    </property>
</bean>

这里是 hibernate-cfg.xml 文件：

          <?xml version="1.0" encoding="UTF-8"?>
         <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
     <hibernate-configuration>
<session-factory>
    <property name="hibernate.dialect">org.hibernate.dialect.MySQL5InnoDBDialect</property>
    <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
    <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/netprofit</property>
    <property name="hibernate.connection.username">root</property>
    <property name="hibernate.connection.password">test</property>
    <property name="hibernate.connection.autocommit">false</property>
    <property name="hibernate.hbm2ddl.auto">update</property>
    <property name="hibernate.show_sql">true</property>
    <property name="hibernate.format_sql">true</property>
    <property name="hibernate.jdbc.batch_size">50</property>


    <property name="hibernate.c3p0.max_size">1</property>
    <property name="hibernate.c3p0.min_size">0</property>
    <property name="hibernate.c3p0.timeout">5000</property>
    <property name="hibernate.c3p0.max_statements">1000</property>

    <property name="hibernate.c3p0.idle_test_period">300</property>
    <property name="hibernate.c3p0.acquire_increment">1</property>


    <mapping class="com.netprofit.dao.hibernate.HUserRegistrationPojo" />
</session-factory>

这里是 HibDao 类（为简单起见，用户定义的类）：

  public class HibDao extends HibernateDaoSupport {
private static final ThreadLocal THREAD = new ThreadLocal();

protected HibDao() {
}

public static Session session() throws Exception {
    Session session = (Session) HibDao.THREAD.get();
    if (session == null) {            
        session = getSessionFactory().openSession();  **--->>>Here how can i open the Session**
        HibDao.THREAD.set(session);
        session().setFlushMode(FlushMode.COMMIT);
    }
    return session;
}

protected static void begin() throws Exception {
    session().beginTransaction();

}

protected static void commit() throws Exception {
    session().getTransaction().commit();
}

protected static void rollback() throws Exception {
    session().getTransaction().rollback();
    session().close();
    HibDao.THREAD.set(null);
}

protected static void flush() throws Exception {
    session().flush();
}

protected static void close() throws Exception {

    session().close();
    HibDao.THREAD.set(null);
}
 }

然后我只是扩展了 HibDao 类并使用 begin()、commit() 和 rollback() 方法来处理休眠事务......而且我对 Spring 不熟悉......

谢谢....

Answer 1

没有指定具体问题（没有注释行）。我读到这样的问题 - “我已经在 xml 文件中注入了 SessionFactory bean。现在，我想在 Java 程序中重新收集它。”

简单！

ApplicationContext context = new FileSystemXmlApplicationContext("c:/../application-hibernate.xml");
SessionFactory sessionFact = (SessionFactory) context.getBean("sessionFactory");

现在你可以这样做了：

Session session =  sessionFact.openSession();    

注意：我是通过直接解析 xml 文件来获取 bean，这不是一个好习惯。在理想情况下，您将从 Servlet/Action 类的请求对象中获取 ApplicationContext 对象。