使用JTA实现跨库事务 -

Ajita

浏览: 708869 次

最近访客更多访客>>

btvying

tim2018

u011407152

ioandy

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

使用JTA实现跨库事务

博客分类：

java应用

JTA atomikos 跨库事务

本文是基于atomikos实现的JTA跨库事务
示例中的数据访问层为Hibernate，可替换为喜欢的任意的方式。
具体使用比较简单，只是需要在配置上做一些修改
具体测试源码见附件，其中核心配置如下：

    <context:component-scan base-package="com.ajita.*" />
	<tx:annotation-driven />
	<tx:jta-transaction-manager />

	<bean id="dataSourceA" class="com.atomikos.jdbc.AtomikosDataSourceBean"
		init-method="init" destroy-method="close">
		<property name="uniqueResourceName">
			<value>DataSourceA</value>
		</property>
		<property name="xaDataSourceClassName">
			<value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>
		</property>
		<property name="xaProperties">
			<props>
				<prop key="databaseName">test</prop>
				<prop key="serverName">127.0.0.1</prop>
				<prop key="port">3306</prop>
				<prop key="user">root</prop>
				<prop key="password">123456</prop>
				<prop key="url">jdbc:mysql://127.0.0.1:3306/test</prop>
			</props>
		</property>
		<property name="minPoolSize">
			<value>1</value>
		</property>
	</bean>

	<bean id="dataSourceB" class="com.atomikos.jdbc.AtomikosDataSourceBean"
		init-method="init" destroy-method="close">
		<property name="uniqueResourceName">
			<value>DataSourceB</value>
		</property>
		<property name="xaDataSourceClassName">
			<value>net.sourceforge.jtds.jdbcx.JtdsDataSource</value>
		</property>
		<property name="xaProperties">
			<props>
				<prop key="databaseName">SimpleDB</prop>
				<prop key="serverName">127.0.0.1</prop>
				<prop key="portNumber">1434</prop>
				<prop key="user">sa</prop>
				<prop key="password">123456</prop>
			</props>
		</property>
		<property name="minPoolSize">
			<value>1</value>
		</property>
	</bean>

	<bean id="entityManagerFactoryA"
		class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
		<property name="persistenceXmlLocation">
			<value>classpath*:persistence.xml</value>
		</property>
		<property name="persistenceUnitName" value="PersistenceUnitA" />
		<property name="dataSource" ref="dataSourceA" />
		<property name="jpaVendorAdapter">
			<bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
				<property name="showSql" value="true" />
				<property name="databasePlatform" value="org.hibernate.dialect.MySQL5InnoDBDialect" />
			</bean>
		</property>
	</bean>

	<bean id="entityManagerFactoryB"
		class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
		<property name="persistenceXmlLocation">
			<value>classpath*:persistence.xml</value>
		</property>
		<property name="persistenceUnitName" value="PersistenceUnitB" />
		<property name="dataSource" ref="dataSourceB" />
		<property name="jpaVendorAdapter">
			<bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
				<property name="showSql" value="true" />
				<property name="databasePlatform" value="org.hibernate.dialect.SQLServerDialect" />
			</bean>
		</property>
	</bean>

	<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
		init-method="init" destroy-method="close">
		<property name="forceShutdown" value="false" />
	</bean>

	<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.J2eeUserTransaction">
		<property name="transactionTimeout" value="300" />
	</bean>

	<bean id="transactionManager"
		class="org.springframework.transaction.jta.JtaTransactionManager"
		depends-on="atomikosTransactionManager,atomikosUserTransaction">
		<property name="transactionManager" ref="atomikosTransactionManager" />
		<property name="userTransaction" ref="atomikosUserTransaction" />
		<property name="allowCustomIsolationLevels" value="true" />
	</bean>

有不清楚的，欢迎留言交流~

SimpleDemo.zip (12.4 KB)
下载次数: 31

分享到：

[转]redis中各种数据类型对应的jedis操作 ... | 基于Cas的单点登录实现

2014-02-28 11:18
浏览 4308
评论(4)
分类:编程语言
查看更多

4 楼 johnny_56 2014-06-20

嗯。问题已解决，谢谢，是连接的问题，但是不是配置文件问题，而是数据库问题。

3 楼 Ajita 2014-06-19

johnny_56 写道

你好，请问，我的报这个是什么原因呢。
用的是jtds1.2.7
Caused by: com.atomikos.beans.PropertyException: no writeable property 'URL' in class 'net.sourceforge.jtds.jdbcx.JtdsDataSource'
at com.atomikos.beans.PropertyUtils.getSetter(PropertyUtils.java:261)
at com.atomikos.beans.PropertyUtils.setDirectProperty(PropertyUtils.java:175)
at com.atomikos.beans.PropertyUtils.setProperty(PropertyUtils.java:85)
at com.atomikos.beans.PropertyUtils.setProperties(PropertyUtils.java:161)
at com.atomikos.jdbc.AtomikosDataSourceBean.doInit(AtomikosDataSourceBean.java:167)
at com.atomikos.jdbc.AbstractDataSourceBean.init(AbstractDataSourceBean.java:239)

这个问题解决了。是之前换驱动了。数据库是sqlserver2000,一开始用的是微软的驱动，后来因为不支持XA，所以换了jtds，然后参数设置不一样。
换成这样。
<bean id="dataSourceSqlServer" class="com.atomikos.jdbc.AtomikosDataSourceBean"
        init-method="init" destroy-method="close">
       <property name="uniqueResourceName" value="sqlserver_ds" />
       <property name="xaDataSourceClassName">
<value>net.sourceforge.jtds.jdbcx.JtdsDataSource</value>
</property>
        
        <property name="xaProperties">
        <props>
<prop key="databaseName">HallQueueDbWasu</prop>
<prop key="serverName">127.0.0.1</prop>
<prop key="portNumber">1433</prop>
<prop key="user">sa</prop>
<prop key="password">sa</prop>
</props>
        </property>
        <property name="minPoolSize">
<value>1</value>
</property>
</bean> 。但是又抱另一个错误了。。。。

Caused by: com.atomikos.jdbc.AtomikosSQLException: Cannot initialize AtomikosDataSourceBean
at com.atomikos.jdbc.AtomikosSQLException.throwAtomikosSQLException(AtomikosSQLException.java:19)
at com.atomikos.jdbc.AbstractDataSourceBean.init(AbstractDataSourceBean.java:249)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1544)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1485)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1417)
... 46 more
Caused by: com.atomikos.icatch.SysException: XAConnectionFactory: failed to create pooled connection
at com.atomikos.jdbc.AtomikosXAConnectionFactory.createPooledConnection(AtomikosXAConnectionFactory.java:42)
at com.atomikos.datasource.pool.ConnectionPool.init(ConnectionPool.java:45)
at com.atomikos.datasource.pool.ConnectionPool.<init>(ConnectionPool.java:33)
at com.atomikos.jdbc.AbstractDataSourceBean.init(AbstractDataSourceBean.java:240)
... 53 more
2014-6-19 16:25:38 org.apache.catalina.core.StandardContext start

主要是创建连接池失败了，还是配置参数的问题。

2 楼 johnny_56 2014-06-19

johnny_56 写道

1 楼 johnny_56 2014-06-19

发表评论

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

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

使用JTA实现跨库事务

评论

发表评论

相关推荐

最近访客 更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

使用JTA实现跨库事务

评论

发表评论

相关推荐

[转]redis中各种数据类型对应的jedis操作命令

CXF记录WebService的soap日志

上传一个基于Jax-ws的WebService

上传一个最简单的cxf结合spring的Java WebService例子

Tomcat集群——使用apache负载

Tomcat集群（使用了nginx负载）

Maven培训分享

使用nexus搭建内部Maven仓库及使用简介

基于Mina的Http Server以及简单的Http请求客户端

Java发送邮件

XStream转换Java对象与XML

简单的log4j.properties示例

Spring集成Hibernate写SQLServer

基于Spring MVC接收并处理HTTP请求

最近访客更多访客>>