본 절에서는 XA 기능을 구성요소별로 설명한다.

JDBC 3.0 표준에서는 전역 트랜잭션과 지역 트랜잭션 사이에서 커넥션을 공유할 수 있고, 각각으로 변환할 수 있다.

일반적으로 커넥션은 다음의 세 가지 모드 중에 반드시 하나를 갖는다.

각 커넥션은 실행 상태에 따라 다음과 같이 세 가지 모드 사이에서 자동으로 바뀐다. 단, 커넥션이 초기화될 때에는 항상 NO_TXN 모드로 동작한다.

Tibero에서는 XA 표준에 따른 분산 트랜잭션 패키지인 com.tmax.tibero.jdbc.ext 내부에 다음과 같은 클래스를 지원한다.

본 절에서는 JDBC 2.0 표준 패키지에 정의된 XA 인터페이스의 구성요소를 설명한다.

다음은 두 개의 트랜잭션 브랜치로 이루어진 Two-phase 분산 트랜잭션 환경을 구현하는 순서이다.

다음의 예는 위 순서에 맞게 구현된 Java 프로그램 소스 코드이다.

import java.sql.*;
import javax.sql.XAConnection;
import javax.transaction.xa.XAResource;
import com.tmax.tibero.jdbc.ext.*;

public class TwoBranchXA
{
  public static void main(String args[]) throws SQLException
  {
    createBaseTable();
    try {
          // Create XADataSource instance
          TbXADataSource xads1 = new TbXADataSource();
          xads1.setUrl("jdbc:tibero:thin:@localhost:7629:dbsvr");
          xads1.setUser("tibero");
          xads1.setPassword("tmax");
          
          TbXADataSource xads2 = new TbXADataSource();
          xads2.setUrl("jdbc:tibero:thin:@localhost:8629:dbsvr");
          xads2.setUser("wrpark");
          xads2.setPassword("tmax");
          
          // Get the XA connection
          XAConnection xacon1 = xads1.getXAConnection();
          XAConnection xacon2 = xads2.getXAConnection();

          // Get the physical connection
          Connection conn1 = xacon1.getConnection();
          Connection conn2 = xacon2.getConnection();

          // Get the XA resource
          XAResource xars1 = xacon1.getXAResource();
          XAResource xars2 = xacon2.getXAResource();   

          // Create the Xid
          Xid xid1 = createXid(1);
          Xid xid2 = createXid(2);

          // Start the resource
          xars1.start(xid1, XAResource.TMNOFLAGS);
          xars2.start(xid2, XAResource.TMNOFLAGS);

          // Execute SQL operations
          execute1(conn1);
          execute2(conn2);

          // End both the branches
          xars1.end(xid1, XAResource.TMSUCCESS);
          xars2.end(xid2, XAResource.TMSUCCESS);

          // Prepare the resource manager
          int pre1 = xars1.prepare(xid1);
          int pre2 = xars2.prepare(xid2);

          // Commit or rollback
          if (pre1 == XAResource.XA_RDONLY || pre1 == XAResource.XA_OK)
              xars1.commit(xid1, false);
          else   
              xars1.rollback(xid1);    

          if (pre2 == XAResource.XA_RDONLY || pre2 == XAResource.XA_OK)      
              xars2.commit(xid2, false);  
          else     
              xars2.rollback(xid2);   

           // Clear
           conn1.close();   
           conn1 = null; 
           conn2.close();      
           conn2 = null;    

           xacon1.close();   
           xacon1 = null;    
           xacon2.close();       
           xacon2 = null;  
        }
    catch (Exception se) {
           se.printStackTrace();    
        }     
  }
}