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

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

<bean id="transactionManager" value="java:comp/UserTransaction"/>      </bean>             <bean id="transactionAdvisor" >      <ref local="transactionManager"/>      </property>      <property name="transactionAttributes">     <props>      <prop key="*">PROPAGATION_REQUIRED</prop>      </props>     </property>     </bean>           <!-- 注册自动代理创建，为业务Bean添加事务拦截器 -->      <bean id="BOAutoProxyCreator" 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 {       /**     * 创—AO类     * @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 的实现原理。

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

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