8 データのマッピングおよび操作
内容は次のとおりです。
8.1 自己記述型の証跡の使用のガイドライン
SOURCEDEFS OVERRIDE
またはTARGETDEFS OVERRIDE
を使用していない場合、証跡ファイル形式が12.2以上であれば、自己記述型の証跡ファイルがデフォルトになります。Oracleでは自己記述型の証跡ファイルを使用することをお薦めします。SOURCEDEFS OVERRIDE
およびTARGETDEFS OVERRIDE
は、下位互換性の要件にのみ使用する必要があります。
自己記述型の証跡を使用するためのガイドラインを次に示します。
-
自己記述型の証跡を使用している場合、ソースの列名がターゲット表の列名にマップされます。列の順序は重要ではなく、列名が異なる場合は、
COLMAP
を使用して明示的にマップする必要があります。 -
ソースのOracle GoldenGateリリースが12.1以前の場合は、
SOURCEDEFS OVERRIDE
またはTARGETDEFS OVERRIDE
を使用する必要があります。『Oracle GoldenGateリファレンス』のSOURCEDEFS OVERRIDE
およびTARGETDEFS OVERRIDE
を参照してください。
親トピック: データのマッピングおよび操作
8.2 マッピングおよびデータ統合を制御するパラメータ
Oracle GoldenGateで実行されるデータの選択、マッピングおよび操作は、すべてTABLE
パラメータおよびMAP
パラメータのオプションを1つ以上使用して行われます。
-
Extractパラメータ・ファイルで
TABLE
を使用します。 -
Replicatパラメータ・ファイルで
MAP
を使用します。
TABLE
とMAP
は、パラメータ・ファイル内の他のパラメータに影響を受けるデータベース・オブジェクトを指定します。これらのパラメータによるオブジェクト名指定の詳細は、「Oracle GoldenGateの入力におけるオブジェクト名の指定」を参照してください。
親トピック: データのマッピングおよび操作
8.3 異なるデータベース間のマッピング
異なるデータ構造を持つ表どうしのマッピングおよび変換には、ソース定義ファイルまたはターゲット定義ファイル、あるいは(一定の場合)その両方が必要です。異なるデータベース間のマッピングは、ソース列またはターゲット列のデータ型に関係なく、自己記述型の証跡によって制御され、マッピングは列名によって実行されます。
自己記述型の証跡に基づく自動マッピングを行わない場合、または下位互換性が必要な場合は、SOURCEDEFS
またはTARGETDEFS
を使用します。
親トピック: データのマッピングおよび操作
8.4 データのマッピングおよび変換の実行場所の決定
計画中の構成が大量の列マッピングまたはデータ変換を伴う場合は、次のガイドラインに従って、それらの機能をどのプロセスで実行するかを判断してください。
8.4.1 WindowsシステムとUNIXシステムでのマッピングおよび変換
Oracle GoldenGateがWindowsベースおよびUNIXベースのシステムでのみ動作している場合、列のマッピングおよび変換をExtractプロセスまたはReplicatプロセスで実行できます。Extractプロセスでこの処理に追加のオーバーヘッドが発生するのを防止するため、マッピングおよび変換がReplicatプロセスまたは中間システムで実行されるように構成できます。
複数のソースに対して1つのターゲットがある場合、状況によってはソースでマッピングと変換を実行すると効率が向上することがあります。
親トピック: データのマッピングおよび変換の実行場所の決定
8.4.2 NonStopシステムでのマッピングおよび変換
WindowsシステムまたはUNIXシステムからNonStop Enscribeターゲットへのデータのマッピングまたは変換を行う場合、マッピングまたは変換はソースのWindowsシステムまたはUNIXシステムで実行する必要があります。NonStop用のReplicatは、3つまたは2つの部分からなるSQL表名およびデータ型を、Enscribeプラットフォームで使用される3つの部分からなるファイル名に変換できません。Extractは、証跡データをEnscribeの名前およびターゲット・データ型でフォーマットできます。
親トピック: データのマッピングおよび変換の実行場所の決定
8.5 データ・マッピング時のグローバリゼーションに関する考慮事項
データベースとプラットフォームの間のデータのマッピングおよび変換を計画する際には、グローバリゼーションに関してOracle GoldenGateでサポートされている処理とサポートされていない処理を考慮してください。これらの考慮事項には、次のトピックが含まれます。
8.5.1 文字セット間の変換
Oracle GoldenGateでは、ソースとターゲットの文字セットが異なると、オブジェクト名および列データがデータベース間で正しく比較、マップ、操作されるようにするため、文字セットの変換が行われます。サポートされる文字セットのリストは、サポートされる文字セットを参照してください。
異なるデータベースの間で文字が正確に表現されるためには、次の条件を満たす必要があります。
-
ターゲット・データベースの文字セットは、ソース・データベースの文字セットのスーパーセットであるか、ソース・データベースの文字セットと同等である必要があります。同等とは、同一であることではなく、同じ文字のセットが存在することを意味します。たとえば、Shift-JISとEUC-JPは、厳密に言うと完全に同一ではありませんが、ほとんどの場合に同じ文字が存在します。
-
クライアント・アプリケーションで異なる文字セットが使用されている場合、データベースの文字セットがクライアント・アプリケーションの文字セットのスーパーセットであるか、クライアント・アプリケーションの文字セットと同等であることも必要です。
-
Oracleを含む多くのデータベースで、文字セットに含まれない文字をデータベースに強制的に入力できます。Oracle GoldenGateでは、これは無効な値とみなされ、データのレプリケート時にこの文字を正しくマップしない場合があります。このような状況では、『Oracle GoldenGateリファレンス』の説明に従って、
REPLACEBADCHAR
パラメータを使用できます。
この構成では、クライアントまたはソースの文字セットからローカル・データベースの文字セットへの変換時に、すべての文字が表現されます。
Replicatプロセスは、1つのソース文字セットから1つのターゲット文字セットへの変換をサポートできます。
8.5.1.1 データベース・オブジェクト名
Oracle GoldenGateでは、カタログ、スキーマ、表および列の名前は、ソース・データベースおよびターゲット・データベースの文字セット・エンコーディングに従って、ネイティブ言語で処理されます。このサポートにより、データベース階層のあらゆるレベルで、シングルバイトおよびマルチバイトの名前、記号、アクセント文字、大/小文字の区別が維持され、ロケールがあればそれも考慮されます。
親トピック: 文字セット間の変換
8.5.1.2 列データ
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からローカル時間に変換されると、これらの制限も変換後のタイムスタンプに適用されます。ゼロの月、ゼロの日のフィールドまたはすべてゼロの日付の値はサポートされていません。たとえば、0000-00-00 00:00:00などの値や、ゼロの月またはゼロの日のフィールドを含む任意の日付値はサポートされていません。
列データの文字セット変換は、ReplicatのMAP
パラメータのCOLMAP
句またはUSEDEFAULTS
句のソース列とターゲット列との直接マッピングに限定されています。直接マッピングは、ストアド・プロシージャや列変換関数を使用しない、名前から名前へのマッピングです。Replicatは、文字セット変換を実行します。Extractやデータ・ポンプでは変換は実行されません。
親トピック: 文字セット間の変換
8.5.2 ロケールの維持
Oracle GoldenGateでは、大/小文字が区別されないオブジェクト名の比較時に、データベースのロケールが考慮されます。サポートされるロケールのリストは、サポートされるロケールを参照してください。
8.5.3 エスケープ・シーケンスのサポート
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進エスケープ・シーケンスです。
8.6 TABLEおよびMAPを使用した列のマッピング
Oracle GoldenGateでは、表レベルおよびグローバル・レベルの列マッピングが提供されます。明示的な列マッピング・ルールがない場合は、デフォルトの列マッピングも提供されます。
この項には、次のような列マッピング・ガイドラインがあります。
内容は次のとおりです。
親トピック: データのマッピングおよび操作
8.6.1 列名での大/小文字の区別および特殊文字のサポート
Oracle GoldenGateでの列名とリテラルの指定は、デフォルトで、SQL-92ルールに従います。大/小文字を区別するために二重引用符が必要になるデータベースの場合は、Oracle GoldenGateパラメータ・ファイル、変換関数、ユーザー・イグジットおよびコマンドにおいて、大/小文字を区別する列名を二重引用符で囲む必要があります。大/小文字を区別するために引用符が必要ないその他のデータベースの場合は、大/小文字が区別される列名を、データベースに格納されているとおりに指定する必要があります。リテラルは一重引用符で囲む必要があります。詳細は、大/小文字が区別される列名とリテラルの区別を参照してください。
親トピック: TABLEおよびMAPを使用した列のマッピング
8.6.2 COLMAPによる表レベルの列マッピングの構成
自己記述型の証跡を使用している場合、ソース・オブジェクトの列は、ターゲット・オブジェクトの同じ列名にマップされます。列名がソースとターゲット間で異なる場合、または列を変換する必要がある場合にのみ、列名を管理する必要があります。
ただし、自己記述型の証跡を使用していない場合、デフォルトのマッピングは列の順序によって行われ、列名では行われません。そのため、ソースの列1はターゲットの列1に、ソースの列2はターゲットの列2にマッピングされます。
MAPおよびTABLE
パラメータのCOLMAP
オプションを使用して、次の処理を実行します。
-
異なる名前を持つターゲット列に個別のソース列をマップします。
-
明示的な列マッピングが不要な場合、デフォルトの列マッピングを指定します。
-
ソース列からターゲット列に対してデータを選択、マップ、変換および移動するための指示を提供します。
内容は次のとおりです。
8.6.2.1 USEDEFAULTSを使用したデフォルトの列マッピングの有効化
COLMAPの
USEDEFAULTS
オプションを使用すると、ソース列と対応するターゲット列の名前が同一の場合に、自動デフォルト列マッピングを指定できます。USEDEFAULTS
を使用すると、すべてのターゲット列を明示的にマップする必要がないので、時間を節約できます。
デフォルト・マッピングの場合、Oracle GoldenGateはそれらの列をマッピングし、必要な場合は、データ型を、データ定義ファイルに基づいて変換します(unresolvable-reference.htmlを参照)。明示的なマッピング文でマップされている列にはデフォルト・マッピングを指定しないでください。
次の列マッピングの例では、 ソース表ACCTBL
とターゲット表ACCTTAB
のデフォルト列マッピングと明示的な列マッピングの使用について示します。両方の表の大半の列は同じで、次の点が異なります。
-
ソース表には
CUST_NAME
列がありますが、ターゲット表にはNAME
列があります。 -
ソース表の10桁の
PHONE_NO
列は、ターゲット表の個別のAREA_CODE
列、PHONE_PREFIX
列およびPHONE_NUMBER
列に対応します。 -
ソース表の個別の
YY列、MM
列およびDD
列は、ターゲット表の単一のTRANSACTION_DATE
列に対応します。
これらの相違点に対処するため、USEDEFAULTS
を使用して同じ列を自動的にマップし、異なる列には明示マッピングおよび変換関数を使用します。
次のサンプルは、MAP
パラメータとTABLE
パラメータのCOLMAP
オプションを使用した列マッピングを示しています。ソース表ACCTBL
からターゲット表ACCTTAB
へのマッピングについて説明します。
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)
)
;
表8-1 サンプルの列マッピング
パラメータ文 | 説明 |
---|---|
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による表レベルの列マッピングの構成
8.6.2.2 COLMAP句でマップされる列の指定
COLMAP
の構文は次のとおりです。
COLMAP ([USEDEFAULTS, ]target_column
=source_expression
)
この構文でtarget_column
はターゲット列の名前とsource_expression
です。source_expressions
の例を次に示します。
-
ソース列の名前(
ORD_DATE
など)。 -
数値定数(
123
など)。 -
一重引用符で囲まれた文字列定数(
'ABCD'
など)。 -
Oracle GoldenGate列変換関数を使用する式。
COLMAP
文内で、Oracle GoldenGate列変換関数のいずれかを使用して、マップされた列のデータを変換できます。たとえば:@STREXT (COL1, 1, 3)
-
BEFORE column_name
の使用例を示します。BEFORE ORD_DATE
-
AFTER column_name
の使用例を示します。AFTER ORD_DATE
。列名がリストされている場合、これがデフォルトのオプションです。
列マッピングに、異なるデータベース・タイプに由来する、大/小文字が区別される複数の列が関係する場合、各列を、データベースに格納されているとおりに指定してください。
-
大/小文字を区別するために二重引用符が必要になるデータベースの場合は、大/小文字が区別される列名を二重引用符で囲んで指定してください。
-
大/小文字は区別されるが二重引用符が必要ないデータベースの場合は、列名を、データベースに格納されているとおりに指定してください。
次は、Oracleデータベースのターゲット列と、大/小文字が区別されるSQLサーバー・データベースのソース列との間でのマッピングを示しています。
COLMAP ("ColA" = ColA)
Oracle GoldenGateへの名前の指定の詳細は、「Oracle GoldenGateの入力におけるオブジェクト名の指定」を参照してください。
文字セットとロケールが異なるデータベース間でソース列とターゲット列をマップする場合のグローバリゼーションに関する考慮事項については、「データ・マッピング時のグローバリゼーションに関する考慮事項」を参照してください。
COLMAP
を使用してキー列に値をマップ(主キーの更新操作が発生)しないでください。Oracle GoldenGateがターゲット行の特定に使用するWHERE
句では、キー列の正しい変更前イメージが使用されません。かわりに、変更後イメージが使用されます。このため、SQLEXEC
文などのキー列に基づく関数を使用している場合、エラーになります。
列マッピングの制限
-
LOB
列は、FILTER
列、WHERE
列、またはCOLMAP
文のsource_expression
としては使用できません。LOB
列は、BLOB
、CLOB
、NCLOB
、XMLType
、ユーザー定義データ型、ネストした表、VARRAYs
およびその他の特別なデータ型です。 -
ソース列に4000バイトを超える値が含まれる場合、値は
LOB
レコードとして証跡に格納されるため、変換ルーチンでこの列を使用することはできません。たとえば、OracleのVARCHAR2(4000 CHAR
)と日本語の文字セットは、それぞれの文字を3バイトとして保存します。これは、列の長さが12000バイトになり、Oracle GoldenGateではこの値がLOB
フィールドとして格納されることを意味します。 -
Oracle GoldenGateが実行する完全な全SQL文のサイズは、4MBを超えます。たとえば、数千の
VARCHAR2(4000)
列を持つ表があり、それぞれに4000バイトを配置する場合、Oracle GoldenGateで実行される合計のSQL文が、最大サイズの4MBを超える可能性があります。
親トピック: COLMAPによる表レベルの列マッピングの構成
8.6.3 COLMATCHによるグローバル列マッピングの構成
COLMATCH
パラメータでは、列マッピングのグローバル・ルールを作成します。COLMATCH
では、同じデータセットに対して異なる列名を持つ類似した構造の表どうしをマップできます。このタイプの列をマップする場合、個別のTABLE
文またはMAP文の
COLMAP
句で表レベルのマッピングを使用するより、COLMATCH
の方が簡単です。
大/小文字の区別は次のようにサポートされます。
-
MySQL、SQL ServerおよびTeradataの場合、データベースの大/小文字が区別されるときは、
COLMATCH
では、名前が引用符で囲まれて指定されているかどうかにかかわらず、大/小文字と名前が完全に一致するものが検索されます。 -
同じデータベース内で名前の大/小文字を区別することも区別しないことも可能なOracle DatabaseおよびDB2データベースで、大/小文字を区別するために二重引用符が必要になる場合、
COLMATCH
では、名前が引用符で囲まれているとき、大/小文字と名前がデータベースと完全に一致することが求められます。
構文
COLMATCH {NAMEStarget_column
=source_column
| PREFIXprefix
| SUFFIXsuffix
| RESET}
引数 | 説明 |
---|---|
NAMES |
列名に基づいてマップします。 列名で大/小文字が区別され、データベースで大/小文字が区別されるために引用符が必要な場合、列名を二重引用符で囲みます。これらのデータベース・タイプでは、Oracle GoldenGateは、引用符で囲まれていない列名を大/小文字の区別がされないものとして扱います。 大/小文字の区別はサポートしているが引用符が必要ないデータベースの場合は、列名を、データベースに格納されているとおりに指定してください。
COLMATCH NAMES "aBc" = aBc |
PREFIX |
指定した名前接頭辞または名前接尾辞を無視します。 データベースで大/小文字が区別されるために引用符が必要な場合、接頭辞または接尾辞を二重引用符で囲みます。たとえば、" 大/小文字の区別はサポートしているが引用符が必要ないデータベースの場合は、接頭辞または接尾辞を、データベースに格納されているとおりに指定してください。たとえば、 次の例では、大/小文字が区別されない接頭辞を無視するよう指定しています。ターゲット列名 COLMATCH PREFIX p_ 次の例では、大/小文字が区別される SUFFIX "_k" |
RESET |
前に定義した |
次の例は、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 |
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
表では無効化されます。これらの表のソース列とターゲット列は、名前がすべて同一であるため、自動的にマップされます。
親トピック: TABLEおよびMAPを使用した列のマッピング
8.6.4 デフォルトの列マッピングの理解
自己記述型の証跡ファイルについて、COLMATCH
またはCOLMAP
を使用した明示的な列マッピングが存在しない場合、Oracle GoldenGateでは、デフォルトで次のルールに従ってソース列とターゲット列がマップされます。
これは、SOURCEDEFS
またはTARGETDEFS
を使用している場合は当てはまりません。
-
ソース列の名前および大/小文字がターゲット列のものと正確に一致することが検出された場合、2つの列はマップされます。
-
大/小文字が一致しないことが検出された場合、名前のフォールバック・マッピングが使用されます。フォールバック・マッピングでは、大/小文字を区別せずにターゲット表のマッピングを実行して、一致する名前を探します。大文字の名前を使用して、厳密でない列名のマッチングが適用されます。この動作は、
GLOBALS
パラメータのNAMEMATCHIGNORECASE
によって制御されます。名前のフォールバック照合は、NAMEMATCHEXACT
パラメータを使用して無効にすることも、NAMEMATCHNOWARNING
パラメータを使用して、有効にしたまま警告メッセージを表示することもできます。 -
どのソース列にも対応していないターゲット列には、データベースによって指定されたデフォルト値が割り当てられます。
デフォルトのマッピングを実行できない場合、ターゲット列は、デフォルトで次の表に示されているいずれかの値になります。
列型 | 値 |
---|---|
数値 |
0 (ゼロ) |
文字または |
空白 |
日付または日時 |
現在の日時 |
|
NULL |
親トピック: TABLEおよびMAPを使用した列のマッピング
8.6.5 データ型変換
次の例では、Oracle GoldenGateによるデータ型のマップ方法について説明します。
内容は次のとおりです。
親トピック: TABLEおよびMAPを使用した列のマッピング
8.6.5.1 数値の列
数値の列は、ターゲット列の型およびスケールと一致するように変換されます。ターゲット列のスケールがソースのスケールより小さい場合、数値の右側が切り捨てられます。ターゲット列のスケールがソースのスケールより大きい場合、数値の右側に0(ゼロ)が埋め込まれます。
REPLACEBADNUM
パラメータを使用することで、数字列をマップするときに検出される無効な数字データの代替値を指定できます。詳細は、『Oracle GoldenGateリファレンス』を参照してください。
親トピック: データ型変換
8.6.5.2 文字型の列
文字型の列では、VARCHAR
などの文字ベースのデータ型、文字列形式の数値、文字列形式の日時、および文字列リテラルを使用できます。ターゲット列のスケールがソースのスケールより小さい場合、列の右側が切り捨てられます。ターゲット列のスケールがソースのスケールより大きい場合、列の右側に空白が埋め込まれます。
リテラルは一重引用符で囲む必要があります。
REPLACEBADCHAR
パラメータを使用すると、文字の列をマッピングするときにソースまたはターゲットの文字セットに対して有効なコードポイントが存在しない場合、Oracle GoldenGateプロセスのレスポンスを制御できます。詳細は、『Oracle GoldenGateリファレンス』を参照してください。
親トピック: データ型変換
8.6.5.3 日時の列
日時(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からローカル時間に変換されると、これらの制限も変換後のタイムスタンプに適用されます。タイムゾーンに応じて、変換により時間が追加または引かれる場合があり、これにより、タイムスタンプがサポートされている上限を超えたり、下回ったりすることがあります。
必要な精度は、データ型およびターゲット・プラットフォームに応じて異なります。ターゲット列のスケールがソースのスケールより小さい場合、データの右側が切り捨てられます。ターゲット列のスケールがソースのスケールより大きい場合、列の右側が現在の日時の値で拡張されます。
親トピック: データ型変換
8.7 行の選択とフィルタリング
フィルタリングはOracle GoldenGateで使用可能な列に対してのみ実行できます。TRANLOG
ExtractではOracle GoldenGateは、REDOログおよびデータベース内に存在するすべての列にアクセスできます。列がREDOログにない場合は、列のフィルタを行うために、列を明示的にフェッチする必要があります(FETCHCOLS
を使用)。ExtractポンプおよびReplicatでは、これらの列を証跡ファイル内で使用できる必要があります。このため、FILTER
句またはWHERE
句で使用する列は、ADD TRANDATA COLS
を使用して明示的にログに記録する必要があり、デフォルトのLOGALLSUPCOLS
を維持する必要があります。
抽出またはレプリケートする行をフィルタで除外または選択するには、TABLE
およびMAP
パラメータのFILTER
句およびWHERE
句を使用します。
WHERE
句では基本的なWHERE
演算子を使用できますが、FILTER
句では、Oracle GoldenGate列変換関数をすべて使用できるため、WHERE
句より多くの機能が提供されます。
内容は次のとおりです。
8.7.1 FILTER句を使用した行の選択
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
オプションを使用して、フィルタに失敗したときのユーザー定義のエラーを生成します。このオプションは、失敗に応じてイベントを起動する必要がある場合に役立ちます。
FILTER
句内で@RANGE
関数を使用すると、処理のワークロードを複数のMAP
文またはTABLE
文に分散できます。
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'
)
;
表8-2 複数の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'); |
例外 |
例8-1 @COMPUTE関数のコール
次の例では、@COMPUTE
関数をコールして、価格と数量の積が10,000を超えるレコードを抽出します。
MAP SALES.TCUSTORD, TARGET SALES.TORD, FILTER (@COMPUTE (PRODUCT_PRICE * PRODUCT_AMOUNT) > 10000);
例8-2 @STREQ関数のコール
次の例では、@STREQ
関数を使用して、文字列の値が'JOE'
であるレコードを抽出します。
TABLE ACCT.TCUSTORD, FILTER (@STREQ ("Name", 'joe') > 0);
例8-3 レコードの選択
次の例では、AMOUNT
列が50を超えているレコードを選択し、UPDATE
およびDELETE
操作時にフィルタを実行します。
TABLE ACT.TCUSTORD, FILTER (ON UPDATE, ON DELETE, AMOUNT > 50);
例8-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のパラメータ・ファイルの一部を示した表8-2に示すように、1つのMAP
文またはTABLE
文内に複数のFILTER
句を結合できます。Oracle GoldenGateでは、フィルタはいずれか1つが失敗するか、すべてが成功するまでリスト順に実行されます。1つのフィルタが失敗すると、フィルタ全体が失敗します。
親トピック: 行の選択とフィルタリング
8.7.2 WHERE句を使用した行の選択
WHERE
句で表8-3の任意の要素を使用し、条件文に基づいて行の選択または除外(あるいはその両方)を行います。各WHERE
句は、カッコで囲む必要があります。リテラルは一重引用符で囲む必要があります。
表8-3 許可されている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
);
親トピック: 行の選択とフィルタリング
8.7.3 FILTERおよびWHEREを使用して行を選択する場合の考慮事項
適切な選択句を作成するために、次の推奨事項が役立ちます。
ノート:
この項の例は、大/小文字が区別されないデータベースを想定しています。
8.7.3.1 フィルタでのデータ使用可能性の確保
データベースで、変更された列の値のみをトランザクション・ログに記録している場合、変更されていない列のいずれかが選択基準によって参照されると、エラーが発生する可能性があります。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)
8.7.3.2 列値の比較
比較で使用される要素が確実に一致するように、該当する列タイプを比較します。
-
文字の列とリテラル文字列。
-
数値の列と数値(符号と小数点を含む)。
-
日時の列とリテラル文字列(アプリケーションによって取得される列の書式を使用)。
8.7.3.3 NULL値のテスト
列がNULL
値であるかどうかを評価するには、次の構文を使用します。
column
{= | <>} @NULL
次の例では、列値がNULL
の場合にのみTRUE
が戻され、行がレプリケートされます。他のすべての場合(レコードから列が欠落している場合を含む)、FALSE
を返します。
WHERE (amount = @NULL)
次の例では、列がレコードに存在し、NULL
ではない場合にのみTRUE
が戻されます。
WHERE (amount = @PRESENT AND amount <> @NULL)
ノート:
証跡内の値が4000バイトを超える場合、@NULL
関数はTRUE
を返します。
8.8 変更前の値と変更後の値の取得
更新および削除操作では、ソース列の変更前
の値(更新発生前の値)を取得すると役立つことがあります。挿入の場合は、すべての列値が変更後
イメージとみなされます。
これらの値は証跡に格納されており、フィルタおよび列マッピングで使用できます。たとえば、次のことが可能です。
-
例外
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リファレンス』を参照してください。
親トピック: データのマッピングおよび操作
8.9 列の選択
Oracle GoldenGateによって抽出するソース表の列を制御するには、TABLE
パラメータのCOLS
オプションおよびCOLSEXCEPT
オプションを使用します。COLS
では抽出する列を選択し、COLSEXCEPT
では、COLSEXCEPT
で指定した列以外のすべての列を選択します。
抽出する列を制限すると、ターゲット表にソース表と同じ列が含まれない場合や、列に機密情報(個人識別番号その他の固有のビジネス情報など)が含まれる場合に役立ちます。
親トピック: データのマッピングおよび操作
8.10 SQL操作の選択および変換
デフォルトでは、Oracle GoldenGateによってINSERT
、UPDATE
およびDELETE
操作が取得および適用されます。ExtractまたはReplicatのパラメータ・ファイルで次のパラメータを使用して、処理する操作の種類(挿入のみ、または挿入と更新のみなど)を制御できます。
GETINSERTS | IGNOREINSERTS
GETUPDATES | IGNOREUPDATES
GETDELETES | IGNOREDELETES
Replicatパラメータ・ファイルで次のパラメータを使用すると、あるタイプのSQL操作を別のタイプに変換できます。
-
INSERTUPDATES
を使用して、ソースの更新操作をターゲット表への挿入操作に変換します。これは、ターゲット表にトランザクション履歴を保持する場合に便利です。トランザクション・ログ・レコードには、変更された値だけでなく、表の列値もすべて含まれている必要があります。一部のデータベースでは、トランザクション・ログに行の値がすべて記録されず、変更された値のみが記録されます。 -
INSERTDELETES
を使用して、ソースのすべての削除操作をターゲット表への挿入操作に変換します。これは、ソース・データベースに存在していたすべてのレコードの履歴を保持する場合に便利です。 -
UPDATEDELETES
を使用して、ソースの削除操作をターゲットの更新操作に変換します。
親トピック: データのマッピングおよび操作
8.11 トランザクション履歴の使用
Oracle GoldenGateでは、ターゲット・レコードに対する変更の履歴を保持して、各変更の原因となった操作に関する情報をマップできます。この履歴は、各レコードの最新バージョンのみを含むのではなく、表に対して実行されたすべての操作の個別レコードを含むトランザクションベースのレポート・システムを作成する場合に役立ちます。
たとえば、CUSTOMER
という名前のターゲット表に対して行われた次の一連の操作では、ID Dave
の履歴は残りません。最後の操作でレコードを削除するため、Daveの口座の履歴や最後の残高を知ることはできません。
表8-4 CUSTOMER表の操作履歴
順序 | 操作 | ID | 残高 |
---|---|---|---|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
一連のレコードとしてこの履歴を保持すると、多くの場面で役立ちます。たとえば、トランザクションの正味の効果を生成できます。
トランザクション・レポートを実装する手順
- 変更前の値を取得するようにExtractを準備するため、Extractのパラメータ・ファイルで
GETUPDATEBEFORES
パラメータを使用します。変更前の値(または変更前イメージ)は、更新が実行される前に列に存在する値です。変更前イメージによって、Oracle GoldenGateでトランザクション・レコードを作成できます。 - 挿入としてすべての操作を適用するようにReplicatを準備するため、Replicatのパラメータ・ファイルで
INSERTALLRECORDS
パラメータを使用します。表に対する各操作は、その表内の新規レコードになります。 - トランザクション履歴をマップするため、
@GETENV
列変換関数のGGHEADER
オプションの戻り値を使用します。TABLE
パラメータまたはMAP
パラメータのCOLMAP
文に、ソース式として変換関数を含めます。
表8-4に示されている一連のサンプル・トランザクションを使用して、データベースの最新状態ではなく、よりトランザクション指向の強い顧客ビューを生成するために、次のパラメータ構成を作成できます。
プロセス | パラメータ文 |
---|---|
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';
親トピック: データのマッピングおよび操作
8.12 データのテストおよび変換
データのテストおよび変換は、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
)
表8-5 変換関数の構文
構文の要素 | 説明 |
---|---|
@ |
Oracle GoldenGate関数の名前。関数名には、接頭辞 |
|
関数の引数。 |
表8-6 関数の引数
引数の要素 | 例 |
---|---|
数値定数 |
|
一重引用符で囲まれた文字列リテラル |
'ABCD' |
ソース列の名前 |
データベースが大/小文字の区別をしないか、大/小文字の区別をするか、大/小文字の区別をする場合に引用符が必要か、大/小文字の区別をする場合に引用符を必要としないかにより異なります。 |
算術式 |
|
比較式 |
|
他のOracle GoldenGate関数 |
|
親トピック: データのマッピングおよび操作
8.12.1 関数での列名およびリテラルの処理
デフォルトでは、列変換関数内のリテラル文字列は一重引用符で囲む必要があります。データベースによっては大/小文字を区別する列名を二重引用符で囲む必要があります。それ以外の場合は、データベースに格納されているとおりの大/小文字で入力します。
親トピック: データのテストおよび変換
8.12.2 適切な関数の使用
操作対象または評価対象の列のタイプに適した関数を使用してください。たとえば、数値関数は数値を比較する場合にのみ使用できます。文字列値を比較するには、Oracle GoldenGate文字比較関数のいずれかを使用します。LOB列は、変換関数では使用できません。
次の文は、数値関数の@IF
を使用して文字列値を比較しているため、失敗します。
@IF (SR_AREA = 'Help Desk', 'TRUE', 'FALSE')
次の文は、数値を比較しているため、成功します。
@IF (SR_AREA = 20, 'TRUE', 'FALSE')
詳細は、「数値および文字列の操作」を参照してください。
ノート:
引数解析のエラーは、レコードが処理されるまで検出されないことがあります。プロセスを起動する前に構文を確認してください。
親トピック: データのテストおよび変換
8.12.3 日付の変換
@DATE
、@DATEDIF
および@DATENOW
の各関数を使用して、日時の取得、日時の計算および日時の変換を行います。
次の例では、注文が処理された時間を計算します。
例8-5 時間の計算
ORDER_FILLED = @DATE ( 'YYYY-MM-DD HH:MI:SS', 'JTS', @DATE ('JTS', 'YYMMDDHHMISS', ORDER_TAKEN_TIME) + ORDER_MINUTES * 60 * 1000000)
親トピック: データのテストおよび変換
8.12.4 算術演算の実行
算術式の結果を戻すには、@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.
親トピック: データのテストおよび変換
8.12.4.1 @COMPUTEの省略
@COMPUTE
キーワードは、式を関数の引数として渡す場合には必要ありません。
@STRNUM ((AMOUNT1 + AMOUNT2), LEFT)
次の式は、前述の式と同じ結果を戻します。
@STRNUM ((@COMPUTE (AMOUNT1 + AMOUNT2), LEFT)
親トピック: 算術演算の実行
8.12.5 数値および文字列の操作
数値および文字列を変換するため、Oracle GoldenGateでは次の関数が提供されています。
表8-7 数値および文字のための変換関数
目的 | 変換関数 |
---|---|
バイナリ文字列または文字列の数値への変換 |
|
数値の文字列への変換 |
|
文字列の比較。 |
|
文字列の連結。 |
|
文字列からの抽出 |
|
文字列の長さの返却 |
|
ある文字列と別の文字列の置換 |
|
文字列の大文字への変換 |
|
先頭または末尾(あるいはその両方)の空白の切捨て |
|
親トピック: データのテストおよび変換
8.12.6 NULL値、無効なデータおよび欠落データの処理
列データが欠落しているか、無効であるか、またはNULLである場合、Oracle GoldenGate変換関数では、それぞれに対応する値が戻されます。
BALANCE
は1000
でも、AMOUNT
がNULL
の場合、次の式ではNULL
が戻されます。
NEW_BALANCE = @COMPUTE (BALANCE + AMOUNT)
これらの例外条件によって、計算全体が無効になります。変換を確実に成功させるには、@COLSTAT
、@COLTEST
および@IF
の各関数を使用して、例外条件をテスト(および上書き)してください。
親トピック: データのテストおよび変換
8.12.6.1 @COLSTATの使用
@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))
親トピック: NULL値、無効なデータおよび欠落データの処理
8.12.6.2 @COLTESTの使用
@COLTEST
関数を使用して、次の条件をチェックします。
-
PRESENT
は、列が存在してNULLではないかどうかをテストします。 -
NULL
は、列が存在してNULLであるかどうかをテストします。 -
MISSING
は、列が存在していないかどうかをテストします。 -
INVALID
は、列が存在して無効なデータを含んでいるかどうかをテストします。
次の例は、AMOUNT
列が存在してNULL
であるか、およびそれが存在するが無効であるかをチェックします。
@COLTEST (AMOUNT, NULL, INVALID)
親トピック: NULL値、無効なデータおよび欠落データの処理
8.12.6.3 @IFの使用
@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
(いずれかの列が欠落している場合) -
列の合計
親トピック: NULL値、無効なデータおよび欠落データの処理
8.12.7 テストの実行
@CASE、@VALONEOF
および@EVAL
の各関数によって、データを操作またはマップする前にテストを実行するための追加の方法が提供されます。
親トピック: データのテストおよび変換
8.12.7.1 @CASEの使用
@CASE
を使用して、一連の値テストに応じて値を選択します。
@CASE (PRODUCT_CODE, 'CAR', 'A car', 'TRUCK', 'A truck')
この例では、次の要素が戻されます。
-
A car
(PRODUCT_CODE
がCAR
の場合) -
A truck
(PRODUCT_CODE
がTRUCK
の場合) -
FIELD_MISSING
インジケータ(PRODUCT_CODE
が他のどちらの条件も満たさない場合)
親トピック: テストの実行
8.12.7.2 @VALONEOFの使用
@VALONEOF
を使用して、列または文字列と値リストを比較します。
@IF (@VALONEOF (STATE, 'CA', 'NY'), 'COAST', 'MIDDLE')
この例では、STATE
がCA
またはNY
の場合、値が非ゼロ(つまりTRUE
)のときに@IF
によって返されるレスポンスである"COAST
"が返されます。
親トピック: テストの実行
8.12.7.3 @EVALの使用
@EVAL
を使用して、独立した一連の条件テストに基づいて値を選択します。
@EVAL (AMOUNT > 10000, 'high amount', AMOUNT > 5000, 'somewhat high')
この例では、次の要素が戻されます。
-
high amount
(AMOUNT
が10000
を超える場合) -
somewhat high
(前述の条件が満たされなかった場合で、AMOUNT
が5000
を超え、10000
以下の場合) -
FIELD_MISSING
インジケータ(どちらの条件も満たされない場合)
親トピック: テストの実行
8.13 トークンの使用
データを取得して、証跡レコード・ヘッダーのユーザー・トークン領域内に格納できます。トークン・データを取得して、Oracle GoldenGateによる情報の配信方法をカスタマイズするために様々な用途で使用できます。たとえば、トークン・データを次の用途で使用できます。
-
列マップ
-
SQLEXEC
文によってコールされるストアド・プロシージャ -
ユーザー・イグジット
-
マクロ
8.13.1 トークンの定義
トークンを使用するには、トークン名を定義してデータに関連付けます。データとして使用できるのは、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
関数は、トークン・データを移入するための効果的な方法です。この関数には、トークンにマップしてターゲット・システムで列マッピングに使用できる環境情報を取得するための複数のオプションがあります。
親トピック: トークンの使用
8.13.2 ターゲット表でのトークン・データの使用
ターゲット表にトークン・データをマップするには、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 |
例8-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'));
この例のトークンは、証跡のレコード・ヘッダー内では次のように示されます。
親トピック: トークンの使用