トランザクションの使い方

図5-1 は、BEA Tuxedo CORBA アプリケーションでトランザクションがどのように機能するのかを示しています。

図5-2 では、Transactions サンプル・アプリケーションのしくみを示しています。

手順	説明
1	トランザクションに関与する CORBA インターフェイスの OMG IDL コードを記述します。
2	インプリメンテーション・コンフィギュレーション・ファイル (ICF) で CORBA インターフェイスのトランザクション方針を定義します。
3	CORBA クライアント・アプリケーションを記述します。
4	CORBA サーバ・アプリケーションを記述します。
5	コンフィギュレーション・ファイルを作成します。

リスト5-1 は、Transactions サンプル・アプリケーションの OMG IDL コードを示しています。

{
typedef unsigned long CourseNumber;
typedef sequence<CourseNumber> CourseNumberList;

struct CourseSynopsis
{
CourseNumber course_number;
string title;
};
typedef sequence<CourseSynopsis> CourseSynopsisList;

interface CourseSynopsisEnumerator
{
// エントリがない場合は長さ 0 のリストを返す
CourseSynopsisList get_next_n(
in unsigned long number_to_get, // 0 の場合はすべてが返される
out unsigned long number_remaining
);

void destroy();
};
typedef unsigned short Days;
const Days MONDAY = 1;
const Days TUESDAY = 2;
const Days WEDNESDAY = 4;
const Days THURSDAY = 8;
const Days FRIDAY = 16;

struct CourseDetails
{
CourseNumber course_number;
double cost;
unsigned short number_of_credits;
ClassSchedule class_schedule;
unsigned short number_of_seats;
string title;
string professor;
string description;
};
typedef sequence<CourseDetails> CourseDetailsList;
typedef unsigned long StudentId;

// Registrar インターフェイスは、学生がデータベース
// にアクセスするためのメインのインターフェイス
interface Registrar
{
CourseSynopsisList
get_courses_synopsis(
in string search_criteria,
in unsigned long number_to_get,
out unsigned long number_remaining,
out CourseSynopsisEnumerator rest);

CourseDetailsList get_courses_details(in CourseNumberList
courses);
StudentDetails get_student_details(in StudentId student);
NotRegisteredList register_for_courses(
in StudentId student,
in CourseNumberList courses
) raises (
TooManyCredits
);

トランザクション方針	説明
always	インターフェイスは常にトランザクションの一部である必要があります。インターフェイスがトランザクションの一部ではない場合、トランザクションは TP フレームワークによって自動的に開始されます。
ignore	インターフェイスはトランザクションに関与しません。ただし、トランザクションのスコープ内でこのインターフェイスに要求を行うことはできます。このインターフェイスの UBBCONFIG ファイルで指定される AUTOTRAN パラメータは無視されます。
never	インターフェイスはトランザクションに関与しません。このインターフェイス用に作成されるオブジェクトは、トランザクションに関与できません。BEA Tuxedo システムは、この方針が設定されているインターフェイスがトランザクションに関与した場合に INVALID_TRANSACTION 例外を生成します。
optional	インターフェイスはトランザクションに関与できます。要求がトランザクションに関係する場合、オブジェクトはトランザクションに関与できます。このトランザクション方針はデフォルトです。注記要求のトランザクション・プロパティは、autotran パラメータを使用しても定義できます。

リスト5-2 は、トランザクションの開発手順を説明する Transactions サンプル・アプリケーションの CORBA C++ クライアント・アプリケーションの一部分です。

CORBA::Object_var var_transaction_current_oref =
Bootstrap.resolve_initial_references("TransactionCurrent");
CosTransactions::Current_var var_transaction_current_ref=
CosTransactions::Current::_narrow(var_transaction_current_oref.in());
//トランザクションを開始
var_transaction_current_ref->begin();
try {
// トランザクション内でオペレーションを実行
pointer_Registar_ref->register_for_courses(student_id, course_number_list);
// ...
// オペレーションがエラーなしで実行された場合は、トランザクションをコミット
CORBA::Boolean report_heuristics = CORBA_TRUE;
var_transaction_current_ref->commit(report_heuristics);
}
catch (...) {
// オペレーションで実行エラーが発生した場合は、トランザクションをロールバック
// 次に元の例外を再びスローする
// ロールバックが失敗した場合、例外を無視し、
// 元の例外を再びスローする
try {
var_transaction_current_ref->rollback();
}
catch (...) {
TP::userlog("rollback failed");
}
throw;
}

リスト5-3 は、XA リソース・マネージャをオープンおよびクローズする Transactions サンプル・アプリケーションの Server オブジェクトのコードの一部分です。

CORBA::Boolean Server::initialize(int argc, char* argv[])
{
TRACE_METHOD("Server::initialize");
try {
open_database();
begin_transactional();
register_fact();
return CORBA_TRUE;
}
catch (CORBA::Exception& e) {
LOG("CORBA exception : " <<e);
}
catch (SamplesDBException& e) {
LOG("Can’t connect to database");
}
catch (...) {
LOG("Unexpected exception");
}
cleanup();
return CORBA_FALSE;
}

static void cleanup()
{
unregister_factory();
end_transactional();
close_database();
}

// トランザクション・リソース・マネージャを管理するユーティリティ
CORBA::Boolean s_became_transactional = CORBA_FALSE;
static void begin_transactional()
{
TP::open_xa_rm();
s_became_transactional = CORBA_TRUE;
}
static void end_transactional()
{
if(!s_became_transactional){
// クリーンアップは不要
return;
}
try {
TP::close_xa_rm ();
}
catch (CORBA::Exception& e) {
LOG("CORBA Exception : " << e);
}
catch (...) {
LOG("unexpected exception");
}
s_became_transactional = CORBA_FALSE;
}

リスト5-4 は、Transactions サンプル・アプリケーションのコンフィギュレーション・ファイルでこの情報が定義されている部分です。

OPENINFO = "ORACLE_XA:Oracle_XA+SqlNet=ORCL+Acc=P
/scott/tiger+SesTm=100+LogDir=.+MaxCur=5"
OPENINFO = "ORACLE_XA:Oracle_XA+Acc=P/scott/tiger
+SesTm=100+LogDir=.+MaxCur=5"
CLOSEINFO = ""
TMSNAME = "TMS_ORA"