Spring3+JBoss7+Jdbc JTA事务无法开启问题

0 0

Spring3+JBoss7+Jdbc JTA事务无法开启问题5

这两天为了验证JTA，做了一个小工程，主要意图是为了测试在Spring的JtaTransactionManager事务管理器下，管理多个数据库连接下的JDBC操作，实现异常后回滚，正常情况下提交，容器使用的是Jboss7.1.1

问题：前段Action调用Service时，总是无法回滚

先贴Spring配置（applicationContext-jta.xml）

<!-- Activates scanning of @Autowired -->
<context:annotation-config />

<!-- Activates scanning of @Repository and @Service -->
<context:component-scan base-package="com.jta" />

<!-- 从Jboss获取的数据源 -->
<jee:jndi-lookup id="oracleDataSourceProxy" jndi-name="java:jboss/datasources/OracleXA" />
<!-- 事务管理器 -->
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager" />
<!-- 事务注解扫描 -->
<tx:annotation-driven transaction-manager="transactionManager"/>

Service接口

@Transactional(propagation=Propagation.REQUIRED) 
@Service("jtaService")
public interface JtaService {
	void saveFiles();
}

Service实现类

@Service("jtaService")
@Transactional(propagation = Propagation.REQUIRED)
public class JtaServiceImpl implements JtaService {

	@Autowired
	private JtaDao jtaDao;

	@Transactional(propagation = Propagation.REQUIRED)
	public void saveFiles() {

		Random r = new Random();
		int i = r.nextInt(10000);
		File file = new File();
		file.setId(i);
		file.setName("name_10000");
		file.setContent("content_10000");

		File file2 = new File();
		file2.setId(10000);
		file2.setName("name_10000");
		file2.setContent("content_10000");
		try {
			jtaDao.insertToOracle(file);
                        //这里会出现主键冲突
			jtaDao.insertToOracle(file2);
		} catch (SQLException e) {
			throw new RuntimeException("主键冲突错误！");
		}
	}

	public JtaDao getJtaDao() {
		return jtaDao;
	}

	public void setJtaDao(JtaDao jtaDao) {
		this.jtaDao = jtaDao;
	}

}

DAO类

@Component
public class JtaDao {
	
	@Autowired
	private DataSource oracleDataSourceProxy;

	public int insertToOracle(File file) throws SQLException {
		String sql = "insert into t_file values(?, ?, ?, sysdate)";
		return insert(oracleDataSourceProxy, file, sql);
	}

	private int insert(DataSource ds, File file, String sql)
			throws SQLException {
		Connection conn = DataSourceUtils.getConnection(ds);
		PreparedStatement ps = conn.prepareCall(sql);
		ps.setInt(1, file.getId());
		ps.setString(2, file.getName());
		ps.setString(3, file.getContent());
		int i = ps.executeUpdate();
		DataSourceUtils.releaseConnection(conn, ds);
		return i;
	}

	public DataSource getOracleDataSourceProxy() {
		return oracleDataSourceProxy;
	}

	public void setOracleDataSourceProxy(DataSource oracleDataSourceProxy) {
		this.oracleDataSourceProxy = oracleDataSourceProxy;
	}

}

问题补充：使用JTA编程时方式测试可回滚和提交，证明Jboss和数据源及驱动都支持JTA

public void test() throws NamingException, SQLException, IllegalStateException, SecurityException, SystemException {
	UserTransaction ut = null;
	InitialContext ic = new InitialContext();
	ut = (UserTransaction) ic.lookup("java:comp/UserTransaction");
	System.out.println("ut=" + ut);
	
	DataSource ds1 = (DataSource) ic.lookup("java:jboss/datasources/MySQLXA");
	DataSource ds2 = (DataSource) ic.lookup("java:jboss/datasources/OracleXA");
	Connection conn1 = null;
	Connection conn2 = null;
	try {
		conn1 = ds1.getConnection();
		conn2 = ds2.getConnection();
		ut.begin();
		insert(conn1, 1, "name1");
		int i =  1 / 0;//抛出异常
		insert(conn2, 2, "name2");
		ut.commit();
	} catch (NotSupportedException e) {
		ut.rollback();
		System.out.println(e.getMessage());
	} catch (SystemException e) {
		ut.rollback();
		System.out.println(e.getMessage());
	} catch (SecurityException e) {
		ut.rollback();
		System.out.println(e.getMessage());
	} catch (IllegalStateException e) {
		ut.rollback();
		System.out.println(e.getMessage());
	} catch (RollbackException e) {
		ut.rollback();
		System.out.println(e.getMessage());
	} catch (HeuristicMixedException e) {
		ut.rollback();
		System.out.println(e.getMessage());
	} catch (HeuristicRollbackException e) {
		ut.rollback();
		System.out.println(e.getMessage());
	} catch(Exception e) {
		ut.rollback();
		System.out.println(e.getMessage());
	}
}

问题补充：
问题自己已经解决：
主要是将注解方式换成了XML配置，问题出在事务注解扫描未生效，换了方式之后成功，贴下成功后的配置：

<jee:jndi-lookup id="oracleDataSourceProxy" jndi-name="java:jboss/datasources/OracleXA" />
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager" />
	
<tx:advice id="txAdvice" transaction-manager="transactionManager">
	<tx:attributes>
		<tx:method name="save*" propagation="REQUIRED"/>
		<tx:method name="*" read-only="false"/>
	</tx:attributes>
</tx:advice>

<aop:config>
	<aop:pointcut id="txPointCut"
		expression="execution(* com.jta.service.*.*(..))" />
	<aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut" />
</aop:config>

<bean id="jtaDao" class="com.jta.dao.JtaDao">
	<property name="oracleDataSourceProxy" ref="oracleDataSourceProxy"></property>
</bean>
<bean id="jtaService" class="com.jta.service.JtaServiceImpl">
	<property name="jtaDao" ref="jtaDao"></property>
</bean>