8. JTAアプリケーションの開発

8.1. プログラミング・開発ガイド

import javax.ejb.SessionContext;
import javax.transaction.UserTransaction;
import javax.naming.InitialContext;
import javax.sql.DataSource;
import java.sql.Connection;
 
InitialContext ic = new InitialContext();
UserTransaction utx = (UserTransaction)ic.lookup("java:comp/UserTransaction");
DataSource ds = (DataSource)ic.lookup("DB/sample");
UserTransaction utx = ctx.getUserTransaction();
 
// 以下、トランザクション処理
utx.begin();
try {
    // 業務処理
    Connection con = ds.getConnection();
    // コネクション(con)を利用したデータベース更新をここで行なう
    con.close();
    utx.commit();
} catch (Exception e) {
    // 例外処理
    if (con != null) con.close();
    utx.rollback();
}

8.1.1. UserTransactionインスタンスの取得

8.1.1.1. EJBコンテナから利用する場合

// セッションBeanのsetSessionContextメソッド内で渡されたSessionContextを
// フィールド変数(sessionContext)として保持しておく
SessionContext ctx = sessionContext;
UserTransaction utx = ctx.getUserTransaction();

この場合、トランザクション開始前にJDBCコネクションを取得したり、トランザクション完了後にJDBCコネクションをクローズすることができます。

8.1.1.2. EJBコンテナ、Webコンテナ、アプリケーションクライアントから利用する場合

InitialContext ic = new InitialContext();
UserTransaction utx = (UserTransaction)ic.lookup("java:comp/UserTransaction");

EJBアプリケーションに限り、トランザクション開始前にJDBCコネクションを取得したり、トランザクション完了後にJDBCコネクションをクローズすることができます。

8.1.1.3. それ以外の場合

InitialContext ic = new InitialContext();
UserTransaction utx = (UserTransaction)ic.lookup("UserTransaction");

この場合、トランザクション開始前にJDBCコネクションを取得したり、トランザクション完了後にJDBCコネクションをクローズすることはできません。

8.1.2. トランザクションの開始

utx.begin();

8.1.3. 業務処理の実行

DataSource ds = (DataSource)ic.lookup("DB/sample");
Connection con = ds.getConnection();
// コネクション(con)を利用したデータベース更新をここで行なう
con.close();

Memo
データベースのアクセス方法の詳細については、 [ アプリケーション開発ガイド（共通） > 3. JDBCアプリケーションの開発 ] を参照してください。

8.1.4. トランザクションの終了

try {
    // 業務処理
    utx.commit();
} catch (Exception e) {
    // 例外処理
    utx.rollback();
}

8.1.5. トランザクションタイムアウトの設定

utx.setTransactionTimeout(30);
utx.begin();
try {
    // 業務処理
    // 30秒以内に業務処理が終わらない場合自動的にロールバックする

8.1.6. ロールバックのマーク

try {
    // 業務処理
} catch (Exception e) {
    // 例外処理
    utx.setRollbackOnly();
}
utx.commit();

8.1.7. トランザクション状態の取得

int status = utx.getStatus();