关于spring配置两个sessionFactory的配置与注意事项
2015-09-05 10:33
573 查看
在spring中配置两个sessionFactory的思想和配置一个是一样的,只需要把配置一个的配置部分全部复制一份,下面就贴出配置,并指出我在配置的时候出现的一些问题。
1.首先是hibernate.properties:
2.hibernate.cfg.xml
<import resource="classpath:hibernate.cfg.xml" /><context:component-scan base-package="com.stee.traffic" />
到此配置就已经完成，接下来应该是如何注解注入了，我是通过一个类来完成两个sessionFactory的注入的。
4.public interface HibernateSessionFactory {
/**
* 得到实时库的sessionFactory
* @return
*/
Session getCrtSession();
/**
* 得到历史库的sessionFactory
* @return
*/
Session getHisSession();
Session getCrttOpenSession();
Session getHistOpenSession();
}
5.实现接口并分别注入实例到sessionFactory
注意事项：
1.在配置期间在获取session的时候经常会遇到no session found for current thread异常，
解决方法：在配置中加上
spring会默认将自己的CurrentSessionContext实现自SpringSessionContext
2.上述方法不能解决试着在web.xml中配置
session的存在时间，解决了懒加载session关闭的问题。
但是带来的影响也不小，影响并发性等，由于连接长时间得不到释放，对并发性的要求高的项目则不适用。
3.在项目启动时初始化数据的时候，使用getCurrentSession来获取时间时，总是报no session found for current thread异常，具体原因不知道、
由于我的初始化数据是查询基础数据到内存，所有不涉及事务，就使用了openSession来代替。
4.由于oracle可能一个数据库会设计多个账户（实例），那么在连接的时候是不是一个账户都需要配置一个sessionFactory呢？答案：NO、如果多个用户所在数据库是同一个，那么只需要连接一次，在查询的时候使用：select * from 用户.表名，如我的用户为traffic.那么使用select * from traffic.table1.
1.首先是hibernate.properties:
hibernate.dialect=org.hibernate.dialect.OracleDialect hibernate.driverClass=oracle.jdbc.driver.OracleDriver #Real-time url hibernate.crtJdbcUrl=jdbc:oracle:thin:@192.168.1.92:1521:itscrtdb #History-time url hibernate.hisJdbcUrl=jdbc:oracle:thin:@192.168.1.92:1521:itshisdb hibernate.username=traffic hibernate.password=traffic hibernate.minPoolSize=10 hibernate.maxPoolSize=50 hibernate.initialPoolSize=5 hibernate.maxIdleTime=60 hibernate.acquireIncrement=5 hibernate.hbm2ddl.auto=false hibernate.hibernate.show_sql=true hibernate.hibernate.format_sql=true hibernate.show_sql = true hibernate.format_sql = true #org.hibernate.hql.classic.ClassicQueryTranslatorFactory #hibernate.query.factory_class=org.hibernate.hql.ast.ASTQueryTranslatorFactory hibernate.current_session_context_class=org.springframework.orm.hibernate4.SpringSessionContext
2.hibernate.cfg.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" 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/tx http://www.springframework.org/schema/tx/spring-tx-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/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> <!-- hibernate.properties 文件信息获取 --> <bean id="propertyConfig" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="ignoreResourceNotFound" value="true" /> <property name="locations"> <list> <value>classpath:hibernate.properties</value> </list> </property> </bean> <bean id="dataSourceHis" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"> <property name="driverClass" value="${hibernate.driverClass}"/> <property name="jdbcUrl" value="${hibernate.hisJdbcUrl}"/> <property name="user" value="${hibernate.username}"/> <property name="password" value="${hibernate.password}"/> <!-- C3P0 properties refer: http://www.mchange.com/projects/c3p0/ --> <property name="acquireIncrement" value="${hibernate.acquireIncrement}"/> <property name="minPoolSize" value="${hibernate.minPoolSize}"/> <property name="maxPoolSize" value="${hibernate.maxPoolSize}"/> <property name="maxIdleTime" value="${hibernate.maxIdleTime}"/> </bean> <bean id="dataSourceCrt" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"> <property name="driverClass" value="${hibernate.driverClass}"/> <property name="jdbcUrl" value="${hibernate.crtJdbcUrl}"/> <property name="user" value="${hibernate.username}"/> <property name="password" value="${hibernate.password}"/> <!-- C3P0 properties refer: http://www.mchange.com/projects/c3p0/ --> <property name="acquireIncrement" value="${hibernate.acquireIncrement}"/> <property name="minPoolSize" value="${hibernate.minPoolSize}"/> <property name="maxPoolSize" value="${hibernate.maxPoolSize}"/> <property name="maxIdleTime" value="${hibernate.maxIdleTime}"/> </bean> <!-- Hibernate session factory --> <bean id="crtSessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"> <property name="dataSource"> <ref bean="dataSourceCrt"/> </property> <property name="hibernateProperties"> <props> <prop key="hibernate.dialect">${hibernate.dialect}</prop> <prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop> <prop key="hibernate.show_sql">${hibernate.show_sql}</prop> <prop key="hibernate.format_sql">${hibernate.format_sql}</prop> <!-- <prop key="hibernate.query.factory_class">${hibernate.query.factory_class}</prop> --> <prop key="hibernate.current_session_context_class">${hibernate.current_session_context_class}</prop> <prop key="current_session_context_class">thread</prop> </props> </property> <!-- <property name="annotatedClasses"> <list> <value>com.stee.traffic.entity.crt.ErhuanJunction</value> </list> </property> --> <property name="packagesToScan"> <list><value>com.stee.traffic.entity.crt</value></list> </property> </bean> <!-- Hibernate session factory --> <bean id="hisSessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"> <property name="dataSource"> <ref bean="dataSourceHis"/> </property> <property name="hibernateProperties"> <props> <prop key="hibernate.dialect">${hibernate.dialect}</prop> <prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop> <prop key="hibernate.show_sql">${hibernate.show_sql}</prop> <prop key="hibernate.format_sql">${hibernate.format_sql}</prop> <!-- <prop key="hibernate.query.factory_class">${hibernate.query.factory_class}</prop> --> <prop key="hibernate.current_session_context_class">${hibernate.current_session_context_class}</prop> <prop key="current_session_context_class">thread</prop> </props> </property> <property name="annotatedClasses"> <list> <value>com.stee.traffic.entity.his.VmsSegmentData</value> <value>com.stee.traffic.entity.his.TrafficData_VID</value> <value>com.stee.traffic.entity.his.TrafficData_VID_Lane</value> <value>com.stee.traffic.entity.his.FaBuDuan</value> </list> </property> </bean> <bean id="hisTransactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager"> <property name="sessionFactory" ref="hisSessionFactory"/> </bean> <tx:annotation-driven transaction-manager="hisTransactionManager"/> <tx:advice id="txAdviceHis" transaction-manager="hisTransactionManager"> <tx:attributes> <tx:method name="save*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="add*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="insert*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="update*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="mod*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="merge*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="del*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="batch*" propagation="REQUIRED" /> <tx:method name="get*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="query*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="load*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="find*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="*" read-only="true" /> </tx:attributes> </tx:advice> <bean id="crtTransactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager"> <property name="sessionFactory" ref="crtSessionFactory"/> </bean> <tx:annotation-driven transaction-manager="crtTransactionManager"/> <tx:advice id="txAdviceCrt" transaction-manager="crtTransactionManager"> <tx:attributes> <tx:method name="save*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="add*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="insert*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="update*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="mod*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="merge*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="del*" propagation="REQUIRED" rollback-for="Exception"/> <tx:method name="batch*" propagation="REQUIRED" /> <tx:method name="get*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="query*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="load*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="find*" propagation="NOT_SUPPORTED" read-only="true"/> <tx:method name="*" read-only="true" /> </tx:attributes> </tx:advice> <aop:aspectj-autoproxy expose-proxy="true"/> <aop:config > <aop:pointcut id="servicesPointcut" expression="execution(* com.stee.traffic.service..*.*(..))"/> <aop:advisor advice-ref="txAdviceHis" pointcut-ref="servicesPointcut" /> <aop:advisor advice-ref="txAdviceCrt" pointcut-ref="servicesPointcut" /> </aop:config> </beans>3.spring-context.xml
<import resource="classpath:hibernate.cfg.xml" /><context:component-scan base-package="com.stee.traffic" />
到此配置就已经完成，接下来应该是如何注解注入了，我是通过一个类来完成两个sessionFactory的注入的。
4.public interface HibernateSessionFactory {
/**
* 得到实时库的sessionFactory
* @return
*/
Session getCrtSession();
/**
* 得到历史库的sessionFactory
* @return
*/
Session getHisSession();
Session getCrttOpenSession();
Session getHistOpenSession();
}
5.实现接口并分别注入实例到sessionFactory
@Component("HibernateSessionFactoryImpl")
public class HibernateSessionFactoryImpl implements HibernateSessionFactory {
@Autowired
@Qualifier("crtSessionFactory")
private SessionFactory crtSessionFactory;
public void setCrtSessionFactory(SessionFactory crtSessionFactory) {
this.crtSessionFactory = crtSessionFactory;
}
public Session getCrtSession() {
return crtSessionFactory.getCurrentSession();
}
@Autowired
@Qualifier("hisSessionFactory")
private SessionFactory hisSessionFactory;
public void setHisSessionFactory(SessionFactory hisSessionFactory) {
this.hisSessionFactory = hisSessionFactory;
}
@Override
public Session getHisSession() {
return hisSessionFactory.getCurrentSession();
}
@Override
public Session getCrttOpenSession() {
return crtSessionFactory.openSession();
}
@Override
public Session getHistOpenSession() {
return hisSessionFactory.openSession();
}
}6.使用的时候直接继承上述类直接获取想要的sessionFactory即可。注意事项：
1.在配置期间在获取session的时候经常会遇到no session found for current thread异常，
解决方法：在配置中加上
<span style="white-space:pre"> </span>hibernate.current_session_context_class=org.springframework.orm.hibernate4.SpringSessionContext
spring会默认将自己的CurrentSessionContext实现自SpringSessionContext
2.上述方法不能解决试着在web.xml中配置
<filter> <filter-name>openSessionInView1</filter-name> <filter-class>org.springframework.orm.hibernate4.support.OpenSessionInViewFilter</filter-class> <init-param> <param-name>sessionFactoryBeanName</param-name> <param-value>hisSessionFactory</param-value> </init-param> </filter> <filter-mapping> <filter-name>openSessionInView1</filter-name> <url-pattern>/*</url-pattern> </filter-mapping> <filter> <filter-name>openSessionInView</filter-name> <filter-class>org.springframework.orm.hibernate4.support.OpenSessionInViewFilter</filter-class> <init-param> <param-name>sessionFactoryBeanName</param-name> <param-value>crtSessionFactory</param-value> </init-param> </filter> <filter-mapping> <filter-name>openSessionInView</filter-name> <url-pattern>/*</url-pattern> </filter-mapping>增加
session的存在时间，解决了懒加载session关闭的问题。
但是带来的影响也不小，影响并发性等，由于连接长时间得不到释放，对并发性的要求高的项目则不适用。
3.在项目启动时初始化数据的时候，使用getCurrentSession来获取时间时，总是报no session found for current thread异常，具体原因不知道、
由于我的初始化数据是查询基础数据到内存，所有不涉及事务，就使用了openSession来代替。
4.由于oracle可能一个数据库会设计多个账户（实例），那么在连接的时候是不是一个账户都需要配置一个sessionFactory呢？答案：NO、如果多个用户所在数据库是同一个，那么只需要连接一次，在查询的时候使用：select * from 用户.表名，如我的用户为traffic.那么使用select * from traffic.table1.
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- java设计模式之单例模式
- 编码 GBK 的不可映射字符——【java菜鸟成长记】
- jdk1.8 LinkedList增删改的过程
- eclipse打包android项目apk
- Java线程池
- Java中如何由枚举常量的ordinal值获得枚举常量对象
- Spring MVC 两种方式
- Spring MVC 核心类和接口
- java 自写的计算器
- Relative path in absolute URI: ${system:java.io.tmpdir%7D/$%7Bsystem:user.name%7D
- 过滤器模板
- Spring事物处理
- Spring面向切面编程AOP
- Struts2基础知识总结
- 牛客网改错java20150905
- 通过配置监听器来获取Spring容器：
- 《编程导论（Java）·6.1封装性》
- java 开发项目管理工具
- Java中的定时调度
- Java中main方法详解