学步园

 最近项目中涉及到了两个Oracle数据库的操作。需要用到分布式事务,研究之后贴出代码供大家参考。

 1.dao-core.xml(核心事务配置XML)

     <?xml version="1.0" encoding="UTF-8"?><br /> <beans xmlns="http://www.springframework.org/schema/beans"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx"<br /> xmlns:aop="http://www.springframework.org/schema/aop"<br /> xmlns:context="http://www.springframework.org/schema/context"<br /> xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"><br /> <!-- 支持注解 --><br /> <context:annotation-config /></p> <p> <bean id="jotm"<br /> class="org.springframework.transaction.jta.JotmFactoryBean" /></p> <p> <bean id="txManager"<br /> class="org.springframework.transaction.jta.JtaTransactionManager"><br /> <property name="userTransaction" ref="jotm" /><br /> </bean></p> <p> <!--两个数据源--><br /> <bean id="cmcDataSource" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown"><br /> <property name="dataSource"><br /> <bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown"><br /> <property name="transactionManager" ref="jotm"/><br /> <property name="driverName" value="oracle.jdbc.driver.OracleDriver"/><br /> <property name="url" value="jdbc:oracle:thin:@192.168.6.80:1521:C2SServer"/><br /> <property name="user" value="d1xn_cmc"/><br /> <property name="password" value="d1xn_cmc"/><br /> </bean><br /> </property></p> <p> <property name="user" value="d1xn_cmc"/><br /> <property name="password" value="d1xn_cmc"/><br /> </bean></p> <p> <bean id="woniuDataSource" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown"><br /> <property name="dataSource"><br /> <bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown"><br /> <property name="transactionManager" ref="jotm"/><br /> <property name="driverName" value="oracle.jdbc.driver.OracleDriver"/><br /> <property name="url" value="jdbc:oracle:thin:@192.168.6.80:1521:C2SServer"/><br /> <property name="user" value="sn_woniu"/><br /> <property name="password" value="sn_woniu"/><br /> </bean><br /> </property></p> <p> <property name="user" value="sn_woniu"/><br /> <property name="password" value="sn_woniu"/><br /> </bean></p> <p> <!-- =================== 事务管理AOP配置 =================== --><br /> <bean id="cmcEntityManagerFactory"<br /> class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"><br /> <property name="persistenceXmlLocation" value="classpath:com/d1xn/commercial/dao/config/persistence.xml"/><br /> <property name="persistenceUnitName" value="CMC_PU"/><br /> <property name="dataSource" ref="cmcDataSource"/><br /> <property name="loadTimeWeaver"><br /> <bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver"/><br /> </property><br /> <property name="jpaPropertyMap"><br /> <map><br /> <entry key="hibernate.transaction.manager_lookup_class"<br /> value="org.hibernate.transaction.JOTMTransactionManagerLookup" /><br /> <entry key="hibernate.transaction.flush_before_completion" value="true" /><br /> <entry key="hibernate.transaction.auto_close_session" value="true" /><br /> <entry key="hibernate.current_session_context_class" value="jta" /><br /> <entry key="hibernate.connection.release_mode" value="auto" /><br /> </map><br /> </property><br /> </bean></p> <p> <bean id="woniuEntityManagerFactory"<br /> class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"><br /> <property name="persistenceXmlLocation" value="classpath:com/d1xn/commercial/dao/config/persistenceWoniu.xml"/><br /> <property name="persistenceUnitName" value="WONIU_PU"/><br /> <property name="dataSource" ref="woniuDataSource"/><br /> <property name="loadTimeWeaver"><br /> <bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver"/><br /> </property><br /> <property name="jpaPropertyMap"><br /> <map><br /> <entry key="hibernate.transaction.manager_lookup_class"<br /> value="org.hibernate.transaction.JOTMTransactionManagerLookup" /><br /> <entry key="hibernate.transaction.flush_before_completion" value="true" /><br /> <entry key="hibernate.transaction.auto_close_session" value="true" /><br /> <entry key="hibernate.current_session_context_class" value="jta" /><br /> <entry key="hibernate.connection.release_mode" value="auto" /><br /> </map><br /> </property><br /> </bean></p> <p> <tx:advice id="txAdvice" transaction-manager="txManager"><br /> <tx:attributes><br /> <tx:method name="save*" rollback-for="Excepiton"/><br /> <tx:method name="delete*" rollback-for="Excepiton"/><br /> <tx:method name="update*" rollback-for="Excepiton"/><br /> <tx:method name="find*" read-only="true"/><br /> <tx:method name="*" rollback-for="java.lang.Exception"/><br /> </tx:attributes><br /> </tx:advice></p> <p> <aop:config><br /> <aop:pointcut id="userOperation"<br /> expression="execution(public * com.d1xn.commercial.dao.imp.*Service*.*(..))"/><br /> <aop:advisor advice-ref="txAdvice"<br /> pointcut-ref="userOperation"/><br /> </aop:config></p> <p> <!-- ===================== AOP事务配置结束 ====================== --><br /> <!-- 业务类 --><br /> <bean id="cmcDaoHelper" class="com.d1xn.dao.core.DAOHelper" init-method="init"><br /> <property name="entityManagerHelper"><br /> <bean class="com.d1xn.commercial.dao.cmc.CmcEntityManagerHelper"/><br /> </property><br /> </bean></p> <p> <bean id="woniuDaoHelper" class="com.d1xn.dao.core.DAOHelper" init-method="init"><br /> <property name="entityManagerHelper"><br /> <bean class="com.woniu.system.dao.WoniuEntityManagerHelper"/><br /> </property><br /> </bean></p> <p> <bean id="jtaTestService" class="com.d1xn.commercial.dao.imp.JTATestService"><br /> <property name="cmcDaoHelper" ref="cmcDaoHelper"/><br /> <property name="woniuDaoHelper" ref="woniuDaoHelper"/><br /> </bean><br /> </beans>

2.persistence.xml

     <?xml version="1.0" encoding="UTF-8"?><br /> <persistence xmlns="http://java.sun.com/xml/ns/persistence"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xsi:schemaLocation="http://java.sun.com/xml/ns/persistence<br /> http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"<br /> version="1.0"><br /> <persistence-unit name="CMC_PU" transaction-type="JTA"><br /> <provider>org.hibernate.ejb.HibernatePersistence</provider></p> <p> <class>com.d1xn.commercial.pojo.cmc.entity.GameGoodsType</class><br /> <class>com.d1xn.commercial.pojo.cmc.entity.ThreeRole</class></p> <p> <properties><br /> <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle9Dialect" /><br /> <property name="hibernate.show_sql" value="true" /><br /> <!-- 最大连接数 --><br /> <property name="hibernate.c3p0.max_size" value="20"/><br /> <!-- 最小连接数 --><br /> <property name="hibernate.c3p0.min_size" value="5"/><br /> <!-- 获得连接的超时时间,如果超过这个时间,会抛出异常，单位毫秒 --><br /> <property name="hibernate.c3p0.timeout" value="120"/><br /> <!-- 最大的PreparedStatement的数量 --><br /> <property name="hibernate.c3p0.max_statements" value="100"/><br /> <!-- 每隔120秒检查连接池里的空闲连接 ，单位是秒--><br /> <property name="hibernate.c3p0.idle_test_period" value="120"/><br /> <!-- 当连接池里面的连接用完的时候，C3P0一下获取的新的连接数 --><br /> <property name="hibernate.c3p0.acquire_increment" value="2"/><br /> <!-- 每次都验证连接是否可用 --><br /> <property name="hibernate.c3p0.validate" value="true"/><br /> </properties><br /> </persistence-unit><br /> </persistence>

3.persistenceWoniu.xml

     <?xml version="1.0" encoding="UTF-8"?><br /> <persistence xmlns="http://java.sun.com/xml/ns/persistence"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xsi:schemaLocation="http://java.sun.com/xml/ns/persistence<br /> http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"<br /> version="1.0"><br /> <persistence-unit name="WONIU_PU" transaction-type="JTA"><br /> <provider>org.hibernate.ejb.HibernatePersistence</provider></p> <p> <class>com.woniu.system.pojo.SysCompany</class><br /> <class>com.woniu.system.pojo.SysUserRole</class><br /> <class>com.woniu.system.pojo.SysUserRoleId</class></p> <p> <properties><br /> <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle9Dialect" /><br /> <property name="hibernate.show_sql" value="true" /><br /> <!-- 最大连接数 --><br /> <property name="hibernate.c3p0.max_size" value="20"/><br /> <!-- 最小连接数 --><br /> <property name="hibernate.c3p0.min_size" value="5"/><br /> <!-- 获得连接的超时时间,如果超过这个时间,会抛出异常，单位毫秒 --><br /> <property name="hibernate.c3p0.timeout" value="120"/><br /> <!-- 最大的PreparedStatement的数量 --><br /> <property name="hibernate.c3p0.max_statements" value="100"/><br /> <!-- 每隔120秒检查连接池里的空闲连接 ，单位是秒--><br /> <property name="hibernate.c3p0.idle_test_period" value="120"/><br /> <!-- 当连接池里面的连接用完的时候，C3P0一下获取的新的连接数 --><br /> <property name="hibernate.c3p0.acquire_increment" value="2"/><br /> <!-- 每次都验证连接是否可用 --><br /> <property name="hibernate.c3p0.validate" value="true"/><br /> </properties><br /> </persistence-unit><br /> </persistence>

 4.MyTest-context.xml

     <?xml version="1.0" encoding="UTF-8"?><br /> <beans xmlns="http://www.springframework.org/schema/beans"<br /> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"<br /> xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"></p> <p> <import resource="classpath:com/d1xn/commercial/dao/config/dao-core.xml"/></p> <p></beans>

    5.IJTATestService.java接口

     public interface IJTATestService {</p> <p> public boolean saveEntity(IEntity woniu, IEntity cmc);<br /> }  

    6.JTATestService.java类

      public class JTATestService implements IJTATestService {<br /> private DAOHelper woniuDaoHelper;<br /> private DAOHelper cmcDaoHelper;</p> <p> public boolean saveEntity(IEntity woniu, IEntity cmc) {<br /> woniuDaoHelper.persist(woniu);<br /> cmcDaoHelper.persist(cmc);</p> <p> return false;<br /> }</p> <p> public void setWoniuDaoHelper(DAOHelper woniuDaoHelper) {<br /> this.woniuDaoHelper = woniuDaoHelper;<br /> }</p> <p> public void setCmcDaoHelper(DAOHelper cmcDaoHelper) {<br /> this.cmcDaoHelper = cmcDaoHelper;<br /> }<br /> }

   7. MyTest.java

       @ContextConfiguration<br /> @RunWith(SpringJUnit4ClassRunner.class)<br /> public class MyTest {<br /> @Autowired<br /> private IJTATestService service;</p> <p> @org.junit.Test<br /> public void test() {<br /> SysCompany sysCompany = new SysCompany();<br /> sysCompany.setSName("sss");<br /> sysCompany.setSState("0");</p> <p> SysUserRole role = new SysUserRole();<br /> SysUserRoleId id = new SysUserRoleId();<br /> id.setNRoleId(2L);<br /> id.setNUserId(1L);<br /> role.setId(id);</p> <p> GameGoodsType type = new GameGoodsType();<br /> type.setSNo("aaa");<br /> type.setSName("222");<br /> type.setSState("1");</p> <p> service.saveEntity(sysCompany, type);<br /> }<br /> }

     8.特别说明

        在项目测试的过程中，有一个错误困扰了我很久，总会报这样的错误

       Hibernate: select SN_WONIU.SYS_COMPANY_SQ.nextval from dual
       java.sql.SQLException: Cannot get connection for URL jdbc:oracle:thin:@192.168.6.80:1521:C2SServer : 调用中无效的参数

        Google了一大圈有不少人碰到这个问题，后来偶是在http://forum.springsource.org/archive/index.php/t-28145.html找到了答案,就是在配置数据源的时候，StandardXAPoolDataSource中要配置user和password，StandardXADataSource中也要配置user和password。 不明白为啥，希望高人不吝赐教。