基于Atomikos的MySQL与Oracle分布式XA事务失效问题排查

我帮你排查下这个XA事务回滚失败的问题，看起来核心问题出在数据源配置和事务处理逻辑上，咱们一步步来解决：

问题核心分析 #

你遇到的情况是Oracle更新操作没有回滚，本质原因是Oracle和MySQL的数据源没有被正确配置为XA数据源，导致这两个数据库的操作没有加入到Atomikos管理的分布式事务中。当MySQL插入失败时，Oracle的更新已经提交（因为用了普通数据源，事务是本地事务），自然无法回滚。

一、修复XA数据源配置 #

普通的BasicDataSource是本地事务数据源，不支持XA分布式事务，必须替换为Atomikos提供的AtomikosDataSourceBean来包装数据库原生的XA数据源：

1. Oracle XA数据源配置 #

<!-- 配置Oracle原生XA数据源 -->
<bean id="OraXADataSource" class="oracle.jdbc.xa.client.OracleXADataSource" destroy-method="close">
    <property name="URL" value="jdbc:oracle:thin:@localhost:1521:xe"/>
    <property name="user" value="TEST1"/>
    <property name="password" value="TEST11"/>
</bean>

<!-- 用Atomikos包装XA数据源，纳入分布式事务管理 -->
<bean id="OraDataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
    <property name="uniqueResourceName" value="OracleDB"/> <!-- 唯一标识，必须与其他数据源不同 -->
    <property name="xaDataSource" ref="OraXADataSource"/>
    <property name="maxPoolSize" value="10"/>
    <property name="minPoolSize" value="2"/>
</bean>

2. MySQL XA数据源配置 #

首先确保MySQL开启XA支持（MySQL 5.7+默认支持，若版本较低需在my.cnf中添加xa=on），然后配置XA数据源：

<!-- 配置MySQL原生XA数据源 -->
<bean id="MySqlXADataSource" class="com.mysql.cj.jdbc.MysqlXADataSource">
    <property name="url" value="jdbc:mysql://localhost/test2?useSSL=false&amp;serverTimezone=UTC"/>
    <property name="user" value="test2"/>
    <property name="password" value="test2"/>
</bean>

<!-- 用Atomikos包装XA数据源 -->
<bean id="MySqldataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
    <property name="uniqueResourceName" value="MySQLDB"/> <!-- 唯一标识，与Oracle的不同 -->
    <property name="xaDataSource" ref="MySqlXADataSource"/>
    <property name="maxPoolSize" value="10"/>
    <property name="minPoolSize" value="2"/>
</bean>

二、修复事务代码逻辑 #

你的事务处理代码有两个问题：DAO类没有正确使用XA数据源执行SQL，异常处理没有正确触发事务回滚。

1. 修正DAO类实现 #

确保OraUpdater和MySqlInserter使用JdbcTemplate执行SQL，这样才能关联到Atomikos管理的XA连接：

public class OraUpdater {
    private JdbcTemplate jdbcTemplate;
    private String sql;

    // 注入XA数据源
    public void setDataSource(DataSource dataSource) {
        this.jdbcTemplate = new JdbcTemplate(dataSource);
    }

    public void setSql(String sql) {
        this.sql = sql;
    }

    public void update() {
        jdbcTemplate.update(sql); // 实际执行Oracle更新
    }
}

MySqlInserter的实现类似，把插入逻辑用JdbcTemplate执行。

2. 修正事务回调的异常处理 #

需要正确标记事务回滚，并传递实际异常给Spring事务管理器：

public class MyTxTester {
    private final SQLErrorCodeSQLExceptionTranslator exceptionTranslator = new SQLErrorCodeSQLExceptionTranslator();
    private PlatformTransactionManager txManager;
    private OraUpdater oraUpdater;
    private MySqlInserter mySqlInserter;

    public void wrapperCall(){
        TransactionTemplate txTemplate = new TransactionTemplate(txManager);
        txTemplate.execute(new TransactionCallback<Object>() {
            public Object doInTransaction(TransactionStatus transactionStatus) {
                try {
                    // 执行Oracle更新
                    oraUpdater.update();
                    // 执行MySQL插入（触发唯一约束失败）
                    mySqlInserter.update();
                } catch (SQLException sqle) {
                    // 强制标记事务回滚
                    transactionStatus.setRollbackOnly();
                    // 转换为Spring数据访问异常，让事务管理器感知
                    throw exceptionTranslator.translate("执行SQL失败", "", sqle);
                }
                return null;
            }
        });
    }
}

三、额外检查点 #

• 确保Atomikos的日志目录xyz/atomikos存在且有读写权限，XA事务需要日志来完成故障恢复。
• 数据库权限检查：Oracle用户需要授予XA_ADMIN角色；MySQL用户需要PROCESS权限（用于XA事务状态查询）。
• 确认Spring的JtaTransactionManager配置中depends-on="userTransactionService"正确，保证Atomikos事务服务先初始化。

完成以上修改后，再测试场景：Oracle更新后MySQL插入触发唯一约束失败，Oracle的更新会被正确回滚，符合分布式事务的预期。

内容的提问来源于stack exchange，提问作者satish marathe