| Oracle® Fusion Middleware Oracle GoldenGateの管理 12c (12.3.0.1) E89931-05 |
|
 前 |
 次 |
内容は次のとおりです。
データのマッピングおよび操作のサポートには次のような制限があります。
Oracle GoldenGateは、ラージ・オブジェクトのフィルタリング、列マッピングまたは操作をサポートしていません。
Oracle GoldenGateの一部の機能および動作では、データのフィルタリングおよび操作がサポートされません。該当する場合、この制限についての記載があります。
Oracle GoldenGateで実行されるデータの選択、マッピングおよび操作は、すべてTABLEパラメータおよびMAPパラメータのオプションを1つ以上使用して行われます。
Extractパラメータ・ファイルでTABLEを使用します。
Replicatパラメータ・ファイルでMAPを使用します。
TABLEとMAPは、パラメータ・ファイル内の他のパラメータに影響を受けるデータベース・オブジェクトを指定します。これらのパラメータによるオブジェクト名指定の詳細は、「Oracle GoldenGateの入力におけるオブジェクト名の指定」を参照してください。
異なるデータ構造を持つ表どうしのマッピングおよび変換には、ソース定義ファイルまたはターゲット定義ファイル、あるいは(一定の場合)その両方が必要です。このファイルを使用する場合は、SOURCEDEFSパラメータまたはTARGETDEFSパラメータで指定する必要があります。
自己記述型の証跡ファイルを使用している場合、これは該当しません。
ソース定義ファイルまたはターゲット定義ファイルの作成方法の詳細は、メタデータへのレプリケートされたデータの関連付けを参照してください。
計画中の構成が大量の列マッピングまたはデータ変換を伴う場合は、次のガイドラインに従って、それらの機能をどのプロセスで実行するかを判断してください。
Oracle GoldenGateがWindowsベースのシステムとUNIXベースのシステムでのみ稼働している場合、列のマッピングおよび変換は、ソース・システム、ターゲット・システムまたは中間システムで実行できます。ソース・システムでこの処理に追加のオーバーヘッドが発生するのを防止するため、ターゲット・システムまたは中間システムで実行されるマッピングおよび変換を構成できます。
複数のソースに対して1つのターゲットがある場合、状況によってはソースでマッピングと変換を実行すると効率が向上することがあります。アプリケーションでレイアウト変更が発生するたびにターゲットにコピーする必要のある個別のソース定義ファイルをソース・データベースごとに管理するのではなく、ターゲット表から生成された1つのターゲット定義ファイルを使用できます。
使用する定義ファイルのタイプと場所の詳細は、メタデータへのレプリケートされたデータの関連付けを参照してください。
データベースとプラットフォームの間のデータのマッピングおよび変換を計画する際には、グローバリゼーションに関してOracle GoldenGateでサポートされている処理とサポートされていない処理を考慮してください。これらの考慮事項には、次のトピックが含まれます。
Oracle GoldenGateでは、ソースとターゲットのキャラクタ・セットが異なると、オブジェクト名および列データがデータベース間で正しく比較、マップ、操作されるようにするため、キャラクタ・セットの変換が行われます。サポートされるキャラクタ・セットのリストは、サポートされるキャラクタ・セットを参照してください。
異なるデータベースの間で文字が正確に表現されるためには、次の条件を満たす必要があります。
ターゲット・データベースのキャラクタ・セットは、ソース・データベースのキャラクタ・セットのスーパーセットであるか、ソース・データベースのキャラクタ・セットと同等である必要があります。同等とは、同一であることではなく、同じ文字のセットが存在することを意味します。たとえば、Shift-JISとEUC-JPは、厳密に言うと完全に同一ではありませんが、ほとんどの場合に同じ文字が存在します。
クライアント・アプリケーションで異なるキャラクタ・セットが使用されている場合、データベースのキャラクタ・セットがクライアント・アプリケーションのキャラクタ・セットのスーパーセットであるか、クライアント・アプリケーションのキャラクタ・セットと同等であることも必要です。
この構成では、クライアントまたはソースのキャラクタ・セットからローカル・データベースのキャラクタ・セットへの変換時に、すべての文字が表現されます。
Replicatプロセスは、1つのソース・キャラクタ・セットから1つのターゲット・キャラクタ・セットへの変換をサポートできます。
Oracle GoldenGateでは、カタログ、スキーマ、表および列の名前は、ソース・データベースおよびターゲット・データベースのキャラクタ・セット・エンコーディングに従って、ネイティブ言語で処理されます。このサポートにより、データベース階層のあらゆるレベルで、シングルバイトおよびマルチバイトの名前、記号、アクセント文字、大/小文字の区別が維持され、ロケールがあればそれも考慮されます。
Oracle GoldenGateでは、データが次のタイプの列に格納されている場合、キャラクタ・セット間での列データの変換がサポートされます。
文字型の列: CHAR/VARCHAR/CLOBから別のキャラクタ・セットのCHAR/VARCHAR/CLOBへの変換、およびCHAR/VARCHAR/CLOBとNCHAR/NVARCHAR/NCLOBとの間の変換。
文字列ベースの数値および日時データを含む列。z/OSのEBCDICデータとz/OS以外のASCIIデータの間では、これらの列の変換が実行されます。このデータのASCII版とASCII版の間、およびEBCDIC版とEBCDIC版の間では、データに互換性があるため、変換は実行されません。
注意:
Oracle GoldenGateでは、0001-01-03 00:00:00から9999-12-31 23:59:59までのタイムスタンプ・データがサポートされます。タイムスタンプがGMTからローカル時間に変換されると、これらの制限も変換後のタイムスタンプに適用されます。タイムゾーンに応じて、変換により時間が追加または引かれる場合があり、これにより、タイムスタンプがサポートされている上限を超えたり、下回ったりすることがあります。
列データのキャラクタ・セット変換は、ReplicatのMAPパラメータのCOLMAP句またはUSEDEFAULTS句のソース列とターゲット列との直接マッピングに限定されています。直接マッピングは、ストアド・プロシージャや列変換関数を使用しない、名前から名前へのマッピングです。Replicatは、キャラクタ・セット変換を実行します。Extractやデータ・ポンプでは変換は実行されません。
Extract 11.2.1より前のリリースで証跡が書き込まれた場合、文字型の列のキャラクタ・セットをReplicatのSOURCECHARSETパラメータに入力する必要があります。詳細は、『Oracle GoldenGateリファレンス』を参照してください。
Oracle GoldenGateでは、大/小文字が区別されないオブジェクト名の比較時に、データベースのロケールが考慮されます。サポートされるロケールのリストは、サポートされるロケールを参照してください。
Oracle GoldenGateでは、パラメータ・ファイルで文字の列、リテラル・テキストまたはオブジェクト名を表すためのエスケープ・シーケンスの使用がサポートされています。エスケープ・シーケンスは、オペレーティング・システムで必要な文字(制御文字など)がサポートされていない場合に、またはパラメータ・ファイルで使用できない文字が必要になるその他の目的のために使用できます。
エスケープ・シーケンスは、パラメータ・ファイルの任意の場所で使用できますが、TABLE文またはMAP文の次の要素で特に便利です。
オブジェクト名
WHERE句
Unicode列にUnicode文字を割り当てるか、列にネイティブ・エンコーディングされた文字を割り当てるCOLMAP句
COLMAP句内のOracle GoldenGateの列変換関数
Oracle GoldenGateでは、次のタイプのエスケープ・シーケンスがサポートされます。
\uFFFF: Unicodeエスケープ・シーケンス。サロゲート・ペアを除き、任意のUNICODEコード・ポイントを使用できます。
\377: 8進エスケープ・シーケンス
\xFF: 16進エスケープ・シーケンス
次のルールが適用されます。
TABLEまたはMAPでオブジェクト名のマッピングに使用する場合、制限は何もありません。たとえば、次のTABLE指定は有効です。
TABLE schema."\u3000ABC";
列マッピング関数とともに使用する場合、任意のコード・ポイントを使用できますが、対象となるのはNCHAR/NVARCHAR列のみです。CHAR/VARCHAR列の場合、コード・ポイントは7ビットASCIIと同等のものに限定されます。
ソースとターゲットのデータ型は、同一である必要があります(NCHARとNCHARなど)。
各エスケープ・シーケンスは、逆斜線(コード・ポイントU+005C)で始め、次に文字コード・ポイントを続けます。(逆斜線は、一般的にはバックスラッシュ記号と呼ばれます。)パラメータ文または列変換関数の入力文字列内で、実際の文字のかわりにエスケープ・シーケンスを使用します。
注意:
パラメータ・ファイルで実際のバックスラッシュを指定するには、二重のバックスラッシュを指定します。たとえば、COL1: @STRFIND (COL1, '\\' )と指定すると、バックスラッシュが検索されます。
\uFFFF Unicodeエスケープ・シーケンスを使用する手順
\uFFFF Unicodeエスケープ・シーケンスは小文字のuで始め、次に正確に4桁の16進数を続ける必要があります。
サポートされる範囲は次のとおりです。
0から9 (U+0030からU+0039)
AからF (U+0041からU+0046)
aからf (U+0061からU+0066)
\u20acは、ユーロ通貨記号のUnicodeエスケープ・シーケンスです。
注意:
信頼できるクロス・プラットフォーム・サポートのために、Unicodeエスケープ・シーケンスを使用してください。8進および16進のエスケープ・シーケンスは、異なるオペレーティング・システムでは標準化されていません。
\377 8進エスケープ・シーケンスを使用する手順
正確に3桁の8進数が含まれる必要があります。
サポートされる範囲:
1桁目の範囲は0から3 (U+0030からU+0033)
2桁目と3桁目の範囲は0から7 (U+0030からU+0037)
\200は、Microsoft Windowsでのユーロ通貨記号の8進エスケープ・シーケンスです。
\xFF 16進エスケープ・シーケンスを使用する手順
小文字のxで始め、次に正確に2桁の16進数を続ける必要があります。
サポートされる範囲:
0から9 (U+0030からU+0039)
AからF (U+0041からU+0046)
aからf (U+0061からU+0066)
\x80は、Microsoft Windows 1252 Latin1コード・ページのユーロ通貨記号を表す16進エスケープ・シーケンスです。
Oracle GoldenGateでは、表レベルおよびグローバル・レベルの列マッピングが提供されます。明示的な列マッピング・ルールがない場合は、デフォルトの列マッピングも提供されます。
この項には、次のような列マッピング・ガイドラインがあります。
Oracle GoldenGateでの列名とリテラルの指定は、デフォルトで、SQL-92ルールに従います。大/小文字を区別するために二重引用符が必要になるデータベースの場合は、Oracle GoldenGateパラメータ・ファイル、変換関数、ユーザー・イグジットおよびコマンドにおいて、大/小文字を区別する列名を二重引用符で囲む必要があります。大/小文字を区別するために引用符が必要ないその他のデータベースの場合は、大/小文字が区別される列名を、データベースに格納されているとおりに指定する必要があります。リテラルは一重引用符で囲む必要があります。詳細は、大/小文字が区別される列名とリテラルの区別を参照してください。
MAPおよびTABLEパラメータのCOLMAPオプションを使用して、次の処理を実行します。
異なる名前を持つターゲット列に個別のソース列をマップします。
明示的な列マッピングが不要な場合、デフォルトの列マッピングを指定します。
ソース列からターゲット列に対してデータを選択、マップ、変換および移動するための指示を提供します。
COLMAPの構文は次のとおりです。
COLMAP ([USEDEFAULTS, ]target_column=source_expression)
この構文でtarget_columnはターゲット列の名前、source_expressionは次のいずれかであって、これにより、ソース列を名前でマップすることで、ソース値を証跡に記録されたとおりに正確に渡したり、ターゲット列に渡す前にデータを変換したりすることが可能になります。
ソース列の名前(ORD_DATEなど)。
数値定数(123など)。
一重引用符で囲まれた文字列定数('ABCD'など)。
Oracle GoldenGate列変換関数を使用する式。COLMAP文内で、Oracle GoldenGate列変換関数のいずれかを使用して、マップされた列のデータを変換できます。次に例を示します。
@STREXT (COL1, 1, 3)
列マッピングに、異なるデータベース・タイプに由来する、大/小文字が区別される複数の列が関係する場合、各列を、データベースに格納されているとおりに指定してください。
大/小文字を区別するために二重引用符が必要になるデータベースの場合は、大/小文字が区別される列名を二重引用符で囲んで指定してください。
大/小文字は区別されるが二重引用符が必要ないデータベースの場合は、列名を、データベースに格納されているとおりに指定してください。
次は、Oracleデータベースのターゲット列と、大/小文字が区別されるSQLサーバー・データベースのソース列との間でのマッピングを示しています。
COLMAP ("ColA" = ColA)
Oracle GoldenGateへの名前の指定の詳細は、「Oracle GoldenGateの入力におけるオブジェクト名の指定」を参照してください。
キャラクタ・セットとロケールが異なるデータベース間でソース列とターゲット列をマップする場合のグローバリゼーションに関する考慮事項については、「データ・マッピング時のグローバリゼーションに関する考慮事項」を参照してください。
COLMAPを使用してキー列に値をマップ(主キーの更新操作が発生)しないでください。Oracle GoldenGateがターゲット行の特定に使用するWHERE句では、キー列の正しい変更前イメージが使用されません。かわりに、変更後イメージが使用されます。このため、SQLEXEC文などのキー列に基づく関数を使用している場合、エラーになります。次の例に示します。
ソース表TCUSTMER1
ターゲット表TCUSTMER2
2つの表の列レイアウト
Cust Name City State主キーは、Cust、Name、およびCity列で構成されています。
MAP文のSQLEXEC問合せ:
SQLEXEC (id mytest, query 'select city from TCUSTMER1 WHERE state = 'CA'', noparams, ERROR RAISE)
MAP文内のCOLMAP文:
COLMAP ( usedefaults, city = mytest.city )
エラーの原因になるイベントの順序を次に示します。
COLMAPのUSEDEFAULTSオプションを使用すると、ソース列と対応するターゲット列の名前が同一の場合に、自動デフォルト列マッピングを指定できます。USEDEFAULTSを使用すると、すべてのターゲット列を明示的にマップする必要がないので、時間を節約できます。
デフォルト・マッピングの場合、Oracle GoldenGateはそれらの列と、必要な場合は、データ型を、データ定義ファイルに基づいて変換します(「COLMAPでのデータ定義ファイル必要性の判定」を参照)。明示的なマッピング文でマップされている列にはデフォルト・マッピングを指定しないでください。
次の列マッピングの例では、 ソース表ACCTBLとターゲット表ACCTTABのデフォルト列マッピングと明示的な列マッピングの使用について示します。両方の表の大半の列は同じで、次の点が異なります。
ソース表にはCUST_NAME列がありますが、ターゲット表にはNAME列があります。
ソース表の10桁のPHONE_NO列は、ターゲット表の個別のAREA_CODE列、PHONE_PREFIX列およびPHONE_NUMBER列に対応します。
ソース表の個別のYY列、MM列およびDD列は、ターゲット表の単一のTRANSACTION_DATE列に対応します。
これらの相違点に対処するため、USEDEFAULTSを使用して同じ列を自動的にマップし、異なる列には明示マッピングおよび変換関数を使用します。
表11-1 サンプルの列マッピング
| パラメータ文 | 説明 |
|---|---|
MAP SALES.ACCTBL, TARGET SALES.ACCTTAB, |
ソース表 |
COLMAP( |
|
USEDEFAULTS, |
ターゲット列の名前が同一の場合、ソース列をそのままマップします。 |
NAME = CUST_NAME, |
ソース列 |
TRANSACTION_DATE =
@DATE ('YYYY-MM-DD', 'YY',
YEAR, 'MM', MONTH, 'DD', DAY),
|
|
AREA_CODE = @STREXT (PHONE_NO, 1, 3), PHONE_PREFIX = @STREXT (PHONE_NO, 4, 6), PHONE_NUMBER = @STREXT (PHONE_NO, 7, 10)) ; |
|
デフォルトの列マッピングでOracle GoldenGateが従うルールの詳細は、「デフォルトの列マッピングの理解」を参照してください。
COLMAPを使用する場合、状況によってはデータ定義ファイルを作成する必要があります。この必要性を判断するには、ソースおよびターゲットの列構造がOracle GoldenGateの定義に従って同一であるかどうかを検討する必要があります。
ソースとターゲットの構造が同一であるためには、次の要件を満たす必要があります。
データベース・タイプが同じであること(すべてOracleであるなど)。
キャラクタ・セットおよびロケールが同じであること。
同じ数の列が含まれていること。
列名が同一であること(該当する場合は大/小文字、空白、引用符も含む)。
データ型が同一であること。
列の長さが同一であること。
文字の列の列長さセマンティクス(バイトか文字か)が同じであること。
すべての列が同じ順序で定義されていること。
構造的に同一ではないソース表およびターゲット表でCOLMAPを使用する場合、次の要件を満たす必要があります。
Oracle GoldenGate構成および使用中のデータベースに応じて、ソース表またはターゲット表、あるいはその両方のデータ定義を生成します。
使用する予定のシステムに定義ファイルを転送します。
SOURCEDEFSパラメータを使用してターゲット・システム上のReplicatの定義ファイルを指定するか、TARGETDEFSパラメータを使用してソース・システムまたは中間システム上のExtractまたはデータ・ポンプの定義ファイルを指定します。
構造的に同一のソース表およびターゲット表でCOLMAPを使用し、変換などの他の関数でのみCOLMAPを使用する場合、ソース定義ファイルは必要ありません。定義ファイルを使用しない場合、かわりにASSUMETARGETDEFSパラメータを使用する必要があります(ただし、自己記述型の証跡ファイルを使用している場合は除きます)。詳細は、『Oracle GoldenGateリファレンス』を参照してください。
定義ファイルの詳細は、メタデータへのレプリケートされたデータの関連付けを参照してください。
COLMATCHパラメータでは、列マッピングのグローバル・ルールを作成します。COLMATCHでは、同じデータセットに対して異なる列名を持つ類似した構造の表どうしをマップできます。このタイプの列をマップする場合、個別のTABLE文またはMAP文のCOLMAP句で表レベルのマッピングを使用するより、COLMATCHの方が簡単です。
大/小文字の区別は次のようにサポートされます。
MySQL、SQL ServerおよびTeradataの場合、データベースの大/小文字が区別されるときは、COLMATCHでは、名前が引用符で囲まれて指定されているかどうかにかかわらず、大/小文字と名前が完全に一致するものが検索されます。
同じデータベース内で名前の大/小文字を区別することも区別しないことも可能なOracle DatabaseおよびDB2データベースで、大/小文字を区別するために二重引用符が必要になる場合、COLMATCHでは、名前が引用符で囲まれているとき、大/小文字と名前がデータベースと完全に一致することが求められます。
大/小文字の区別のサポートの詳細は、「Oracle GoldenGateの入力におけるオブジェクト名の指定」を参照してください。
構文
COLMATCH
{NAMES target_column = source_column |
PREFIX prefix |
SUFFIX suffix |
RESET}
表11-2 COLMATCHのオプション
| 引数 | 説明 |
|---|---|
NAMES |
列名に基づいてマップします。 列名で大/小文字が区別され、データベースで大/小文字が区別されるために引用符が必要な場合、列名を二重引用符で囲みます。これらのデータベース・タイプでは、Oracle GoldenGateは、引用符で囲まれていない列名を大/小文字の区別がされないものとして扱います。 大/小文字の区別はサポートしているが引用符が必要ないデータベースの場合は、列名を、データベースに格納されているとおりに指定してください。
COLMATCH NAMES "aBc" = aBc |
PREFIX |
指定した名前接頭辞または名前接尾辞を無視します。 データベースで大/小文字が区別されるために引用符が必要な場合、接頭辞または接尾辞を二重引用符で囲みます。たとえば、" 大/小文字の区別はサポートしているが引用符が必要ないデータベースの場合は、接頭辞または接尾辞を、データベースに格納されているとおりに指定してください。たとえば、 次の例では、大/小文字が区別されない接頭辞を無視するよう指定しています。ターゲット列名 COLMATCH PREFIX p_ 次の例では、大/小文字が区別される SUFFIX "_k" |
RESET |
前に定義した |
次に、COLMATCHを使用する場合の例を示します。ソース表とターゲット表は、表名と列名が多少異なる以外は同一です。データベースが大/小文字を区別しません。
表11-3 COLMATCHのサンプル表: ソース・データベース
| ACCT表 | ORD表 |
|---|---|
CUST_CODE CUST_NAME CUST_ADDR PHONE S_REP S_REPCODE |
CUST_CODE CUST_NAME ORDER_ID ORDER_AMT S_REP S_REPCODE |
表11-4COLMATCHのサンプル表: ターゲット・データベース
| ACCOUNT表 | ORDER表 |
|---|---|
CUSTOMER_CODE CUSTOMER_NAME CUSTOMER_ADDRESS PHONE REP REPCODE |
CUSTOMER_CODE CUSTOMER_NAME ORDER_ID ORDER_AMT REP REPCODE |
この例でソース列をターゲット列にマップし、同時に他の表で後続のマップを処理するには、次の構文を使用します。
COLMATCH NAMES CUSTOMER_CODE = CUST_CODE COLMATCH NAMES CUSTOMER_NAME = CUST_NAME COLMATCH NAMES CUSTOMER_ADDRESS = CUST_ADDR COLMATCH PREFIX S_ MAP SALES.ACCT, TARGET SALES.ACCOUNT, COLMAP (USEDEFAULTS); MAP SALE.ORD, TARGET SALES.ORDER, COLMAP (USEDEFAULTS); COLMATCH RESET MAP SALES.REG, TARGET SALE.REG; MAP SALES.PRICE, TARGET SALES.PRICE;
この例のルールに基づいて、次の処理が発生します。
データは、ソースのACCT表およびORD表のCUST_CODE列から、ターゲットのACCOUNT表およびORDER表のCUSTOMER_CODE列にマップされます。
S_接頭辞は無視されます。
PHONE列やORDER_AMT列などの同じ名前を持つ列は、明示的なルールを必要とすることなく、USEDEFAULTSによって自動的にマップされます。詳細は、「デフォルトの列マッピングの理解」を参照してください。
前述のグローバル列マッピングは、REG表およびPRICE表では無効化されます。これらの表のソース列とターゲット列は、名前がすべて同一であるため、自動的にマップされます。
COLMATCHまたはCOLMAPを使用した明示的な列マッピングが存在しない場合、Oracle GoldenGateでは、デフォルトで次のルールに従ってソース列とターゲット列がマップされます。
ソース列の名前および大/小文字がターゲット列のものと正確に一致することが検出された場合、2つの列はマップされます。
大/小文字が一致しないことが検出された場合、名前のフォールバック・マッピングが使用されます。フォールバック・マッピングでは、大/小文字を区別せずにターゲット表のマッピングを実行して、一致する名前を探します。大文字の名前を使用して、厳密でない列名マッピングが適用されます。この動作は、GLOBALSのパラメータNAMEMATCHIGNORECASEによって制御します。名前のフォールバック照合は、NAMEMATCHEXACTパラメータを使用して無効にすることも、NAMEMATCHNOWARNINGパラメータを使用して、有効にしたまま警告メッセージを表示することもできます。
どのソース列にも対応していないターゲット列には、データベースによって指定されたデフォルト値が割り当てられます。
デフォルトのマッピングを実行できない場合、ターゲット列は、デフォルトで表11-5に示されているいずれかの値になります。
表11-5 ターゲット列のデフォルト値
| 列型 | 値 |
|---|---|
数値 |
0 (ゼロ) |
文字または |
空白 |
日付または日時 |
現在の日時 |
|
NULL |
次の例では、Oracle GoldenGateによるデータ型のマップ方法について説明します。
数値の列は、ターゲット列の型およびスケールと一致するように変換されます。ターゲット列のスケールがソースのスケールより小さい場合、数値の右側が切り捨てられます。ターゲット列のスケールがソースのスケールより大きい場合、数値の右側に0(ゼロ)が埋め込まれます。
REPLACEBADNUMパラメータを使用することで、数字列をマップするときに検出される無効な数字データの代替値を指定できます。詳細は、『Oracle GoldenGateリファレンス』を参照してください。
文字型の列では、VARCHARなどの文字ベースのデータ型、文字列形式の数値、文字列形式の日時、および文字列リテラルを使用できます。ターゲット列のスケールがソースのスケールより小さい場合、列の右側が切り捨てられます。ターゲット列のスケールがソースのスケールより大きい場合、列の右側に空白が埋め込まれます。
リテラルは一重引用符で囲む必要があります。
REPLACEBADCHARパラメータを使用すると、文字の列をマッピングするときにソースまたはターゲットのキャラクタ・セットに対して有効なコードポイントが存在しない場合、Oracle GoldenGateプロセスのレスポンスを制御できます。詳細は、『Oracle GoldenGateリファレンス』を参照してください。
日時(DATE、TIMEおよびTIMESTAMP)の列では、日時および文字の列に加え、文字列リテラルを使用できます。リテラルは一重引用符で囲む必要があります。文字の列を日時の列にマップする場合、その列がOracle GoldenGateの外部SQL書式であるYYYY-MM-DD HH:MI:SS.FFFFFFに準拠していることを確認します。
Oracle GoldenGateでは、0001-01-03 00:00:00から9999-12-31 23:59:59までのタイムスタンプ・データがサポートされます。タイムスタンプがGMTからローカル時間に変換されると、これらの制限も変換後のタイムスタンプに適用されます。タイムゾーンに応じて、変換により時間が追加または引かれる場合があり、これにより、タイムスタンプがサポートされている上限を超えたり、下回ったりすることがあります。
必要な精度は、データ型およびターゲット・プラットフォームに応じて異なります。ターゲット列のスケールがソースのスケールより小さい場合、データの右側が切り捨てられます。ターゲット列のスケールがソースのスケールより大きい場合、列の右側が現在の日時の値で拡張されます。
抽出またはレプリケートする行をフィルタで除外または選択するには、TABLEおよびMAPパラメータのFILTER句およびWHERE句を使用します。
WHERE句では基本的なWHERE演算子を使用できますが、FILTER句では、Oracle GoldenGate列変換関数をすべて使用できるため、WHERE句より多くの機能が提供されます。
FILTER句を使用して、基本演算子または1つ以上のOracle GoldenGate列変換関数により、数値に基づいて行を選択します。
注意:
文字列に基づいて列をフィルタするには、Oracle GoldenGate文字列関数のいずれかを使用するか、WHERE句を使用します。
TABLE文でのFILTERの構文は次のとおりです。
TABLE source_table,
, FILTER (
[, ON INSERT | ON UPDATE| ON DELETE]
[, IGNORE INSERT | IGNORE UPDATE | IGNORE DELETE]
, filter_clause);
MAP文でのFILTERの構文は次のとおりで、エラー処理オプションがあります。
MAPsource_table, TARGETtarget_table, , FILTER ( [, ON INSERT | ON UPDATE| ON DELETE] [, IGNORE INSERT | IGNORE UPDATE | IGNORE DELETE] [, RAISEERRORerror_number] ,filter_clause);
FILTER句の有効な要素は、次のとおりです。
Oracle GoldenGate列変換関数。これらの関数は、Oracle GoldenGateに組み込まれており、テストの実行、データの操作、値の取得などを行うことができます。Oracle GoldenGate変換関数の詳細は、「データのテストおよび変換」を参照してください。
数字
数字を含む列
数字を返すファンクション
算術演算子:
+ (加算)
- (減算)
* (乗算)
/ (除算)
\ (余り)
比較演算子:
> (より大きい)
>= (以上)
< (より少ない)
<= (以下)
= (等しい)
<> (等しくない)
比較から導出した結果はゼロ(FALSEを示す)またはゼロ以外(TRUEを示す)になります。
カッコ(式の結果をグループ化)
結合演算子: AND、OR
次のFILTERオプションを使用して、フィルタ句の影響を受けるSQL操作を指定します。これらのオプションは、任意に結合できます。
ON INSERT | ON UPDATE | ON DELETE IGNORE INSERT | IGNORE UPDATE | IGNORE DELETE
MAPパラメータのFILTERのRAISEERRORオプションを使用して、フィルタに失敗したときのユーザー定義のエラーを生成します。このオプションは、失敗に応じてイベントを起動する必要がある場合に役立ちます。
@RANGE関数を使用して、個別のTABLE文またはMAP文の複数のFILTER句間で処理ワークロードを分割できます。たとえば、次の例では、acctソース表のID列に基づいて、2つの範囲(2つのReplicatプロセス間または調整Replicatの2つのスレッド)にレプリケーション・ワークロードを分割します。
表11-6 複数のFILTER文の使用
| パラメータ・ファイル | 説明 |
|---|---|
REPERROR (9999, EXCEPTION) |
指定したエラーに対して例外を起動します。 |
MAP OWNER.SRCTAB, TARGET OWNER.TARGTAB, |
|
SQLEXEC (ID CHECK, ON UPDATE, QUERY ' SELECT COUNT FROM TARGTAB ' 'WHERE PKCOL = :P1 ', PARAMS (P1 = PKCOL)), |
問合せを実行し、更新が発生するたびに |
FILTER (BALANCE > 15000), |
|
FILTER (ON UPDATE, @BEFORE (COUNT) = CHECK.COUNT) |
別の |
; |
セミコロンで |
MAP OWNER.SRCTAB, TARGET OWNER.TARGEXC, EXCEPTIONSONLY, COLMAP (USEDEFAULTS, ERRTYPE = 'UPDATE FILTER FAILED'); |
例外 |
例11-1 @COMPUTE関数のコール
次の例では、@COMPUTE関数をコールして、価格と数量の積が10,000を超えるレコードを抽出します。
MAP SALES.TCUSTORD, TARGET SALES.TORD, FILTER (@COMPUTE (PRODUCT_PRICE * PRODUCT_AMOUNT) > 10000);
例11-2 @STREQ関数のコール
次の例では、@STREQ関数を使用して、文字列の値が'JOE'であるレコードを抽出します。
TABLE ACCT.TCUSTORD, FILTER (@STREQ ("Name", 'joe') > 0);
例11-3 レコードの選択
次の例では、AMOUNT列が50を超えているレコードを選択し、UPDATEおよびDELETE操作時にフィルタを実行します。
TABLE ACT.TCUSTORD, FILTER (ON UPDATE, ON DELETE, AMOUNT > 50);
例11-4 @RANGE関数の使用
(Replicatグループ1のパラメータ・ファイル)
MAP sales.acct, TARGET sales.acct, FILTER (@RANGE (1, 2, ID));
(Replicatグループ2のパラメータ・ファイル)
MAP sales.acct, TARGET sales.acct, FILTER (@RANGE (2, 2, ID));
Replicatのパラメータ・ファイルの一部を示した表11-6に示すように、1つのMAP文またはTABLE文内に複数のFILTER句を結合できます。Oracle GoldenGateでは、フィルタはいずれか1つが失敗するか、すべてが成功するまでリスト順に実行されます。1つのフィルタが失敗すると、フィルタ全体が失敗します。
WHERE句で表11-7の任意の要素を使用し、条件文に基づいて行の選択または除外(あるいはその両方)を行います。各WHERE句は、カッコで囲む必要があります。リテラルは一重引用符で囲む必要があります。
表11-7 許可されているWHERE演算子
| 要素 | 例 |
|---|---|
列名 |
|
数値 |
-123, 5500.123 |
リテラル文字列 |
'AUTO', 'Ca' |
組込みの列テスト |
|
比較演算子 |
=, <>, >, <, >=, < |
結合演算子 |
|
グループ化用カッコ |
複数の要素の論理グループ化用に開きカッコと閉じカッコ( )を使用します。 |
Oracle GoldenGateでは、マルチバイト・キャラクタ・セットまたはローカル・オペレーティング・システムのキャラクタ・セットと互換性のないキャラクタ・セットを含む列に対して、FILTERをサポートしていません。
算術演算子および浮動小数点データ型は、WHEREではサポートされません。より複雑な選択条件を使用するには、FILTER句を使用するか、ユーザー・イグジット・ルーチンを使用します。詳細は、「ユーザー・イグジットを使用したOracle GoldenGate機能の拡張」を参照してください。
WHEREの構文は、TABLE文でもMAP文でも同じです。
TABLEtable, WHERE (clause);
MAPsource_table, TARGETtarget_table, WHERE (clause);
適切な選択句を作成するために、次の推奨事項が役立ちます。
注意:
この項の例は、大/小文字が区別されないデータベースを想定しています。
データベースで、変更された列の値のみをトランザクション・ログに記録している場合、変更されていない列のいずれかが選択基準によって参照されると、エラーが発生する可能性があります。Oracle GoldenGateは、このような行操作を無視し、それらを破棄ファイルに出力して警告を発行します。
欠落列エラーを回避するには、次のように選択条件を作成します。
可能であれば、選択基準として主キー列のみを使用します。
それらの列に対するサプリメンタル・ロギングを有効にして、必要な列値を使用できるようにします。あるいは、TABLEパラメータのFETCHCOLSまたはFETCHCOLSEXCEPTオプションを使用することもできます。これらのオプションは、すべてのサポートされているデータベースに対して有効です。値がログに存在しない場合に、データベースに問い合せて値をフェッチします。FILTER句またはWHERE句が実行される前に値を取得するため、TABLE文のFETCHBEFOREFILTERオプションをFILTER句またはWHERE句の前に指定します。次に例を示します。
TABLE DEMO.PEOPLE, FETCHBEFOREFILTER, FETCHCOLS (age), FILTER (age > 50);
最初に列が存在するかどうかをテストし、次に列の値をテストします。列が存在するかどうかをテストするには、次の構文を使用します。
column_name {= | <>} {@PRESENT | @ABSENT}
次の例では、amount列が10,000を超えている場合にすべてのレコードが戻されます。amountが存在しない場合、レコードは破棄されません。
WHERE (amount = @PRESENT AND amount > 10000)
比較で使用される要素が確実に一致するように、該当する列タイプを比較します。
文字の列とリテラル文字列。
数値の列と数値(符号と小数点を含む)。
日時の列とリテラル文字列(アプリケーションによって取得される列の書式を使用)。
更新操作では、ソース列の変更前の値(更新発生前の値)を取得すると役立つことがあります。これらの値は証跡に格納されており、フィルタおよび列マッピングで使用できます。たとえば、次のことが可能です。
例外MAP文における列マッピング指定の一部として、行の変更前イメージを取得し、競合解決ルーチンのテストまたはトラブルシューティング用に、それらの値を例外表にマップします。
デルタ計算を実行します。たとえば、表にBalance列が含まれる場合、新しい残高から元の残高を差し引いて特定のトランザクションの正味の結果を計算できます。次に例を示します。
MAP "owner"."src", TARGET "owner"."targ", COLMAP (PK1 = PK1, delta = balance – @BEFORE (balance));
注意:
前の例は、Oracleなどの大/小文字が区別されるデータベースを示しています。表名は、大/小文字の区別を表すために引用符で囲まれています。
変更前の値を参照する手順
次のように、@BEFORE列変換関数と、変更前の値を必要とする列の名前を使用します。
@BEFORE (column_name)
GETUPDATEBEFORESパラメータをExtractのパラメータ・ファイルで使用して、トランザクション・レコードから変更前イメージを取得するか、Replicatのパラメータ・ファイルで使用して、列マッピングまたはフィルタで変更前イメージを使用します。競合の検出および解決(CDR)機能を使用する場合は、TABLEのGETBEFORECOLSオプションを使用できます。これらのパラメータを使用するには、すべての列がトランザクション・ログに存在している必要があります。データベースで、変更された列の値のみを記録している場合、@BEFORE関数を使用すると、列の欠落状態が発生し、列がレコードに存在しない場合と同じように列マップが実行されます。列値の使用可能性を確保するには、「フィルタでのデータ使用可能性の確保」を参照してください。
Oracle GoldenGateには、フィルタリング、変換関数または他の目的で必要な場合に変換後の値を取得する@AFTER関数も用意されています。@BEFOREおよび@AFTERの詳細は、『Oracle GoldenGateリファレンス』を参照してください。
Oracle GoldenGateによって抽出するソース表の列を制御するには、TABLEパラメータのCOLSオプションおよびCOLSEXCEPTオプションを使用します。COLSでは抽出する列を選択し、COLSEXCEPTでは、COLSEXCEPTで指定した列以外のすべての列を選択します。
抽出する列を制限すると、ターゲット表にソース表と同じ列が含まれない場合や、列に機密情報(個人識別番号その他の固有のビジネス情報など)が含まれる場合に役立ちます。
デフォルトでは、Oracle GoldenGateによってINSERT、UPDATEおよびDELETE操作が取得および適用されます。ExtractまたはReplicatのパラメータ・ファイルで次のパラメータを使用して、処理する操作の種類(挿入のみ、または挿入と更新のみなど)を制御できます。
GETINSERTS | IGNOREINSERTS
GETUPDATES | IGNOREUPDATES
GETDELETES | IGNOREDELETES
Replicatパラメータ・ファイルで次のパラメータを使用すると、あるタイプのSQL操作を別のタイプに変換できます。
INSERTUPDATESを使用して、ソースの更新操作をターゲット表への挿入操作に変換します。これは、ターゲット表にトランザクション履歴を保持する場合に便利です。トランザクション・ログ・レコードには、変更された値だけでなく、表の列値もすべて含まれている必要があります。一部のデータベースでは、トランザクション・ログに行の値がすべて記録されず、変更された値のみが記録されます。
INSERTDELETESを使用して、ソースのすべての削除操作をターゲット表への挿入操作に変換します。これは、ソース・データベースに存在していたすべてのレコードの履歴を保持する場合に便利です。
UPDATEDELETESを使用して、ソースの削除操作をターゲットの更新操作に変換します。
Oracle GoldenGateでは、ターゲット・レコードに対する変更の履歴を保持して、各変更の原因となった操作に関する情報をマップできます。この履歴は、各レコードの最新バージョンのみを含むのではなく、表に対して実行されたすべての操作の個別レコードを含むトランザクションベースのレポート・システムを作成する場合に役立ちます。
たとえば、CUSTOMERという名前のターゲット表に対して行われた次の一連の操作では、ID Daveの履歴は残りません。最後の操作でレコードを削除するため、Daveの口座の履歴や最後の残高を知ることはできません。
表11-8 CUSTOMER表の操作履歴
| 順序 | 操作 | ID | 残高 |
|---|---|---|---|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
一連のレコードとしてこの履歴を保持すると、多くの場面で役立ちます。たとえば、トランザクションの正味の効果を生成できます。
トランザクション・レポートを実装する手順
GETUPDATEBEFORESパラメータを使用します。変更前の値(または変更前イメージ)は、更新が実行される前に列に存在する値です。変更前イメージによって、Oracle GoldenGateでトランザクション・レコードを作成できます。INSERTALLRECORDSパラメータを使用します。表に対する各操作は、その表内の新規レコードになります。@GETENV列変換関数のGGHEADERオプションの戻り値を使用します。TABLEパラメータまたはMAPパラメータのCOLMAP文に、ソース式として変換関数を含めます。表11-8に示されている一連のサンプル・トランザクションを使用して、データベースの最新状態ではなく、よりトランザクション指向の強い顧客ビューを生成するために、次のパラメータ構成を作成できます。
| プロセス | パラメータ文 |
|---|---|
Extract |
GETUPDATEBEFORES TABLE ACCOUNT.CUSTOMER; |
Replicat |
INSERTALLRECORDS
MAP SALES.CUSTOMER, TARGET SALES.CUSTHIST,
COLMAP (TS = @GETENV ('GGHEADER', 'COMMITTIMESTAMP'),
BEFORE_AFTER = @GETENV ('GGHEADER', 'BEFOREAFTERINDICATOR'),
OP_TYPE = @GETENV ('GGHEADER', 'OPTYPE'),
ID = ID,
BALANCE = BALANCE);
|
注意:
この例は、Oracle GoldenGateプロセスの完全なパラメータ・ファイルを表していません。これらの例が、大/小文字が区別されないデータベースを表していることにも注意してください。
この構成によって、各トランザクションの正味合計と、トランザクションの時刻および顧客IDを戻す次のような問合せが可能になります。
SELECT AFTER.ID, AFTER.TS, AFTER.BALANCE - BEFORE.BALANCE FROM CUSTHIST AFTER, CUSTHIST BEFORE WHERE AFTER.ID = BEFORE.ID AND AFTER.TS = BEFORE.TS AND AFTER.BEFORE_AFTER = 'A' AND BEFORE.BEFORE_AFTER = 'B';
データのテストおよび変換は、ExtractまたはReplicatによって実行できます。これらの機能は、Oracle GoldenGateの組込みの列変換関数をTABLE文またはMAP文のCOLMAP句内で使用することで実装します。これらの変換関数では、次の処理を実行できます。
日付の変換。
列値の存在確認のテスト。
算術演算の実行。
数値および文字列の操作。
NULL値、無効なデータおよび欠落データの処理。
テストの実行。
この章では、データ操作に関連するいくつかのOracle GoldenGate関数の概要について説明します。詳細なリファレンスは、Oracle GoldenGateリファレンスfor Windows and UNIXを参照してください。
Oracle GoldenGate関数で提供される機能の範囲外のロジックを使用する必要がある場合は、Oracle GoldenGateユーザー・イグジットを実装して独自の関数をコールできます。ユーザー・イグジットの詳細は、「ユーザー・イグジットを使用したOracle GoldenGate機能の拡張」を参照してください。
Oracle GoldenGate変換関数の一般的な構文は次のとおりです。
構文
@function(argument)
表11-9 変換関数の構文
| 構文の要素 | 説明 |
|---|---|
@ |
Oracle GoldenGate関数の名前。関数名には、接頭辞 |
|
関数の引数。 |
表11-10 関数の引数
| 引数の要素 | 例 |
|---|---|
数値定数 |
|
一重引用符で囲まれた文字列リテラル |
'ABCD' |
ソース列の名前 |
データベースが大/小文字の区別をしないか、大/小文字の区別をするか、大/小文字の区別をする場合に引用符が必要か、大/小文字の区別をする場合に引用符を必要としないかにより異なります。 |
算術式 |
|
比較式 |
|
他のOracle GoldenGate関数 |
|
デフォルトでは、列変換関数内のリテラル文字列は一重引用符で囲む必要があります。データベースによっては大/小文字を区別する列名を二重引用符で囲む必要があります。それ以外の場合は、データベースに格納されているとおりの大/小文字で入力します。
操作対象または評価対象の列のタイプに適した関数を使用してください。たとえば、数値関数は数値を比較する場合にのみ使用できます。文字列値を比較するには、Oracle GoldenGate文字比較関数のいずれかを使用します。LOB列は、変換関数では使用できません。
次の文は、数値関数の@IFを使用して文字列値を比較しているため、失敗します。
@IF (SR_AREA = 'Help Desk', 'TRUE', 'FALSE')
次の文は、数値を比較しているため、成功します。
@IF (SR_AREA = 20, 'TRUE', 'FALSE')
詳細は、「数値および文字列の操作」を参照してください。
注意:
引数解析のエラーは、レコードが処理されるまで検出されないことがあります。プロセスを起動する前に構文を確認してください。
@DATE、@DATEDIFおよび@DATENOWの各関数を使用して、日時の取得、日時の計算および日時の変換を行います。
次の例では、注文が処理された時間を計算します。
例11-5 時間の計算
ORDER_FILLED = @DATE (
'YYYY-MM-DD HH:MI:SS',
'JTS',
@DATE ('JTS',
'YYMMDDHHMISS',
ORDER_TAKEN_TIME) +
ORDER_MINUTES * 60 * 1000000)
算術式の結果を戻すには、@COMPUTE関数を使用します。関数から返される値は、文字列形式です。算術式では、次の要素を組み合せることができます。
数字
数字を含む列名
数字を返すファンクション
算術演算子:
+ (加算)
- (減算)
* (乗算)
/ (除算)
\ (余り)
比較演算子:
> (より大きい)
>= (以上)
< (より少ない)
<= (以下)
= (等しい)
<> (等しくない)
比較から導出した結果はゼロ(FALSEを示す)またはゼロ以外(TRUEを示す)になります。
カッコ(式の結果をグループ化)
結合演算子AND、OR。Oracle GoldenGateは、結合式の必要部分のみを評価します。文がFALSEになると、式の残りの部分は無視されます。この動作は、紛失またはNULLの可能性があるフィールドを評価するときに役立ちます。たとえば、COL1の値が25で、COL2の値が10の場合は、次のようになります。
@COMPUTE ( (COL1 > 0) AND (COL2 < 3) )returns0.@COMPUTE ( (COL1 < 0) AND (COL2 < 3) )returns 0. COL2 < 3 is never evaluated.@COMPUTE ((COL1 + COL2)/5)returns 7.
数値および文字列を変換するため、Oracle GoldenGateでは次の関数が提供されています。
表11-11 数値および文字のための変換関数
| 目的 | 変換関数 |
|---|---|
バイナリ文字列または文字列の数値への変換 |
|
数値の文字列への変換 |
|
文字列の比較。 |
|
文字列の連結。 |
|
文字列からの抽出 |
|
文字列の長さの返却 |
|
ある文字列と別の文字列の置換 |
|
文字列の大文字への変換 |
|
先頭または末尾(あるいはその両方)の空白の切捨て |
|
列データが欠落しているか、無効であるか、またはNULLである場合、Oracle GoldenGate変換関数では、それぞれに対応する値が戻されます。
BALANCEは1000でも、AMOUNTがNULLの場合、次の式ではNULLが戻されます。
NEW_BALANCE = @COMPUTE (BALANCE + AMOUNT)
これらの例外条件によって、計算全体が無効になります。変換を確実に成功させるには、@COLSTAT、@COLTESTおよび@IFの各関数を使用して、例外条件をテスト(および上書き)してください。
@COLSTAT関数を使用して、列が欠落しているか、NULLであるか、または無効であることを示すインジケータをExtractまたはReplicatに戻します。このインジケータは、別の変換関数を使用する大規模な操作式の一部として使用できます。
次の例では、ターゲット列のITEMにNULLを戻します。
ITEM = @COLSTAT (NULL)
次の@IFの計算では、PRICEおよびQUANTITYが0(ゼロ)未満の場合に、@COLSTATを使用してターゲット列にNULLを戻します。
ORDER_TOTAL = PRICE * QUANTITY, @IF ((PRICE < 0) AND (QUANTITY < 0), @COLSTAT (NULL))
@COLTEST関数を使用して、次の条件をチェックします。
PRESENTは、列が存在してNULLではないかどうかをテストします。
NULLは、列が存在してNULLであるかどうかをテストします。
MISSINGは、列が存在していないかどうかをテストします。
INVALIDは、列が存在して無効なデータを含んでいるかどうかをテストします。
次の例は、AMOUNT列が存在してNULLであるか、およびそれが存在するが無効であるかをチェックします。
@COLTEST (AMOUNT, NULL, INVALID)
@IF関数では、条件に基づいて2つの値のうち1つを返します。この関数を@COLSTAT関数および@COLTEST関数とともに使用して、1つ以上の例外条件をテストする条件付き引数を開始し、そのテストの結果に基づいて処理を実行します。
NEW_BALANCE = @IF (@COLTEST (BALANCE, NULL, INVALID) OR @COLTEST (AMOUNT, NULL, INVALID), @COLSTAT (NULL), BALANCE + AMOUNT)
この変換では次のいずれかの値が戻されます。
NULL (BALANCEまたはAMOUNTがNULLまたはINVALIDの場合)
MISSING (いずれかの列が欠落している場合)
列の合計
@CASE、@VALONEOFおよび@EVALの各関数によって、データを操作またはマップする前にテストを実行するための追加の方法が提供されます。
@CASEを使用して、一連の値テストに応じて値を選択します。
@CASE (PRODUCT_CODE, 'CAR', 'A car', 'TRUCK', 'A truck')
この例では、次の要素が戻されます。
A car (PRODUCT_CODEがCARの場合)
A truck (PRODUCT_CODEがTRUCKの場合)
FIELD_MISSINGインジケータ(PRODUCT_CODEが他のどちらの条件も満たさない場合)
@VALONEOFを使用して、列または文字列と値リストを比較します。
@IF (@VALONEOF (STATE, 'CA', 'NY'), 'COAST', 'MIDDLE')
この例では、STATEがCAまたはNYの場合、値が非ゼロ(つまりTRUE)のときに@IFによって返されるレスポンスである"COAST"が返されます。
データを取得して、証跡レコード・ヘッダーのユーザー・トークン領域内に格納できます。トークン・データを取得して、Oracle GoldenGateによる情報の配信方法をカスタマイズするために様々な用途で使用できます。たとえば、トークン・データを次の用途で使用できます。
列マップ
SQLEXEC文によってコールされるストアド・プロシージャ
ユーザー・イグジット
マクロ
トークンを使用するには、トークン名を定義してデータに関連付けます。データとして使用できるのは、Oracle GoldenGate列変換関数から取得された任意の有効な文字データまたは値です。
レコード・ヘッダーのトークン領域には、最大16,000バイトのデータを格納できます。トークン名、データ長およびデータ自体がこの領域に収まる必要があります。
トークンを定義するには、Extractパラメータ・ファイルのTABLEパラメータのTOKENSオプションを使用します。
構文
TABLEtable_spec, TOKENS (token_name=token_data[, ...]);
説明:
table_specはソース表の名前です。コンテナまたはカタログの名前(該当する場合)と所有者名を表名の前に付ける必要があります。
token_nameは、選択したトークンに付ける名前です。任意の数の英数字を使用できます。大/小文字は区別されません。
token_dataは、最大2000バイトの文字列です。データには、一重引用符に囲まれた文字列、またはOracle GoldenGateの列変換関数の結果のいずれかを指定できます。トークン・データのキャラクタ・セットは変換されません。トークンは、Extract用ソース・データベースのキャラクタ・セットおよびReplicat用ターゲット・データベースのキャラクタ・セットである必要があります。証跡ファイルには、ユーザー・トークンはUTF-8で格納されます。
TABLE ora.oratest, TOKENS (
TK-OSUSER = @GETENV ('GGENVIRONMENT' , 'OSUSERNAME'),
TK-GROUP = @GETENV ('GGENVIRONMENT' , 'GROUPNAME')
TK-HOST = @GETENV('GGENVIRONMENT' , 'HOSTNAME'));
この例に示されているとおり、Oracle GoldenGateの @GETENV関数は、トークン・データを移入するための効果的な方法です。この関数には、トークンにマップしてターゲット・システムで列マッピングに使用できる環境情報を取得するための複数のオプションがあります。
ターゲット表にトークン・データをマップするには、ReplicatのMAP文に含まれるCOLMAP句のソース式で@TOKEN列変換関数を使用します。@TOKEN関数によって、マップするトークンの名前を提供します。@TOKENを使用したCOLMAP構文は、次のとおりです。
構文
COLMAP (target_column= @TOKEN ('token_name'))
次のMAP文では、hostやgg_groupなどのターゲット列が、tk-hostやtk-groupなどのトークンにマップされます。引数は一重引用符で囲む必要があります。
| ユーザー・トークン | 値 |
|---|---|
tk-host |
:sysA |
tk-group |
:extora |
tk-osuser |
:jad |
tk-domain |
:admin |
tk-ba_ind |
:B |
tk-commit_ts |
:2011-01-24 17:08:59.000000 |
tk-pos |
:3604496 |
tk-rba |
:4058 |
tk-table |
:oratest |
tk-optype |
:insert |
例11-6 MAP文
MAP ora.oratest, TARGET ora.rpt,
COLMAP (USEDEFAULTS,
host = @token ('tk-host'),
gg_group = @token ('tk-group'),
osuser= @token ('tk-osuser'),
domain = @token ('tk-domain'),
ba_ind= @token ('tk-ba_ind'),
commit_ts = @token ('tk-commit_ts'),
pos = @token ('tk-pos'),
rba = @token ('tk-rba'),
tablename = @token ('tk-table'),
optype = @token ('tk-optype'));
この例のトークンは、証跡のレコード・ヘッダー内では次のように示されます。
