Hibernate+Spring多数据库解决方案(二)

上篇 Hibernate+Spring多数据库解决方案(一)

4） 事务控制，使用Spring的 JtaTransactionManager 类来控制，但要为其注入JBboss启动后的 JTA事务管理器的名字 java:comp/UserTransaction； 使用Spring的自动代理功能为 业务类 *Service 进行拦截，控制事务边界。
    

<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">  
    <property name="userTransactionName" value="java:comp/UserTransaction"/>  
    </bean>   
      
    <bean id="transactionAdvisor" class="org.springframework.transaction.interceptor.TransactionInterceptor">  
    <property name="transactionManager" >  
    <ref local="transactionManager"/>  
    </property>  
    <property name="transactionAttributes">  
   <props>   
   <prop key="*">PROPAGATION_REQUIRED</prop>   
   </props>  
   </property>  
   </bean>   
     
   <!-- 注册自动代理创建，为业务Bean添加事务拦截器 -->   
   <bean id="BOAutoProxyCreator" class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">   
   <property name="proxyTargetClass" value="true"></property>  
   <property name="beanNames">  
   <list>  
   <value>*Service</value>   
   </list>  
   </property>  
   <property name="interceptorNames">  
   <list>   
   <value>trasactionMethodPointcutAdvisor</value> <!-- 注意： 事务拦截器必须包含在业务日志拦截器中，以免事务控制混乱；或者将业务日志的方法recordLog 设置为 PROPAGATION_REQUIRES_NEW 属性 -->   
   </list>  
   </property>  
   </bean>  

 <

   5） 配置 XA 数据源，在 jboss 4 的 server/default/deploy  目录下添加 oracle-xa-ds.xml 文件，在其中配置数据源，

 

  <xa-datasource>  
    <jndi-name>XAOracleDS_MAIN</jndi-name>  
    <track-connection-by-tx/>  
    <isSameRM-override-value>false</isSameRM-override-value>  
    <use-java-context>false</use-java-context>   
    <xa-datasource-class>oracle.jdbc.xa.client.OracleXADataSource</xa-datasource-class>  
    <xa-datasource-property name="URL">jdbc:oracle:thin:@192.168.0.25:1521:DB_SYS</xa-datasource-property>  
    <xa-datasource-property name="User">admin</xa-datasource-property>  
    <xa-datasource-property name="Password">admin</xa-datasource-property>  
   <!-- Uses the pingDatabase method to check a connection is still valid before handing it out from the pool -->  
   <!--valid-connection-checker-class-name>org.jboss.resource.adapter.jdbc.vendor.OracleValidConnectionChecker</valid-connection-checker-class-name-->  
   <!-- Checks the Oracle error codes and messages for fatal errors -->  
   <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.OracleExceptionSorter</exception-sorter-class-name>  
   <!-- Oracles XA datasource cannot reuse a connection outside a transaction once enlisted in a global transaction and vice-versa -->  
   <no-tx-separate-pools/>  
   <metadata>  
   <type-mapping>Oracle9i</type-mapping>  
   </metadata>  
   </xa-datasource>  

这里是 XAOracleDS_MAIN 的配置，XAOracleDS_ORDER 的配置修改下 IP，user，password就可以了。

   6） 关键代码
    最关键的一步，就是以往 dao.setSessionFactory( sessionFactory ) 注入，要改为由  SessionFactoryManager 来注入，否则dao无法关联到正确的库，也无法操作数据。

    我们项目中采用动态 Service，DAO 创建，也就是零配置，是在 DAOFactory 中进行的注入，在 DAOFactory.createDAO(daoClass)方法中，源代码贴出来，帮助理解：

 

  public class DAOFactory {   
    /** 
    * 创建DAO类 
    * @param daoClass 
    * @return 
    * @throws Exception 
    */  
    public static BaseDAO createDAO(Class daoClass) throws Exception {  
           SessionFactoryManager sessionFactoryManager = (SessionFactoryManager) BeanFactory.getBean(SessionFactoryManager.class);  
         BaseDAO dao = null;  
         try {  
               dao = (BaseDAO) BeanFactory.createBean(daoClass);  
         } catch (Exception e) {  
            throw e;  
         }  
         SessionFactory sf = sessionFactoryManager.getSessionFactory( dao.getVoClass() );  
         dao.setSessionFactory(sf); //注入sessionFactory  
         return dao;  
      }  
   }  

OK。 写个测试用例跑跑看：在删除user的时候，同时删除它对应的所有订单。 

下篇再详细说下多库的集中模式，和 SessionFactoryManager  的实现原理。

既然已经在spring配置文件中配置了2个sessionfactory，为什么不直接使用配置文件把需要的sessionfactory直接注入到DAO中？

如果你的Service ，DAO是一个个配置在Spring中的话，完全可以啊直接注入啊，没问题，只要你不怕麻烦的话，注意不要配叉了。

只是个人不喜欢臃肿的 Service ，DAO 配置，个人喜好。

补充一下（也算提前预告）， 不管是两库，还是多库，只要符合“平行库”的多数据库架构，也都可以用配置的方式进行固定注入, 例如：

    <bean id="userDao" class="com.sr.jsfuser.dao.jdbc.UserDao">         
    <property name="sessionFactory" ref="sessionFactory_DB_MAIN" />         
</bean>

但是在“主+分支”的多数据库架构中，例如：一个省公司库+多个市公司库， 数据路由需要由例如 user 的所属的公司的编码 companyID 来决定， 因为此时 Order 在每个市公司库中都有，这种方式就需要使用变量的方式了。
(我们项目中是十多个数据库的架构)。 不过使用 sessionFactoryManager 来处理路由算法 还是更为简便。

过几天会详细介绍多数据库架构的这两种模式和路由的处理原理。