SAP HANAおよびSAP HANA Cloudソース

SAP HANA変更キャプチャメソッド

SAP HANAソースのログベースの変更データキャプチャ

1. 1Secure AgentはCDCジョブ要求を受信します。
2. 2Secure Agentは、ソースからデータベースキャッシュへのデータの初期ロードを実行します。
3. 3初期ロードが完了すると、Secure Agentはトランザクションログから変更データの読み取りを開始します。
4. 4Secure Agentは、トランザクションログのデータとキャッシュ内のROWCACHEテーブルのデータを使用して、DML変更の完全な行を生成し、その完全な行をROWCACHEテーブルに挿入し直します。
5. 5Secure Agentは、完全な行をターゲットに書き込みます。

SAP HANAソースの準備

一般的なタスク

• •SAP HANA Database Ingestionコネクタは、JDBCを使用してSAP HANAおよびSAP HANA Cloudデータベースに接続し、データとメタデータを読み取って、接続プロパティをテストします。SAP HANA JDBCドライバファイルngdbc.jarをダウンロードし、Secure Agentが実行されているマシンのSecure Agentインストールディレクトリの特定のサブディレクトリにコピーする必要があります。
1. 1SAP HANA JDBCドライバのjarファイルを、Secure Agentが実行されているLinuxまたはWindowsマシンにダウンロードします。ファイル名をngdbc.jarに変更します。
ダウンロードするファイルが最新バージョンであることを確認します。ファイルのダウンロードで問題が発生した場合は、SAPカスタマサポートにお問い合わせください。
2. 2Secure Agentの下に次のディレクトリを作成します。
mkdir /mnt/c/REL/ext/connectors/thirdparty/informatica.hanami
3. 3このディレクトリにngdbc.jarファイルをコピーします。
<Secure Agent installation directory>/ext/connectors/thirdparty/informatica.hanami
4. 4Secure Agentを再起動します。
• •データベース取り込みとレプリケーションユーザーを作成します。管理者権限を持つユーザーとしてソースデータベースに接続し、次の文を実行します。
CREATE USER dbmi_user password "<password>" NO FORCE_FIRST_PASSWORD_CHANGE;
この文は、デフォルトの権限を使用してデータベースにユーザーを作成します。これにより、基本的なデータディクショナリビューを読み取ることができ、必要なCDCオブジェクトをユーザー自身のスキーマに作成することができます。
• •SAP HANAまたはSAP HANA Cloudソースを含むデータベース取り込みとレプリケーションタスクをデプロイして実行するには、ソース接続で、次のシステムビューからメタデータやその他の情報を読み取る権限を持つデータベース取り込みとレプリケーションユーザー（dbmi_user）を指定する必要があります。
• - SYS.M_DATABASE - データベースのバージョンを取得するために使用されます。
• - SYS.M_CS_PARTITIONS - テーブルがパーティション化されているかどうかを識別するために使用されます。（SAP HANA Cloudには適用されません）
• - SYS.SCHEMAS - データベースのスキーマのリストを取得するために使用されます。
• - SYS.TABLES - スキーマのテーブル名のリストを取得するために使用されます。
• - SYS.TABLE_COLUMNS - テーブルのカラムメタデータを取得するために使用されます。
• - SYS.INDEXES - テーブルのインデックス情報を取得するために使用されます。
• - SYS.INDEX_COLUMNS - テーブルのインデックス情報を取得するために使用されます。
• •SAP HANA Cloudソースの場合、暗号化するために、接続にはSAP HANA JDBCカスタム接続プロパティ設定が必要です。SAP HANA Database Ingestionプロパティの［詳細接続プロパティ］フィールドに次のプロパティを入力します。
encrypt=true&validateCertificate=false

初期ロードの場合

• •初期ロードジョブの場合、ソーステーブルからデータを読み取るために、次のGRANT文のいずれかを実行します。
GRANT SELECT ON SCHEMA schema_user TO dbmi_user;
この文は、スキーマ内のすべてのテーブルに対するSELECTアクセス権を付与します。
- or -
GRANT SELECT ON database.table_name TO dbmi_user;
この文は、特定のソーステーブルに対するSELECTアクセス権を付与します。データを読み取るソーステーブルごとに、この付与を繰り返します。

トリガベースのCDCの場合

• •トリガベースのCDCを使用する増分ロードジョブの場合は、次の特権を付与します。
• - dbmi_userのPKLOGおよびシャドー_CDCテーブルに行を書き込むトリガの場合は、dbmi_userのスキーマに対するINSERTアクセス権を、ソーステーブルのスキーマを所有するユーザー（ schema_user）に付与します。
GRANT INSERT ON SCHEMA dbmi_user TO schema_user;
• - トリガを使用してschema_userのスキーマ内のソーステーブルから変更データをキャプチャするには、次のいずれかの文を実行します。
GRANT TRIGGER ON SCHEMA schema_user TO dbmi_user;
この文は、スキーマ内のすべてのテーブルに対するトリガアクセス権を付与します。
- or -
GRANT TRIGGER ON database.table_name TO dbmi_user;
この文は、特定のソーステーブルに対するトリガアクセス権を付与します。選択した少数のテーブルからデータをキャプチャする場合は、この文を使用します。CDC対象のソーステーブルごとに、付与を繰り返します。

ログベースのCDCの場合

• •Secure Agentが実行されている仮想マシン（VM）からソースデータベースにアクセスできることを確認します。
• •増分ロードジョブ、または初期ロードと増分ロードの組み合わせジョブでは、Secure AgentとSAP HANAデータベースが別々のマシンにインストールされている場合、SAP HANAデータベースのオンラインログおよびアーカイブログがSecure Agentマシンにマウントされていることを確認します。
オンラインログおよびアーカイブログの生成を担当するデータベースユーザーは、マウントポイントに対する書き込み権限を持っている必要があります。データベース取り込みエージェントサービスが開始される場所となるSecure Agentのユーザーは、オンラインログおよびアーカイブログにアクセスするためにマウントポイントに対する読み取り権限が必要です。
• •ジョブがSAP HANAデータベースのバージョンなど必要なシステム概要情報を取得できるように、データベース取り込みおよびレプリケーションユーザーがSAP HANAシステム監視ビューSYS.M_SYSTEM_OVERVIEWに対する読み取りアクセス権限を持っていることを確認します。
• •ソースデータベースでログノーマルモードを有効にします。手順については、SAP HANAのドキュメント（here）を参照してください。
データベースのログモードがノーマルであることを確認するために、次のコマンドを発行します。
SELECT value FROM M_INIFILE_CONTENTS WHERE file_name = 'global.ini' AND SECTION = 'persistence' AND KEY = 'log_mode'
コマンドは、ログモードとして「normal」を返すはずです。
• •SAP HANA Database Ingestion接続で指定されたソースデータベースユーザーに、次のオブジェクトに対する読み取りアクセス権があることを確認します。
• - REDOログファイル
• - ソースデータベース内のM_LOG_SEGMENTSシステムテーブル
• •ソースデータベースとは別のSAP HANAまたはOracleキャッシュデータベースを作成します。
キャッシュデータベースに対してアーカイブログが無効になっていることを確認します。このデータベースではアーカイブログは必要なく、データベースのオーバーヘッドが増加するだけであるためです。
また、キャッシュデータベースにROWCACHEテーブルとTRANSACTIONSテーブルを作成します。データベース取り込みおよびレプリケーションタスクを設定するときに、これらのテーブルとインデックスを作成するスクリプトを［CDCスクリプト］フィールドからダウンロードするか、または実行します。
• •暗号化されたログファイルから変更データをキャプチャするためにログベースのCDCを使用する予定がある場合は、ソースログを復号するために必要なキーが含まれる暗号化ルートキーファイルがSecure Agentマシン上に存在していることを確認します。また、キーファイルにアクセスするためのバックアップパスワードが存在することも確認してください。サポートが必要な場合は、データベース管理者に問い合わせてください。

使用に関する考慮事項:

一般的な使用に関する考慮事項

• •データベース取り込みとレプリケーションでは、任意のロードタイプとログベースまたはトリガベースのキャプチャタイプを使用するジョブに対して、Red Hat LinuxまたはSUSE Linux上のSAP HANAおよびSAP HANA Cloudソースがサポートされます。
• •データベース取り込みとレプリケーションの増分ロードジョブ、および初期ロードと増分ロードの組み合わせジョブは、最大120文字の長さのテーブル名をサポートします。
• •SAP HANAまたはSAP HANA Cloudソースを使用した増分ロードまたは組み合わせロードジョブでは、スキーマドリフトオプションはサポートされていません。
• •データベース取り込みとレプリケーションでは、初期ロードジョブまたは増分ロードジョブの場合、SAP HANAソーステーブルにプライマリキーは必要ありません。
• •データベース取り込みとレプリケーションは、ターゲットのデフォルトのカラムデータ型にマッピングされている場合でも、次のソースデータ型をサポートしていません。
• - ARRAY
• - BINTEXT
• - BLOB
• - CLOB
• - nclob
• - ST_GEOMETRY
• - ST_POINT
• - TEXT
データベース取り込みとレプリケーションジョブは、これらのデータ型を持つカラムにはnullをプロパゲートします。
注:
ALPHANUM、BINTEXT、CHAR、およびCLOBデータ型は、SAP HANA Cloudでは使用できません。
SAP HANAデータ型からターゲットデータ型へのデフォルトのマッピングについては、デフォルトのデータ型マッピングを参照してください。
• •SAP HANAソースとMicrosoft Azure Synapse Analyticsターゲットを持つデータベース取り込みとレプリケーションタスクのデプロイで、ソーステーブルに長さの長い複数カラムのプライマリキーが含まれている場合、デプロイに失敗することがあります。この場合、プライマリキーの長さを短くしてから、タスクを再度デプロイしてください。
• •トリガベースのCDCまたはログベースのCDCのいずれかに初期ロードと増分ロードの組み合わせジョブを使用する場合は、以下が適用されます。
• - SAP HANA CDCソースを使用した組み合わせロードジョブのジョブレベルの再同期はサポートされていません。テーブルレベルの再同期はサポートされています。
• - 組み合わせロードジョブでのSAP HANA CDCソースのテーブルレベルの同期の場合、デフォルトのオプションは［再同期（更新）］です。このオプションは、テーブルを削除し、再同期の時点でソーススキーマを再作成します。ただし、再同期後に［カラムの追加］スキーマドリフトの変更が発生した場合、新しく追加されたカラムのデータはキャプチャされません。
• •複数のエージェントが含まれるSecure Agentグループを使用していて、アクティブなエージェントが予期せずダウンした場合、データベース取り込みとレプリケーションジョブは、Secure Agentグループ内の別の使用可能なエージェントに自動的に切り替えることができます。自動スイッチオーバーは、15分のハートビート間隔が経過した後に行われます。SAP HANAソースを持つデータベース取り込みとレプリケーションジョブの場合、自動スイッチオーバーに次の制限があります。
• - ジョブで永続ストレージを有効にすることはできません。
• - ジョブでトリガーベースのCDCメソッドを使用することはできません。
• - Kafkaターゲットを持つジョブでは、チェックポイント情報をKafkaヘッダーに格納する必要があります。2025年7月リリースより前に存在していたジョブの場合、チェックポイント情報はSecure Agentのチェックポイントファイルに格納されるため、自動スイッチオーバーを実行できません。
• •SAP HANAソースを持つCDCステージングタスクは、関連付けられている適用ジョブがデプロイ解除された後、またはテーブルが適用ジョブから削除された後はテーブルの変更を追跡しません。削除されたテーブルに対して、そのテーブルの使用可能な最も早いポイントを使用して新しい増分ロードタスクを開始すると、データ損失が発生する可能性があります。適用ジョブがデプロイ解除された場合、ROWCACHEおよびTRANSACTIONテーブルが他の適用ジョブに含まれていないのであれば、これらのテーブルを手動でクリーンアップしてください。
テーブルをクリーンアップするには、次の手順を実行します。
1. 1DBCacheデータベースに接続します。
2. 2現在のスキーマを検証します。現在のスキーマにDBCacheテーブルが含まれていることを確認します。
SELECT CURRENT_SCHEMA "current schema" FROM DUMMY;
3. 3ROWCACHEテーブルから削除するレコードの数を書き留めます。
SELECT COUNT(*) COUNT_RECORDS_TO_BE_DELETED FROM ROWCACHE WHERE SCHEMA_NAME = '<schema_name>' AND TABLE_NAME = '<table_name>';
4. 4ROWCACHEテーブルから、指定したソースとスキーマテーブルのすべてのレコードを削除します。削除件数が正しくない場合にロールバックできるように、自動コミットが無効になっていることを確認します。
DELETE FROM ROWCACHE WHERE SCHEMA_NAME = '<schema_name>' AND TABLE_NAME = '<table_name>';
5. 件数が一致したら変更をコミットします。
6. 5TRANSACTIONSテーブルから削除するレコードの数を書き留めます。
SELECT COUNT(*) COUNT_RECORDS_TO_BE_DELETED FROM TRANSACTIONS WHERE INITIAL_LOAD_SCHEMA_NAME = '<schema_name>' AND INITIAL_LOAD_TABLE_NAME LIKE '<TABLE_NAME>_%';
7. 6TRANSACTIONSテーブルから、指定したソースとスキーマテーブルのすべてのレコードを削除します。削除件数が正しくない場合にロールバックできるように、自動コミットが無効になっていることを確認します。

DELETE FROM TRANSACTIONS WHERE INITIAL_LOAD_SCHEMA_NAME = '<schema_name>' AND INITIAL_LOAD_TABLE_NAME LIKE '<table_name>_%';
8. 件数が一致したら変更をコミットします。

トリガベースのCDCの使用に関する考慮事項

• •トリガベースのCDCを使用する増分ロードジョブおよび組み合わせロードジョブの場合、データベース取り込みとレプリケーションでは、ソースデータベースに次のテーブルが必要です。
• - PKLOGログテーブル。変更タイプとタイムスタンプ、トランザクションID、スキーマ名、テーブル名など、キャプチャされたDML変更に関するメタデータが含まれます。
• - PROCESSEDログテーブル。最新の変更データキャプチャサイクルの最大シーケンス番号（SCN）が含まれます。
• - シャドー<スキーマ>。<テーブル名>_CDCテーブル。トランザクションIDやタイムスタンプなどのメタデータとともに、ソーステーブルからキャプチャされた更新の操作前のイメージと、挿入、更新、および削除の操作後のイメージが含まれます。変更がキャプチャされるソーステーブルごとにシャドーテーブルが存在する必要があります。
また、データベース取り込みとレプリケーションは、AFTER DELETE、AFTER INSERT、およびAFTER UPDATEトリガを使用して、各ソーステーブルのDML変更の操作前のイメージと操作後のイメージを取得し、変更のエントリをPKLOGテーブルとシャドー_CDCテーブルに書き込みます。データベース取り込みとレプリケーションは、処理された挿入、更新、削除行ごとに、SAP HANAシーケンス値をPKLOGテーブルとシャドー_CDCテーブルにも書き込みます。シーケンス値は、CDC処理中にシャドー_CDCテーブルの行をPKLOGテーブルの行にリンクします。
タスクをデプロイすると、データベース取り込みとレプリケーションは、PKLOG、PROCESSED、およびシャドー_CDCテーブル、トリガ、およびシーケンスが存在することを検証します。これらのアイテムが存在しない場合、デプロイ操作は失敗します。
• •タスクウィザードの［ソース］ページから、PKLOG、PROCESSED、シャドー_CDCテーブル、トリガ、およびシーケンスを作成するCDCスクリプトをダウンロードまたは実行できます。SAP HANA Database Ingestionプロパティで［トリガプレフィックス］の値を指定した場合、生成されたトリガの名前の先頭にはプレフィックス_が付きます。
デフォルトでは、トリガはアプリケーションのシステムユーザーをキャプチャします。代わりにトランザクションユーザーをキャプチャする場合は、CDCスクリプトをダウンロードし、スクリプト内の「APPLICATIONUSER」の箇所をすべて「XS_APPLICATIONUSER」に置き換えます。例えば、AFTER DELETEトリガでこの置換を行うと、アーカイブプロセスに関連する削除を識別して除外できます。
• •増分ロードジョブでは、シャドー_CDCテーブルに含まれるソーステーブルカラムのみがソーススキーマ定義の一部になります。新しいカラムがソーステーブルに追加され、シャドー_CDCテーブルに存在しない場合、新しく追加されたカラムは無視されます。
• •既存のソースカラムを削除または名前変更する場合は、トリガおよび対応するシャドー_CDCテーブルを適切に変更します。トリガおよび対応するシャドー_CDCテーブルを適切に変更しなかった場合、マッピングは失敗します。
• • トリガベースのCDCを使用する増分ロードジョブの実行中に、テーブルのサイズを維持するために、古いレコードをPKLOGテーブルおよびシャドー_CDCテーブルから削除するハウスキーピングがいくつか行われます。PKLOGテーブルとシャドー_CDCテーブルの自動ハウスキーピングを有効にするには、SAP HANA Database Ingestion接続プロパティの［ログのクリア］フィールドで、0より大きい値を指定します。デフォルト値は14日間で、最大値は366です。0の値を指定すると、ハウスキーピングは無効になります。
ハウスキーピングは増分ロードジョブの実行中に行われます。複数のジョブが異なるテーブルに対して実行されている場合、各ジョブはPKLOGテーブルと、そのジョブに対してのみ定義されているシャドー_CDCテーブルに対してハウスキーピングを実行します。ジョブからソーステーブルを削除しても、対応するシャドー_CDCテーブルのパージは行われません。

ログベースのCDCの使用に関する考慮事項

• •Secure Agentがインストールされている仮想マシンからデータベースキャッシュにアクセスできることを確認します。データベースキャッシュに対するSecure Agentの読み取りおよび書き込み操作のパフォーマンスを最適化するには、データベースキャッシュをSecure Agentの近くに配置します。
• •データベース取り込みおよびレプリケーションジョブにログベースのCDCを使用するには、CDCステージンググループを設定する必要があります。ステージンググループのCDCステージングタスクは、1つのキャッシュデータベースにのみ接続可能です。
• •キャプチャタイプを［ログベース］に設定してデータベースキャッシュプロパティを設定する、SAP HANA Database Ingestion接続を作成します。接続を使用する各適用タスクでCDCステージングが自動的に有効になります。グループ内の最初のタスクのステージンググループを選択するか、または作成すると、同じ接続を使用する後続のすべての適用タスクが同じグループに追加されます。グループは編集できますが、新しいグループを作成することはできません。
• •トランザクションログファイルに対する読み取り操作のパフォーマンスを最適化するには、CDCステージングタスクを実行するSecure Agentをソースデータベースの近くに配置します。
• •SAP HANA Cloudソースは、ログベースのCDCではサポートされていません。
• •SAP HANAのログベースのCDCでは、暗号化されたオンラインREDOログやアーカイブログから変更データをキャプチャできます。ログはAES-256 CBC（暗号ブロックチェイニング）アルゴリズムで暗号化されている必要があります。
注:
暗号化されたログの有無にかかわらず、組織でログベースのキャプチャを有効にするには、Informaticaグローバルカスタマサポートにお問い合わせください。
暗号化されたログから変更データをキャプチャするには、まずソースの暗号化されたログを復号するために必要なキーが含まれている暗号化ルートキーファイルがSecure Agentシステム上で利用可能であることを確認します。Secure Agentグループ内で、キーファイルはそのグループの各Secure Agentマシンに同じファイル名で存在しなければなりません。また、キーファイルにアクセスするためのバックアップパスワードが存在することも確認してください。これらの管理作業についてサポートが必要な場合は、データベース管理者に問い合わせてください。
データベース取り込みおよびレプリケーションジョブで暗号化されたログのログベースのCDC処理を有効にするには、ジョブが使用するSAP HANA Database Ingestion接続の［キーバックアップパスワード］および［キーバックアップデータパス］プロパティの両方を設定する必要があります。これらのプロパティの片方だけを設定すると、ジョブのデプロイが失敗します。両方のプロパティを空欄にすると、データベース取り込みとレプリケーションはログが暗号化されていないと想定します。同じ接続で、暗号化されたログと暗号化されていないログの両方を処理することはできません。
注:
CDC処理中に暗号化をオフにしたり、暗号化されていない古いログに遭遇したりした場合、データベース取り込みおよびレプリケーションはログが暗号化されているかどうかを検出し、必要に応じて復号ロジックを有効または無効にします。
• •ソースデータベースでは、データを複数のノードに分散させて1つのデータベースを形成するマルチノードストレージは使用できません。
• •スキーマドリフトDDLの変更はサポートされていません。
• •ソーステーブルはCOLUMNタイプのテーブルである必要があります。
• •SAP HANAトランザクションログでは、テーブル内の各変更はコンテナIDで表されます。各コンテナIDは、テーブルのパーティションを表します。データベース取り込みおよびレプリケーションはトランザクションログを読み取るときに、コンテナIDを使用して変更が属するテーブルを判断します。ALTER PARTITION、動的パーティション、またはTRUNCATE TABLE操作によってコンテナIDが変更され、ジョブの失敗やデータ損失が発生する可能性があります。
• •解析の失敗やデータ損失のトラブルシューティングに使用するのに十分な期間にわたってトランザクションログが保持されていることを確認します。
• •ログベースのCDCは、SMALLDECIMALカラムから一部の値を誤ってレプリケートする可能性があります。
• •適用ジョブとCDCステージングタスクのデプロイを解除し、後で同じデータベースキャッシュを使用する場合は、まずROWCACHEテーブルとTRANSACTIONSテーブルを削除してキャッシュをクリーンアップする必要があります。