`
king_lm
  • 浏览: 8169 次
社区版块
存档分类
最新评论

Hibernate的session是否是同一实例(二)

Hibernate Session Spring aop 多数据源 
阅读更多

多数据源的情况，首先是配置

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
	xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/aop 
	http://www.springframework.org/schema/aop/spring-aop-3.0.xsd   
	http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd   
	http://www.springframework.org/schema/context 
	http://www.springframework.org/schema/context/spring-context-3.0.xsd   
	http://www.springframework.org/schema/jee 
	http://www.springframework.org/schema/jee/spring-jee-3.0.xsd   
	http://www.springframework.org/schema/tx 
	http://www.springframework.org/schema/tx/spring-tx-3.0.xsd"
	default-autowire="byName">

	<context:property-placeholder
		location="classpath*:META-INF/fundProfileContext.properties" />

	<context:component-scan base-package="com.jsw.fund" />

	<bean id="basedataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
		<property name="driverClassName" value="${finabase.jdbc.driver}" />
		<property name="url" value="${finabase.jdbc.url}" />
		<property name="username" value="${finabase.jdbc.user}" />
		<property name="password" value="${finabase.jdbc.password}" />
		<!--initialSize: 初始化连接 -->
		<property name="initialSize" value="5" />
		<!--maxIdle: 最大空闲连接 -->
		<property name="maxIdle" value="10" />
		<!--minIdle: 最小空闲连接 -->
		<property name="minIdle" value="5" />
		<!--maxActive: 最大连接数量 -->
		<property name="maxActive" value="100" />
		<!--removeAbandoned: 是否自动回收超时连接 -->
		<property name="removeAbandoned" value="true" />
		<!--removeAbandonedTimeout: 超时时间(以秒数为单位) -->
		<property name="removeAbandonedTimeout" value="180" />
		<!--maxWait: 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
		<property name="maxWait" value="30000" />
	</bean>
	<bean id="derivateDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
		<property name="driverClassName" value="${derivate.jdbc.driver}" />
		<property name="url" value="${derivate.jdbc.url}" />
		<property name="username" value="${derivate.jdbc.user}" />
		<property name="password" value="${derivate.jdbc.password}" />
		<!--initialSize: 初始化连接 -->
		<property name="initialSize" value="5" />
		<!--maxIdle: 最大空闲连接 -->
		<property name="maxIdle" value="10" />
		<!--minIdle: 最小空闲连接 -->
		<property name="minIdle" value="5" />
		<!--maxActive: 最大连接数量 -->
		<property name="maxActive" value="100" />
		<!--removeAbandoned: 是否自动回收超时连接 -->
		<property name="removeAbandoned" value="true" />
		<!--removeAbandonedTimeout: 超时时间(以秒数为单位) -->
		<property name="removeAbandonedTimeout" value="180" />
		<!--maxWait: 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
		<property name="maxWait" value="30000" />
	</bean>
	
		<bean id="profileAppDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
		<property name="driverClassName" value="${profileApp.jdbc.driver}" />
		<property name="url" value="${profileApp.jdbc.url}" />
		<property name="username" value="${profileApp.jdbc.user}" />
		<property name="password" value="${profileApp.jdbc.password}" />
		<!--initialSize: 初始化连接 -->
		<property name="initialSize" value="5" />
		<!--maxIdle: 最大空闲连接 -->
		<property name="maxIdle" value="10" />
		<!--minIdle: 最小空闲连接 -->
		<property name="minIdle" value="5" />
		<!--maxActive: 最大连接数量 -->
		<property name="maxActive" value="100" />
		<!--removeAbandoned: 是否自动回收超时连接 -->
		<property name="removeAbandoned" value="true" />
		<!--removeAbandonedTimeout: 超时时间(以秒数为单位) -->
		<property name="removeAbandonedTimeout" value="180" />
		<!--maxWait: 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
		<property name="maxWait" value="30000" />
	</bean>
	
	<!-- Hibernate配置 -->
	<bean id="baseSessionFactory"
		class="com.jsw.common.spring.support.AnnotationSessionFactoryBean">
		<property name="dataSource" ref="basedataSource" />
		<property name="packagesToScan" value="com.jsw.fund.model.base" />
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">${hibernate.dialect}</prop>
				<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
				<prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop>
				<prop key="hibernate.cache.use_query_cache">false</prop>
				<prop key="hibernate.cache.use_second_level_cache">false</prop>
			</props>
		</property>
		<property name="lobHandler">
			<ref bean="lobHandler"></ref>
		</property>
	</bean>
	
	<bean id="derivateSessionFactory"
		class="com.jsw.common.spring.support.AnnotationSessionFactoryBean">
		<property name="dataSource" ref="derivateDataSource" />
		<property name="packagesToScan" value="com.jsw.fund.model.derivate" />
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">${hibernate.dialect}</prop>
				<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
				<prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop>
				<prop key="hibernate.cache.use_query_cache">false</prop>
				<prop key="hibernate.cache.use_second_level_cache">false</prop>
			</props>
		</property>
		<property name="lobHandler">
			<ref bean="lobHandler"></ref>
		</property>
	</bean>

	<bean id="profileAppSessionFactory"
		class="com.jsw.common.spring.support.AnnotationSessionFactoryBean">
		<property name="dataSource" ref="profileAppDataSource" />
		<property name="packagesToScan" value="com.jsw.fund.profile.model" />
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">${hibernate.dialect}</prop>
				<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
				<prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop>
				<prop key="hibernate.cache.use_query_cache">false</prop>
				<prop key="hibernate.cache.use_second_level_cache">false</prop>
			</props>
		</property>
		<property name="lobHandler">
			<ref bean="lobHandler"></ref>
		</property>
	</bean>

	<bean name="lobHandler"
		class="org.springframework.jdbc.support.lob.DefaultLobHandler"
		lazy-init="true">
	</bean>

	<bean id="baseTransactionManager"
		class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="baseSessionFactory" />
	</bean>

	<bean id="derivateTransactionManager"
		class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="derivateSessionFactory" />
	</bean>
	<bean id="profileAppTransactionManager"
		class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="profileAppSessionFactory" />
	</bean>

	<tx:advice id="baseTxAdvice" transaction-manager="baseTransactionManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED" />
			<tx:method name="create*" propagation="REQUIRED" />
			<tx:method name="delete*" propagation="REQUIRED" />
			<tx:method name="update*" propagation="REQUIRED" />
			<tx:method name="get*" read-only="true" propagation="REQUIRED" />
			<tx:method name="load*" read-only="true" propagation="REQUIRED" />
			<tx:method name="find*" read-only="true" propagation="REQUIRED" />
			<tx:method name="search*" read-only="true" propagation="REQUIRED" />
			<tx:method name="*" propagation="REQUIRED" read-only="false" />
		</tx:attributes>
	</tx:advice>

	<aop:config>
		<aop:advisor id="baseAopAdvisor" pointcut="execution(* com.jsw..*ServiceImpl.*(..))"
			advice-ref="baseTxAdvice" />
		<aop:advisor id="baseAopAdvisor2" pointcut="execution(* com.jsw..*Service.*(..))"
			advice-ref="baseTxAdvice" />
		<aop:advisor id="baseAopAdvisor3" pointcut="execution(* com.jsw..*ProcessorImpl.*(..))"
			advice-ref="baseTxAdvice" />
		<aop:advisor id="baseAopAdvisor4" pointcut="execution(* com.jsw..*Shell.*(..))"
			advice-ref="baseTxAdvice" />
		<aop:advisor id="baseAopAdvisor5" pointcut="execution(* com.jsw..*ShellImpl.*(..))"
			advice-ref="baseTxAdvice" />
	</aop:config>
	
	<tx:advice id="derivateTxAdvice" transaction-manager="derivateTransactionManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED" />
			<tx:method name="create*" propagation="REQUIRED" />
			<tx:method name="delete*" propagation="REQUIRED" />
			<tx:method name="update*" propagation="REQUIRED" />
			<tx:method name="get*" read-only="true" propagation="REQUIRED" />
			<tx:method name="load*" read-only="true" propagation="REQUIRED" />
			<tx:method name="find*" read-only="true" propagation="REQUIRED" />
			<tx:method name="search*" read-only="true" propagation="REQUIRED" />
			<tx:method name="*" propagation="REQUIRED" read-only="false" />
		</tx:attributes>
	</tx:advice>

	<aop:config>
		<aop:advisor id="derivateAopAdvisor" pointcut="execution(* com.jsw..*ServiceImpl.*(..))"
			advice-ref="derivateTxAdvice" />
		<aop:advisor id="derivateAopAdvisor2" pointcut="execution(* com.jsw..*Service.*(..))"
			advice-ref="derivateTxAdvice" />
		<aop:advisor id="derivateAopAdvisor3" pointcut="execution(* com.jsw..*Processor.*(..))"
			advice-ref="derivateTxAdvice" />
		<aop:advisor id="derivateAopAdvisor4" pointcut="execution(* com.jsw..*ProcessorImpl.*(..))"
			advice-ref="derivateTxAdvice" />
			
		<!--保证在shell中,用到的derivate为同一个session -->
		<aop:advisor id="derivateAopAdvisor5" pointcut="execution(* com.jsw..*Shell.*(..))"
			advice-ref="derivateTxAdvice" />
		<aop:advisor id="derivateAopAdvisor6" pointcut="execution(* com.jsw..*ShellImpl.*(..))"
			advice-ref="derivateTxAdvice" />
	</aop:config>
	
	<tx:advice id="profileAppTxAdvice" transaction-manager="profileAppTransactionManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED" />
			<tx:method name="create*" propagation="REQUIRED" />
			<tx:method name="delete*" propagation="REQUIRED" />
			<tx:method name="update*" propagation="REQUIRED" />
			<tx:method name="get*" read-only="true" propagation="REQUIRED" />
			<tx:method name="load*" read-only="true" propagation="REQUIRED" />
			<tx:method name="find*" read-only="true" propagation="REQUIRED" />
			<tx:method name="search*" read-only="true" propagation="REQUIRED" />
			<tx:method name="*" propagation="REQUIRED" read-only="false" />
		</tx:attributes>
	</tx:advice>

	<aop:config>
		<aop:advisor id="profileAppAopAdvisor" pointcut="execution(* com.jsw..*ServiceImpl.*(..))"
			advice-ref="profileAppTxAdvice" />
		<aop:advisor id="profileAppAopAdvisor2" pointcut="execution(* com.jsw..*Service.*(..))"
			advice-ref="profileAppTxAdvice" />
		<aop:advisor id="profileAppAopAdvisor3" pointcut="execution(* com.jsw..*Processor.*(..))"
			advice-ref="profileAppTxAdvice" />
		<aop:advisor id="profileAppAopAdvisor4" pointcut="execution(* com.jsw..*ProcessorImpl.*(..))"
			advice-ref="profileAppTxAdvice" />
		<aop:advisor id="profileAppAopAdvisor5" pointcut="execution(* com.jsw..*Shell.*(..))"
			advice-ref="profileAppTxAdvice" />
		<aop:advisor id="profileAppAopAdvisor6" pointcut="execution(* com.jsw..*ShellImpl.*(..))"
			advice-ref="profileAppTxAdvice" />
	</aop:config>

	<tx:annotation-driven />
	
</beans>

 

 

Test Case:

 

  @Test
  public void testT() throws Exception {
    shell.process();
  }

 

 

process的实现：

  @Override
  public void process() {
    fundProfileService.f1();
    fundProfileService.f2();
    fundCategoryService.f1();
    fundCategoryService.f2();
    fundProfileService.f1();
    fundProfileService.f2();
  }

 

其中fundProfileService使用的数据源是basedataSource,fundCategoryService使用的数据源是derivateDataSource。

 

f1 f2参见上篇日志

http://king-lm.iteye.com/blog/1913556

输出的结果：

 

22580698

22580698

22580698

13180774

13180774

13180774

22580698

22580698

22580698

 

 

若把base的aop-config改为：

	<aop:config>
		<aop:advisor id="baseAopAdvisor" pointcut="execution(* com.jsw..*ServiceImpl.*(..))"
			advice-ref="baseTxAdvice" />
		<aop:advisor id="baseAopAdvisor2" pointcut="execution(* com.jsw..*Service.*(..))"
			advice-ref="baseTxAdvice" />
		<aop:advisor id="baseAopAdvisor3" pointcut="execution(* com.jsw..*ProcessorImpl.*(..))"
			advice-ref="baseTxAdvice" />
	</aop:config>

 

则输出的结果为：

8559295

12230572

12230572

4115754

4115754

4115754

12062111

18151786

18151786

看到derivateDataSource还是比较整齐的,baseDataSource每次调用都会发生变化,然而base的transactionManager的事务在service上，所以一个service中调用2此的输出结果是一样的。
结论：
多数据源的事务管理，各顾各的，互不干涉。在同一个事务中共用同一session。
分享到：
| Hibernate的session是否是同一实例(一)
评论
发表评论

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

相关推荐

    hibernate二级缓存实例

    在这个"hibernate二级缓存实例"中，我们将深入探讨二级缓存的原理、配置以及在实际项目中的应用。 首先，我们需要了解一级缓存和二级缓存的区别。一级缓存是Session级别的，每个Session都有自己的一级缓存，用于...

    hibernate中session的管理

    由于Servlet容器（如Tomcat）通常只创建一个Servlet实例供所有请求共享，每个线程在执行时可能会访问到同一份Session，导致数据错乱。 为了解决这个问题，我们可以采用ThreadLocal。ThreadLocal是Java提供的一种...

    Hibernate 缓存 实例

    其中，`hibernate.cache.provider_class`指定了使用Ehcache作为缓存提供者，`hibernate.cache.provider_configuration_file_resource_path`指定了Ehcache的配置文件路径，`hibernate.show_sql`则控制是否显示SQL日志...

    hibernate的核心接口--Session

    Hibernate 保证同一 Session 实例缓存中的每个数据库记录仅对应一个持久化实例。 - **行为**: 在 Session 清理缓存时，会根据持久化实例的属性变化来同步更新数据库。 **3. 脱管状态 (detached)** - **定义**: ...

    hibernate的一级缓存和二级缓存

    一级缓存，也称为Session缓存，是每个Hibernate Session实例私有的。当Session执行查询操作时，会将结果存储在一级缓存中。如果同一Session再次执行相同的查询，Hibernate将直接从一级缓存获取数据，避免了重复的...

    Struts＋Spring＋Hibernate开发实例 （SSH整合）

    Spring的Hibernate支持可以自动管理Session和事务，但在某些特定情况下，如需要自定义SQL查询或Criteria查询，我们需要扩展Spring的功能。为此，定义了一个IBase接口和BaseDao实现类，模仿HibernateTemplate的功能，...

    Hibernate 二级缓存 总结整理

    当我们在Session中对实体进行CRUD操作时，数据会首先被缓存到一级缓存中，同一Session内的后续查询会优先从一级缓存中获取数据，避免了频繁访问数据库。 2. **二级缓存（Second-Level Cache）**：一级缓存的局限...

    hibernate持久化对象生命周期[参照].pdf

    需要注意的是，不同Session实例可能各自持有同一数据库记录的游离对象实例。 4. 状态转换 - 从瞬时到持久化：使用Session的`save()`方法。 - 从持久化到瞬时：Session的`delete()`方法或事务回滚。 - 从持久化到...

    HIBERNATE的缓存机制

    这意味着在同一个Session内，对同一对象的多次读取和写入都会在缓存内完成，无需重复查询数据库。每个持久化类实例都有唯一的OID（对象标识符），确保了数据的唯一性。当事务结束时，Session会将所有未提交的更改...

    强人Hibernate文档笔记

    【强人Hibernate文档笔记】是针对Hibernate框架的深入学习资料，涵盖了对象定义、实例状态、JMX集成和JCA支持等关键概念。以下是对这些内容的详细解释： **一、对象定义** 1. **SessionFactory**: SessionFactory是...

    hibernate缓存和事务

    3. **SessionFactory和Session**：通过`Configuration`对象读取配置并创建SessionFactory，然后使用SessionFactory创建Session实例，执行数据库操作。 4. **事务边界**：在开始和结束数据库操作时，明确定义事务...

    Hibernate缓存深入详解

    - **一级缓存**：这是SessionFactory级别的缓存，也是每个Session实例内部的缓存。一级缓存是事务范围的，即每个事务都有自己独立的一级缓存，当事务结束时，该缓存随之失效。一级缓存的生命周期与Session对象相同，...

    Hibernate缓存策略（一级缓存、二级缓存）.docx

    当我们在同一个Session内多次读取同一对象时，Hibernate会首先检查一级缓存，如果找到，就直接从缓存中获取，而不会再次执行SQL查询。例如，上面的测试代码演示了这一点：在同一个Session中，通过load方法加载同一个...

    Hibernate 帮助文档

    #### 二、Hibernate的重要性 Hibernate之所以受到广泛欢迎，主要有以下几个原因： - **简化数据库操作**：Hibernate通过将Java对象与数据库表进行映射，使得开发者可以直接操作Java对象，而不需要编写复杂的SQL语句...

    hibernate缓存

    1. **一级缓存**：一级缓存是每个Hibernate Session实例的私有缓存，它自动管理对象的生命周期。当持久化对象被加载到内存时，它们会被添加到一级缓存中。当在同一个Session中再次访问这些对象时，Hibernate会首先从...

    hibernate 缓存详解

    二级缓存分为查询缓存和实体缓存两种，前者用于缓存 HQL 查询的结果，后者则存储对象实例。二级缓存可以显著减少对数据库的访问，但在分布式环境中需要考虑缓存同步的问题。 三、缓存策略 1. 谨慎使用缓存：并非...

    Hibernate注释深入解析

    Hibernate访问数据库的过程通常从`Configuration`实例开始。通过`new Configuration().configure()`初始化`Configuration`，Hibernate会在类路径下寻找`hibernate.cfg.xml`配置文件。配置文件包含了数据库连接信息...

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