---
title: "分布式事务示例 - JDBC 驱动程序  V2.4.15 | OceanBase 文档中心"
description: 分布式事务示例 本节主要介绍如何使用 Oracle XA 功能实现分布式事务的示例。 Oracle XA 导入 使用 Oracle XA 功能必须导入以下内容： import oracle.jdbc.xa.OracleXid; import oracle.jdbc.xa.OracleXAException; impo…
---
切换语言

- 中文站 - 简体中文
- International - English
- 日本站 - 日本語

文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*bhcER5Qvet8AAAAAAAAAAAAADiGDAQ/original) JDBC 驱动程序 V 2.4.15

# 分布式事务示例

更新时间：2026-05-08 16:10:59

[编辑](https://github.com/oceanbase/connector-j-doc/edit/V2.4.15/zh-CN/400.reference-information/100.features-specific-to-oracle-mode/500.distributed-transactions/300.distributed-transaction-example.md)  

本节主要介绍如何使用 Oracle XA 功能实现分布式事务的示例。

## Oracle XA 导入

使用 Oracle XA 功能必须导入以下内容：

```java
import oracle.jdbc.xa.OracleXid;
import oracle.jdbc.xa.OracleXAException;
import oracle.jdbc.pool.*;
import oracle.jdbc.xa.client.*;
import javax.transaction.xa.*;

```

`oracle.jdbc.pool` 软件包具有用于连接池功能的类，并将与 XA 相关的类作为子类。

或者，如果代码将在数据库内部运行并访问该数据库以进行 SQL 操作，则必须导入 `oracle.jdbc.xa.server` 而不是 `oracle.jdbc.xa.client`。语法如下：

```java
import oracle.jdbc.xa.server.*;

```

客户端和服务器软件包分别具有 `OracleXADataSource`、`OracleXAConnection` 和 `OracleXAResource` 类的版本。 这三个类的抽象版本位于顶层 `oracle.jdbc.xa` 包中。

## Oracle XA 代码示例

如下为 XA 事务的处理过程示例：

1. 使用 `XA START` 启动 XA 事务，并将其置于 `ACTIVE` 状态。
 2. 对于处于 `ACTIVE` 状态的 XA 事务，执行构成该事务的 SQL 语句，然后执行 `XA END` 语句。`XA END` 使事务置于 `IDLE` 状态。
 3. 对于处于 `IDLE` 状态的 XA 事务，可以执行 `XA PREPARE` 语句或 `XA COMMIT ... ONE PHASE` 语句：

      - `XA PREPARE` 将事务置于 `PREPARED` 状态。此时的 `XA RECOVER` 语句在其输出中包括事务的 `xid` 值，因为 `XA RECOVER` 会列出所有处于`PREPARED` 状态的 XA 事务。
      - `XA COMMIT ... ONE PHASE` 用于预备和提交事务。由于事务终止，`xid` 值未由 `XA RECOVER` 列出。
 4. 对于处于 `PREPARED` 状态的 XA 事务，可以执行 `XA COMMIT` 语句来提交和终止事务，或者执行 `XA ROLLBACK` 来回滚和终止事务。

```java
public static void initClass() throws SQLException {
    createTable(tableName1, "c1 int,c2 int");
    createTable(tableName2, "c1 int,c2 int");
    createTable(tableName3, "c1 varchar(200)");
}

public void obOracleXAOne() throws Exception {
    Assume.assumeTrue(sharedUsePrepare());
    Connection conn = setConnection();  
    conn.createStatement().execute(" insert into " + tableName1 + "  values(1,2)");
    JDBC4MysqlXAConnection mysqlXAConnection = new JDBC4MysqlXAConnection(
        (OceanBaseConnection) conn);
    String gtridStr = "gtrid_test_wgs_ob_oracle_xa_one";
    String bqualStr = "bqual_test_wgs_ob_oracle_xa_one";
    Xid xid = new MysqlXid(gtridStr.getBytes(), bqualStr.getBytes(), 123);
    try {
        mysqlXAConnection.start(xid, XAResource.TMNOFLAGS);
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        pstmt = conn.prepareStatement("select c1 from " + tableName1);
        rs = pstmt.executeQuery();

        while (rs.next()) {
            System.out.println(rs.getInt(1));
        }
        pstmt.close();
        pstmt = conn.prepareStatement("insert into " + tableName1 + " (c1, c2) values(?, ?)");
        pstmt.setInt(1, 12);
        pstmt.setInt(2, 12);
        pstmt.executeUpdate();
        mysqlXAConnection.end(xid, XAResource.TMSUCCESS);
        mysqlXAConnection.prepare(xid);
        mysqlXAConnection.commit(xid, false);
    } catch (Exception e) {
        e.printStackTrace();
        mysqlXAConnection.rollback(xid);
        throw e;
    }
}

public void obOracleXAOnePhase() throws Exception {
    Assume.assumeTrue(sharedUsePrepare());
    Connection conn = null;

    conn = setConnection();
    conn.createStatement().execute(" insert into " + tableName2 + "  values(1,2)");

    JDBC4MysqlXAConnection mysqlXAConnection = new JDBC4MysqlXAConnection(
        (OceanBaseConnection) conn);
    String gtridStr = "gtrid_test_wgs_ob_oracle_xa_one_phase";
    String bqualStr = "bqual_test_wgs_ob_oracle_xa_one_phase";

    Xid xid = new MysqlXid(gtridStr.getBytes(), bqualStr.getBytes(), 123);
    try {
        mysqlXAConnection.start(xid, XAResource.TMNOFLAGS);
        // ps test
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        pstmt = conn.prepareStatement("select c1 from " + tableName2 + "");
        rs = pstmt.executeQuery();

        while (rs.next()) {
            System.out.println(rs.getInt(1));
        }

        pstmt.close();

        pstmt = conn.prepareStatement("insert into " + tableName2 + " (c1, c2) values(?, ?)");
        pstmt.setInt(1, 12);
        pstmt.setInt(2, 12);
        pstmt.executeUpdate();

        mysqlXAConnection.end(xid, XAResource.TMSUCCESS);
        mysqlXAConnection.commit(xid, true);
    } catch (Exception e) {
        mysqlXAConnection.rollback(xid);
        throw e;
    }
}

```

#### 说明

`setConnection()` 对应的连接参数需要使用 `useServerPrepStmts=true`，类似于 `jdbc:oceanbase://xx:xx/xx?useServerPrepStmts=true&...` 。

  上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线