SharePlex 11.4 - 管理者ガイド

トランスフォーメーションの概要

トランスフォーメーションでは、ターゲットデータベースにSQL操作を適用する代わりに、PL/SQLプロシージャ（トランスフォーメーションルーチンとして定義）を呼び出すようにPostプロセスに指示します。トランスフォーメーションによって、ターゲットにポストする前に、またはターゲットのポストの代わりにレプリケートされたデータを操作することができます。

例えば、ソース側のテーブルとターゲット側のテーブルの構造が異なる場合は（ある人の姓と名がソース側のテーブルでは1つの列に含まれるが、ターゲット側のテーブルでは別の列にある場合など）、レプリケーションに成功するように、これらの列のデータを変換するトランスフォーメーションルーチンを記述することができます。トランスフォーメーションルーチンを使用してデータ型、測定単位、文字セットを変換することができます。また、I/Oオーバーヘッドを削減するためにデータベースのトリガーの代わりに使用したり、その他多くのビジネス要件に使用したりすることができます。

テーブルにトランスフォーメーションを指定した場合、Postはレプリケートされたデータに対して何も行いません。その代わりに、トランスフォーメーションルーチンにデータ値を渡すため、プロシージャでデータの形式と送信先の両方を制御することができます。ターゲット側のテーブルへのポスト、別の場所へのポスト、またはその両方が可能です。したがって、ルーチンを記述する場合は、プロシージャの中にポストに必要なSQL操作を含める必要があります。

サポート対象のソース

Oracle

サポート対象

Oracle

サポートされているレプリケーション戦略

トランスフォーメーションは、同一の構造やデータの維持を考慮することなく、SharePlexを使用して1つのテーブルから別のテーブルにデータを転送する便利な方法です。このため、レポート作成、ブロードキャスト、データマート、およびウェアハウスの用途に有効です。

トランスフォーメーションは、ピアツーピアや高可用性レプリケーション環境には適していません。高可用性を実現するには、レプリケーションによって同期させた同一のデータベースが必要です。ピアツーピアレプリケーションでは、SharePlexは、同じレコードに同時に変更があった場合にコンフリクトを検出して解決できなければなりません。データが変換されると、SharePlexは同期を検証し、コンフリクトを検出するために前後の値を比較することができません。

サポートされている操作

トランスフォーメーションでは、INSERT、UPDATE、DELETEの操作のみがサポートされています。プロシージャを開発する際には以下が可能です。

• 3つの操作のタイプすべてに対して1つのプロシージャを作成することも、操作のタイプごとにプロシージャを作成することもできます。
• 1つのプロシージャをすべてのテーブルに使用することも、異なるテーブルに異なるプロシージャを使用することもできます。SharePlexでは、このためにワイルドカードを使ってテーブルを指定できます。

トランスフォーメーションルーチンが個々のテーブルに指定され、そのテーブルが別のルーチンが指定されたテーブルグループの一部でもある場合、関連するDML操作が発生すると、そのテーブルに固有のルーチンだけがそのテーブルに使用されます。

トランスフォーメーションを使用する際の考慮事項

トランスフォーメーションによってデータが変更され、SharePlexはデータをポストしないため、トランスフォーメーションによってレプリケーションの動作が変更されます。これはSharePlex処理のカスタマイズです。トランスフォーメーション手順を確実に成功させるために、トランスフォーメーションを実施する前に以下の考慮事項を確認してください。

権限

トランスフォーメーションのためにPL/PGSQLを通じてアクセスするテーブルには、オブジェクトの所有者からSharePlexに暗黙的に付与された権限が必要です。

キー

PRIMARYまたはUNIQUEキーは、トランスフォーメーションを使用するすべてのテーブルに必要です。SharePlexは、キーを使用してUPDATEとDELETEに対するターゲット側の行を特定します。これにより、UPDATE操作のターゲット側のテーブルからトランスフォーメーションルーチンに値を返すことができます。ターゲットシステムでキーの変更を許可しないでください。許可すると、SharePlexはルーチンに値を渡すための行を特定することができなくなります。

ルーチンのテスト

意図したとおりに動作することを確認し、あるルーチンが別のルーチンを打ち消さないことを確認するために、本番稼働環境に投入する前にトランスフォーメーションルーチンをテストしてください。データが変換されると、SharePlexは、ルーチンが正しく機能しているかどうかの指標である同期を検証するために前後の値を比較することができません。同期を確認する唯一の方法は、compareコマンドにkeyオプションを使用することです。このオプションはキーの値だけを比較するもので、同期の完全な確認にはなりません。欠落している行や余分な行を検出するだけです。これは、ターゲットデータが変換されているため、非キー列の値がソース列の値と適切に相関しているかどうかを示すものではありません。

これらの理由から、repairコマンドはデータの再同期には使用できません。再同期の手順は、各企業のビジネスルールとデータベース環境に基づいて独自に考案する必要があります。

日付

SharePlexのトランスフォーメーションのデフォルトの日付形式はMMDDYYYY HH24MISSです。デフォルトの日付を持つテーブルでは、この形式を使用する必要があります。使用しないとトランスフォーメーションでエラーが返されます。デフォルトの日付でテーブルを作成する前に、SQL*Plusで以下のコマンドを使用して日付形式を変更してください。

ALTER SESSION SET nls_date_format = 'MMDDYYYYHH24MISS'

その他の考慮事項

• トランスフォーメーションではLOB列とLONG列の変更はサポートされません。
• プロシージャにデータを渡すための処理のオーバーヘッドが、プロシージャ自体を実行するためのオーバーヘッドに加わることで、通常のレプリケーションやポスティングよりもターゲットシステムの全体的なパフォーマンスが低下します。
• 一般的なコンフリクト解決とトランスフォーメーションの両方に同じPL/SQLパッケージが使用されます（名前はsp_cr）。テーブルには、一般的なコンフリクト解決かトランスフォーメーションのいずれかを使用しますが、両方を使用することはできません。変換されたテーブルはSharePlexでcompareすることができず、コンフリクトの解決は成功しません。両方が使われている場合、SharePlexはトランスフォーメーションルーチンのみを呼び出します。該当する場合、同じ設定内の異なるテーブルに対して一般的なコンフリクト解決とトランスフォーメーションを使用することができます。詳細については、ピアツーピアレプリケーションの設定 を参照してください。

トランスフォーメーションの展開

トランスフォーメーションの展開には以下のステップがあります。

1. トランスフォーメーション対象のソース側とターゲット側のテーブルの設定エントリを作成します。トランスフォーメーションを使用するテーブルには特別な設定手順はありません。他のテーブルと同じように設定します。詳細については、設定ファイルの作成を参照してください。
2. トランスフォーメーションルーチンを作成します。詳細については、トランスフォーメーションルーチンの作成を参照してください。
3. トランスフォーメーションファイルを作成し、トランスフォーメーションルーチンの呼び出しをSharePlexに指示します。詳細については、トランスフォーメーションファイルの作成を参照してください。

トランスフォーメーションルーチンの作成

トランスフォーメーションルーチンは動的PL/SQLプロシージャ言語で記述します。sp_crという名前のパブリックパッケージで定義されているパラメーター、レコード構造、テーブル構造を使用します。このパッケージは、データベースのSharePlexスキーマにインストールされています。このパッケージでは以下のパラメーターを使用します。

プロシージャインターフェイス

このテンプレートに従ってプロシージャを作成してください。

ここで:

• splexはSharePlexのスキーマです。
• sp_crはPL/SQLレコードおよびテーブルの構造を含むパッケージの名前です。
• row_typは、in/out変数を渡すPL/SQLレコードの名前です（「パッケージの定義」を参照）。
• col_def_typeは、列情報を保存するPL/SQLテーブルの名前です（「col_def_typeテーブル」を参照）。

パッケージの定義

SharePlexは、SharePlexのデータベーススキーマのsp_crという名前を持つパブリックパッケージのPL/SQLレコードとテーブルの構造を定義します。 このパッケージでは以下のパラメーターを使用します。

CREATE SCHEMA IF NOT EXISTS sp_cr;

CREATE TYPE sp_cr.row_typ AS

(src_host VARCHAR(32),

src_db VARCHAR(32),

src_time VARCHAR(20),

statement_type VARCHAR(6),

source_table VARCHAR(128),

target_table VARCHAR(128),

native_error INTEGER,

sql_state VARCHAR(10)

);

CREATE TYPE sp_cr.col_def_typ AS

(column_name VARCHAR,

datatype VARCHAR,

is_key BOOLEAN,

is_changed BOOLEAN,

old_value VARCHAR ,

new_value VARCHAR

);

CREATE SEQUENCE EXC_SEQ START WITH 1 INCREMENT BY 1 MINVALUE 1 CACHE 20 NO CYCLE ;

IN変数

行の操作によってコンフリクトが発生するたびに、SharePlexはこのメタデータ情報をプロシージャに渡します。

OUT変数

これらの変数は、プロシージャに成功したか失敗したかに基づいてSharePlexのアクションを指示します。

col_def_typeテーブル

SharePlexは、レプリケートされた操作ごとにcol_def_tabtyp PL/SQLテーブルを作成します。 このテーブルには列情報が保存されます。これは、プロシージャの使用目的がトランスフォーメーションかコンフリクト解決かによって異なります。

• トランスフォーメーション: 行を操作するたびに、SharePlexは列情報をcol_def_typeに書き込みます。
• コンフリクトの解決: 行の操作でコンフリクトが発生するたびに、SharePlexは列情報をcol_def_tabtypに書き込みます。

すべてのフィールドはSharePlexによってルーチンに渡されますが、SharePlexが行を見付けられない場合は、すべてのフィールドに値があるとは限りません。

以下はcol_def_tabtypテーブルに入力するために使用するデータ型です。

CREATE SCHEMA IF NOT EXISTS sp_cr;

CREATE TYPE sp_cr.row_typ AS

(src_host VARCHAR(32),

src_db VARCHAR(32),

src_time VARCHAR(20),

statement_type VARCHAR(6),

source_table VARCHAR(128),

target_table VARCHAR(128),

native_error INTEGER,

sql_state VARCHAR(10)

);

CREATE TYPE sp_cr.col_def_typ AS

(column_name VARCHAR,

datatype VARCHAR,

is_key BOOLEAN,

is_changed BOOLEAN,

old_value VARCHAR ,

new_value VARCHAR

);

CREATE SEQUENCE EXC_SEQ START WITH 1 INCREMENT BY 1 MINVALUE 1 CACHE 20 NO CYCLE ;

col_def_tabtypの説明

col_def_tabtypテーブルのエントリの例（操作のタイプ別）

以下の表は、各操作で起こりうる結果を示しています。

INSERT操作

¹ INSERTが失敗するのは、同じPRIMARYキーを持つ行が既にターゲットデータベースに存在するためです。SharePlexはINSERTの現在の値を返しません。

UPDATE操作

¹（コンフリクト解決）UPDATEが失敗するのは、SharePlexがPRIMARYキーとプリイメージを使用して行を見付けることができないためです。行が見付からない場合、SharePlexはPRIMARYキーのみを使用して行を検索します。SharePlexが行を見付けた場合、変更された列だけでなくキー列の現在の値も返します。SharePlexがPRIMARYキーを使用しただけでは行を見付けられない場合、SharePlexはNULLを返します。

²（トランスフォーメーション）UPDATEの場合、SharePlexはPRIMARYキーとプリイメージを使用して行を検索することはできません。これはトランスフォーメーションによりプリイメージが異なるためです。別の方法として、PRIMARYキーだけを使用して行を検索することもできます。見付かった場合、SharePlexは変更された列だけでなくキー列の現在の値も返します。PRIMARYキーだけでは行を特定できない場合、current_valueはNULLになります。

DELETE操作

¹ DELETEが失敗するのは、SharePlexがPRIMARYキーを使用して行を見付けることができなかったためです。したがって、SharePlexはNULLを返します。

トランスフォーメーションファイルの作成

SQL操作のポストではなくトランスフォーメーションルーチンの呼び出しをSharePlexに指示するには、transformation.SIDファイルを使用します。ここで、SIDはターゲットデータベースのORACLE_SIDです。SQL操作を実行する前に、Postはこのファイルを読み込んで、呼び出さなければならないトランスフォーメーションルーチンがあるかどうかを判断します。

このファイルの場所

空白のtransformation.SIDファイルでは、SIDはターゲットインスタンスのORACLE_SIDです。これは、SharePlexのインストール時にSharePlexの変数データディレクトリのdataサブディレクトリに含まれていたものです。ターゲットシステム上のファイルを使用します。

このファイルがない場合は、ASCIIテキストエディタでASCII形式のファイルを作成することができます。名前はtransformation.SIDでなければなりません。ここで、SIDはターゲットインスタンスのORACLE_SIDです。

注: SIDでは大文字と小文字を区別します。

重要: transformation.SIDファイルは、アクティブな設定ごとに1つだけでなければなりません。

ファイルへの入力方法

以下のテンプレートを使用して、プロシージャを1つ以上のオブジェクトおよび操作のタイプにリンクします。

ここで:

• owner.objectはターゲットオブジェクトの所有者と名前またはワイルドカードエントリです（「構文規則」を参照）。
• i| u | dは、指定されたプロシージャによって変換される操作のタイプです。例えばidやiudのように、一部またはすべての操作のタイプを指定することができます。大文字でも小文字でも構いません。
• owner.procedureは、指定されたオブジェクトと操作のタイプを扱うプロシージャの所有者と名前です。

構文規則

• オブジェクトの指定、操作のタイプの指定、プロシージャの指定の間には、少なくとも1つのスペースを空けなければなりません。
• LIKE演算子とSQLワイルドカード（%）を使用すると、検索文字列を使用して複数のオブジェクトを指定できます（例を参照）。
• アンダースコア（_）を使用して1文字のワイルドカードを表すことができます。アンダースコア文字を含むテーブル名（emp_salなど）の場合、SharePlexはバックスラッシュ（\）を拡張文字として認識し、アンダースコアがワイルドカードではなくリテラルであることを示します（例: like:scott.%\_corp\_emp）。LIKE演算子を使用しない場合、オブジェクト名にアンダースコアが含まれていても、バックスラッシュ拡張文字は必要ありません。
• ファイルのいずれかの場所にコメント行を入れます。コメント行の先頭にはポンド記号（#）を付けます。

トランスフォーメーションファイルの例

レプリケーション中にファイルを変更する方法

トランスフォーメーションファイルはレプリケーション中にいつでも変更でき、テーブルやプロシージャを追加したり削除したりできます。ファイルを変更したら、Postプロセスを一旦停止し、再度開始します。

セキュリティ機能の設定

SharePlexは、ローカルシステム上およびネットワーク経由で転送中のレプリケートされたデータを保護するのに役立つ多くのセキュリティ機能を備えています。この章では、これらの機能の設定と使用に関するガイドラインを説明します。

注意: PostgreSQLからPostgreSQLへデータをレプリケートする場合、SharePlexはSSL/TLSによるデータの保護およびエクスポートとインポート間のデータの暗号化セキュリティ機能のみをサポートします。

内容