CORBA クライアント・アプリケーションのトランザクション

CORBA::Object_var var_transaction_current_oref =
Bootstrap.resolve_initial_references(“TransactionCurrent”);
CosTransactions::Current_var transaction_current_oref=
CosTransactions::Current::_narrow(
var_transaction_current_oref.in());

org.omg.CORBA.Object transCurObj =
gBootstrapObjRef.resolve_initial_references(
“TransactionCurrent”);
org.omg.CosTransactions.Current gTransCur=
org.omg.CosTransactions.CurrentHelper.narrow(transCurObj);

表 4-1 では、TransactionCurrent オブジェクトのメソッドについて説明します。

表 4-1 TransactionCurrent オブジェクトのメソッド

メソッド	説明
begin	新しいトランザクションを作成します。以降のオペレーションは、このトランザクションのスコープ内で発生します。クライアント・アプリケーションがトランザクションを開始したとき、デフォルトのトランザクション・タイムアウトは 300 秒です。set_timeout メソッドで、このデフォルト値を変更できます。
commit	トランザクションを正常に終了します。このクライアント・アプリケーションですべてのオペレーションが正常に終了したことを示します。
rollback	トランザクションを強制的にロールバックします。
rollback_only	可能なアクションのみがロールバックされるようにトランザクションをマークします。通常、このメソッドは、サーバ・アプリケーションでのみ使用されます。
suspend	現在のトランザクションの参加を一時停止します。このメソッドは、トランザクションを示すオブジェクトを返し、クライアント・アプリケーションが後でトランザクションを再開できるようにします。
resume	指定したトランザクションの参加を再開します。
get_status	クライアント・アプリケーションでトランザクションのステータスを返します。
get_transaction_name	トランザクションを示す出力可能な文字列を返します。
set_timeout	トランザクションに関連付けられたタイムアウトを修正します。デフォルトのトランザクション・タイムアウト値は 300 秒です。begin メソッドで明示的に開始するのではなく、トランザクションが自動的に開始した場合、タイムアウト値は、UBBCONFIG ファイルの TRANTIME パラメータで指定した値です。TRANTIME パラメータの設定方法については、第 5章「トランザクションの管理」を参照してください。
get_control	トランザクションを表すコントロール・オブジェクトを返します。

//トランザクションを開始
transaction_current_oref->begin();
try {
//Perform the operation inside the transaction
pointer_Registar_ref->register_for_courses(student_id, course_number_list);
...
// オペレーションがエラーなしで実行された場合は、トランザクションをコミット
CORBA::Boolean report_heuristics = CORBA_TRUE;
transaction_current_ref->commit(report_heuristics);
}
catch (CORBA::Exception &) {
// オペレーションで実行エラーが発生した場合は、トランザクションをロールバック
// 次に元の例外を再びスローする
// ロールバックが失敗した場合、例外を無視し、
// 元の例外を再びスローする
try {
transaction_current_ref->rollback();
}
catch (CORBA::Exception &) {
TP::userlog("rollback failed");

throw;
}

try{
gTransCur.begin();
//トランザクション内でオペレーションを実行
not_registered =
gRegistrarObjRef.register_for_courses(student_id,selected_course_numbers);

if (not_registered != null)

//オペレーションがエラーなしで実行された場合は、トランザクションをコミット
boolean report_heuristics = true;
gTransCur.commit(report_heuristics);

} else gTransCur.rollback();

} catch(org.omg.CosTransactions.NoTransaction nte) {
System.err.println(“NoTransaction: “ + nte);
System.exit(1);
} catch(org.omg.CosTransactions.SubtransactionsUnavailable e) {
System.err.println(“Subtransactions Unavailable: “ + e);
System.exit(1);
} catch(org.omg.CosTransactions.HeuristicHazard e) {
System.err.println(“HeuristicHazard: “ + e);
System.exit(1);
} catch(org.omg.CosTransactions.HeuristicMixed e) {
System.err.println(“HeuristicMixed: “ + e);
System.exit(1);
}

' トランザクションを開始
'
objTransactionCurrent.begin
'
' コースの登録を試行
'
NotRegisteredList = objRegistrar.register_for_courses(mStudentID,
CourseList, exception)
'
If exception.EX_majorCode = NO_EXCEPTION then
' 要求が成功したら、トランザクションをコミット
'
Dim report_heuristics As Boolean
report_heuristics = True
objTransactionCurrent.commit report_heuristics
Else
' 要求が失敗したら、トランザクションをロールバック
'
objTransactionCurrent.rollback
MsgBox "Transaction Rolled Back"
End If