Hi,
I have two different databases.
1.Oracle
2. HSQLDB
I am inseting one row in each database, Second database insert fails. So I want to rollback the entire transaction and first database sould not be committed.
But in my code first database insert is getting committed.
Here is my spring configuration
Code:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:oxm="http://www.springframework.org/schema/oxm"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/oxm
http://www.springframework.org/schema/oxm/spring-oxm-1.5.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
<aop:aspectj-autoproxy proxy-target-class="true" />
<bean id="oracleDataSource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
<property name="url"
value="jdbc:oracle:thin:@172.168.1.1:1521:xe" />
<property name="username" value="xxx" />
<property name="password" value="xxx" />
</bean>
<bean id="hsqldbDataSource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="org.hsqldb.jdbcDriver" />
<property name="url" value="jdbc:hsqldb:hsql://localhost/" />
<property name="username" value="sa" />
<property name="password" value="" />
</bean>
<bean id="testAspect" class="com.demo.aop.TestAspect"></bean>
<bean id="XATester" class="com.demo.xa.XATesterClass">
<property name="oracleDatasource" ref="oracleDataSource"></property>
<property name="hsqldbDatasource" ref="hsqldbDataSource"></property>
<property name="transactionManager" ref="transactionManager"></property>
</bean>
<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
init-method="init" destroy-method="close">
<property name="forceShutdown">
<value>true</value>
</property>
</bean>
<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
</bean>
<tx:annotation-driven transaction-manager="transactionManager" />
<bean id="transactionManager"
class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager">
<ref bean="atomikosTransactionManager" />
</property>
<property name="userTransaction">
<ref bean="atomikosUserTransaction" />
</property>
</bean>
<bean id="caroline" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="transactionManager"><ref bean="transactionManager" /></property>
<property name="target"><ref bean="XATester" /></property>
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED, -Exception</prop>
</props>
</property>
</bean>
<aop:config proxy-target-class="true">
<aop:aspect ref="testAspect">
<aop:pointcut id="myCut" expression="execution(public * *(..))" />
<aop:around pointcut-ref="myCut" method="log" />
</aop:aspect>
</aop:config>
</beans>
This is how i am doing database insert.
Code:
/**
*
*/
package com.demo.xa;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
import org.springframework.jdbc.core.simple.SimpleJdbcTemplate;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.DefaultTransactionDefinition;
/**
* @author dp.prabu
*
*/
public class XATesterClass implements TesterInterface {
private DataSource oracleDatasource;
private DataSource hsqldbDatasource;
private PlatformTransactionManager transactionManager;
/**
* @return the oracleDatasource
*/
public DataSource getOracleDatasource() {
return oracleDatasource;
}
/**
* @param oracleDatasource the oracleDatasource to set
*/
public void setOracleDatasource(DataSource oracleDatasource) {
this.oracleDatasource = oracleDatasource;
}
/**
* @return the hsqldbDatasource
*/
public DataSource getHsqldbDatasource() {
return hsqldbDatasource;
}
/**
* @param hsqldbDatasource the hsqldbDatasource to set
*/
public void setHsqldbDatasource(DataSource hsqldbDatasource) {
this.hsqldbDatasource = hsqldbDatasource;
}
/**
* @return the transactionManager
*/
public PlatformTransactionManager getTransactionManager() {
return transactionManager;
}
/**
* @param transactionManager the transactionManager to set
*/
public void setTransactionManager(PlatformTransactionManager transactionManager) {
this.transactionManager = transactionManager;
}
public void testMethod() {
try {
SimpleJdbcInsert insertRecordHsqldb = new SimpleJdbcInsert(hsqldbDatasource).withTableName("temp");
Map<String,Object> parametersHsqldb = new HashMap<String,Object>();
parametersHsqldb.put("code", "3");
parametersHsqldb.put("name", "Prabu");
insertRecordHsqldb.execute(parametersHsqldb);
SimpleJdbcInsert insertRecord = new SimpleJdbcInsert(oracleDatasource).withTableName("EMP");
Map<String,Object> parameters = new HashMap<String,Object>();
parameters.put("id", "46");
parameters.put("name", "Prabu");
insertRecord.execute(parameters);
SimpleJdbcTemplate template2 = new SimpleJdbcTemplate(this.oracleDatasource);
String sql1 = "SELECT * FROM EMP";
List<Map<String, Object>> rows1=template2.queryForList(sql1);
System.out.println(rows1.size());
SimpleJdbcTemplate template = new SimpleJdbcTemplate(this.hsqldbDatasource);
String sql = "SELECT * FROM TEMP";
List<Map<String, Object>> rows=template.queryForList(sql);
System.out.println(rows.size());
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
}
Please advise. I don know what is wrong with this code.
Spring / Hibernate / Atomikos using two transactions instead of one so rollback fails
Reply With Quote