DB2 for z/OSソース

ソースの準備:

• •Db2 for z/OSソースを使用したデータベース取り込みとレプリケーションの増分ロードジョブは、ストアドプロシージャを使用してDb2 Instrumentation Facility Interface（IFI）を呼び出し、z/OSソースシステム上のDb2ログから変更データを読み取ります。データベース取り込みとレプリケーションは、ストアドプロシージャライブラリとJCLをDb2 for zOS Database IngestionコネクタパッケージのZIPファイルで提供します。ストアドプロシージャライブラリをAPF許可ライブラリで受け取り、ご使用の環境に合わせてJCLをカスタマイズする必要があります。ストアードプロシージャは、DB2ソースシステムのWorkload Manager（WLM）アドレススペースで実行されます。z/OSシステム要件、ストアドプロシージャのセットアップ、および必要な権限の詳細については、「Db2 for z/OS CDCのストアドプロシージャのインストールと設定」を参照してください。
• •データベース取り込みとレプリケーションの増分ロードタスクでDb2ソースを定義するときに、［CDCスクリプト］フィールドで［すべてのカラムのCDCを有効化］オプションを選択する必要があります。データベース取り込みとレプリケーションは、ソーステーブルおよびCDCに使用される特定のDb2カタログテーブルでDb2 DATA CAPTURE CHANGESを有効にするためのスクリプトを生成します。この属性が1つのジョブに設定されると、他のすべてのジョブは、Db2で必要なカタログテーブルに対してその属性が有効になったことを認識します。十分な権限がある場合はユーザーインタフェースからCDCスクリプトを実行するか、SYSDBA権限を持つDB2 DBAにスクリプトの実行を依頼することができます。
• •データベース取り込みとレプリケーションユーザーに、データベース取り込みとレプリケーションロードタイプを実行するために必要なDb2 for z/OS特権があることを確認してください。詳細については、DB2 for z/OSの権限を参照してください。
• •データベース取り込みとレプリケーションは、Progress DataDirect JDBC IBM DB2ドライバを使用して、Db2 for z/OSソースに接続します。Db2 for z/OSソースを使用したデータベース取り込みとレプリケーションの新しい実装の場合、増分ジョブを最初に実行するユーザーは、JDBC接続を確立するためのSYSADMまたはSYSDBA権限を持っている必要があります。
• •初期ロードと増分ロードの両方を実行し、これらのジョブタイプに対して異なるDb2 for z/OS特権を持った異なるユーザーを使用する場合は、次の手順を実行します。
1. 1初期ロードと増分ロード用に個別のDb2 for zOS Database Ingestion接続を作成します。接続プロパティで、接続を使用する初期ロードジョブまたは増分ロードジョブに必要なDb2特権を持つユーザーを指定します。
2. 2接続へのアクセスを特定のユーザーに制限するには、管理者で接続アセットに明示的なユーザー権限を設定します。ジョブを実行するために接続を使用するには、ユーザーが実行権限を持っている必要があります。これにより、より低いレベルの特権を持つユーザーは、より高いレベルの権限を必要とするジョブを実行できなくなります。
3. 3初期ロードまたは増分ロードタイプを使用するデータベース取り込みとレプリケーションを作成する場合は、必要なDb2特権とアセット権限を持つユーザーが指定された接続を選択します。

使用に関する考慮事項:

• •データベース取り込みとレプリケーションでは、ソーステーブルの各行が一意であることを想定しているため、各ソーステーブルにプライマリキーを持たせることをお勧めします。データベース取り込みとレプリケーションは、プライマリキーの代わりに一意のインデックスを許可しません。プライマリキーが指定されていない場合、データベース取り込みとレプリケーションはすべてのカラムをプライマリキーの一部であるかのように扱います。
• •z/OSのデフォルト設定では、カタログテーブルに対してALTER文を実行するとスキーマドリフトが有効になります。1つのジョブに対してスキーマドリフトを有効にすると、すべてのジョブに対して有効になります。ALTER文の実行中にジョブが実行されている場合、実行中のジョブでは、その後停止して再開するまでスキーマドリフトは有効になりません。
• •［カラムの追加］オプションを［レプリケート］に設定し、カラムの追加操作がキャプチャされた場合、ALTER TABLE <table> ADD COLUMN操作の直後に、RELOADを指定してDb2 REORG TABLESPACEユーティリティまたはDb2 LOADユーティリティを実行し、Db2ページセットの行データに新しいカラム値またはNULLインジケータが含まれていることを確認する必要があります。
• •CDC処理の場合、データベース取り込みとレプリケーションはDb2 for z/OSソーステーブルスペースでは基本行フォーマット（BRF）をサポートしていません。代わりに、再配列行フォーマット（RRF）を使用してください。テーブルをRRFにするには、Db2 REORGユーティリティまたはUNLOADユーティリティを実行して、後続の再ロードを行います。
• •データベース取り込みとレプリケーションでは、次のDb2 for z/OSデータ型はサポートされません。
• - Blob
• - CLOB
• - DBCLOB
• - XML
データベース取り込みとレプリケーションジョブは、これらのデータ型を持つカラムにはnullをプロパゲートします。
データ型のデフォルトのマッピングについては、「デフォルトのデータ型マッピング」を参照してください。
• •複数のエージェントが含まれるSecure Agentグループを使用していて、アクティブなエージェントが予期せずダウンした場合、データベース取り込みとレプリケーションジョブは、Secure Agentグループ内の別の使用可能なエージェントに自動的に切り替えることができます。自動スイッチオーバーは、15分のハートビート間隔が経過した後に行われます。Db2 for z/OSソースを持つデータベース取り込みとレプリケーションジョブの場合、自動スイッチオーバーに次の制限があります。
• - ジョブで永続ストレージを有効にすることはできません。
• - Kafkaターゲットを持つジョブでは、チェックポイント情報をKafkaヘッダーに格納する必要があります。2025年7月リリースより前に存在していたジョブの場合、チェックポイント情報はSecure Agentのチェックポイントファイルに格納されるため、自動スイッチオーバーを実行できません。
• •Db2 for z/OSアーカイブログを仮想テープシステム（VTS）に保存する場合は、まず、データベース取り込みおよびレプリケーションジョブがアーカイブログデータセットから変更データを抽出するのに十分な期間にわたって、アーカイブログデータセットをディスクに保持してください。アーカイブデータセットが共用可能ディスク上にある場合、複数のデータベース取り込みおよびレプリケーションジョブは、ディスクからの変更データを並行して高速で同時に処理できます。アーカイブデータセットがVTS内にあり、複数のジョブが同じアーカイブを読み取ろうとすると、アーカイブデータセットはDb2内のジョブ接続ごとに割り当てられ、ロックされた後に、ロック解除されます。大量の変更データがある環境でのこの追加の割り当ておよびロックアクティビティによって、Db2で割り当ての競合が発生する可能性があります。

Db2 for z/OS CDCのストアドプロシージャのインストールと設定

z/OSシステム要件

• •z/OSシステムには、2.3以降の推奨オペレーティングシステムバージョンがあります。
• •Db2 for z/OSソースは、Db2バージョン12または13を使用します。
• •データベース取り込みとレプリケーションストアドプロシージャを実行するためのWorkload Manager（WLM）アドレススペースが存在することを確認してください。
Db2 WLMアドレススペースをセットアップしていない場合、詳細については、次のIBMドキュメントを参照してください。
• - Db2 13の場合: https://www.ibm.com/docs/en/db2-for-zos/13?topic=2cdrspudf-setting-up-wlm-application-environment-stored-procedures-during-installation
• - Db2 12の場合: https://www.ibm.com/docs/en/db2-for-zos/12?topic=2cdrspudf-setting-up-wlm-application-environment-stored-procedures-during-installation
• •Db2 for z/OS CDCのストアドプロシージャが受信されるライブラリが存在し、z/OSシステムでAPF許可されていることを確認してください。

ストアドプロシージャライブラリをインストールし、JCLをカスタマイズします

1. 1Db2 for zOS Database Ingestionコネクタが使用可能であることを確認します。
Db2 for zOS Database Ingestionコネクタパッケージには、Db2 for z/OSストアドプロシージャライブラリが含まれています。コネクタがSecure Agent Group（ランタイム環境）に対して有効になっている場合、コネクタパッケージの.zipファイルがインストール場所のダウンロードフォルダにダウンロードされます。パッケージ名の形式はpackage-DB2ZMIです。nnnnn。nnnnnは増分されたパッケージバージョン番号です。複数のパッケージバージョンが存在する場合は、最新のバージョンを使用してください。
2. 2package-DB2ZMInnnnn.zipファイルを解凍します。ストアドプロシージャファイルは、パッケージ名の下のDb2WLMStoredProcedureフォルダに追加されます。
3. 3FTPを使用して、Db2WLMStoredProcedureフォルダ内の#STPINSTファイルをz/OSシステム上のシーケンシャルファイル、PDS、またはPDSEに転送します。
注:
• - バイナリモードを設定せずにファイルを転送します。
• - システム要件を満たすために必要な場合は、高レベル修飾子（HLQ）を追加します。
4. 4FTPまたは別のファイル転送方法を使用して、次のファイルをそれぞれz/OSシステム上の別のデータセットに転送します。
• - DBMI.ZOS.DBRMLIB.XMI
• - DBMI.ZOS.LOADLIB.XMI
• - DBMI.ZOS.USERJCL.XMI
注:
• - システム要件を満たすために必要な場合は、HLQを追加または編集します。
• - バイナリモードでファイルを転送します。
• - 各データセットにLRECL=80、BLKSIZE=3120、およびRECFM=FBのDCB属性があることを確認してください。
必要な属性値を指定するために、データセットの事前の割り当てが必要になる場合があります。

1. 1DBRMLIB転送データセットを受信します。
RECEIVE INDATASET(DBMI.ZOS.DBRMLIB.XMI)
注:
• - データセットをz/OSに転送するときにHLQを指定した場合は、HLQを含めてください。
• - メッセージ「INMR906A Enter restore parameters or 'DELETE' or 'END' +」が表示されたら、APF許可ライブラリを入力します。
DA(your.library_name) UNIT(unit) VOLUME(volume)
UNIT()およびVOLUME()オペランドはオプションです。インストールでRECEIVEファイルがデフォルトでワークユニットまたはボリュームに配置されない場合は、それらを含めてください。
2. 2LOADLIB転送データセットを受信します。
RECEIVE INDATASET(DBMI.ZOS.LOADLIB.XMI)
手順1の注を参照してください。
3. 3USERJCL転送データセットを受信します。
RECEIVE INDATASET(DBMI.ZOS.USERJCL.XMI)
手順1の注を参照してください。
4. 4ご使用の環境のストアドプロシージャJCLを含む#STPINSTファイルをカスタマイズします。
JCLは、データのDb2 IFIへの要求の結果を保持するストアドプロシージャとグローバル一時テーブルを作成します。また、ストアドプロシージャパッケージをバインドします。
注:
• - JCLファイルの先頭にあるコメントに基づいて、JCL内の変数を、ステップ1で受信したDb2サブシステム名（!DSN!）、ストアドプロシージャスキーマ名(!SCHEMA!)、プロシージャ名（!STRPRC!）、WLM環境名（!WLMENV!）、およびDBRMLIB送信データセットの名前（!DBRMLIB!）などz/OS環境に適した値に置き換えます。
• - 受信したデータセットにHLQを使用した場合は、HLQをJCLに含めてください。
• - WLM環境名は、プロシージャAPPLENVパラメータまたはWLMアドレススペースのEXEC PARMで指定されます。
プロシージャパラメータ:
//STARTING EXEC DSNBWLMG,DB2SSN=DSNB,APPLENV='DSNBWLM_GENERAL'
EXEC PARM:
PARM='DSNB,40,DSNBWLM_GENERAL'
• - 受信したLOADLIBライブラリをAPF許可後に使用するか、ライブラリのコンテンツを独自のAPF許可ライブラリにコピーすることができます。
• - WLMアドレススペースのSTEPLIB連結には、Db2 IFIを実行するために、APF許可ライブラリのみが含まれている必要があります。
5. 5受信したUSERJCLデータセットのメンバのJCLをカスタマイズします。詳細については、「Db2 for z/OS USERJCLデータセット」を参照してください。
6. 6ストアドプロシージャJCLジョブを実行する前に、必要なDB2権限が付与されていることを確認します。詳細については、DB2 for z/OSの権限を参照してください。
7. 7データベース取り込みパッケージのDB2 DSNRLSTxxリソース制限テーブルに行を追加して、プロセッサリソースがストアドプロシージャの処理に十分であることを確認します。そうしないと、増分ロードジョブが異常終了する可能性があります。次のカラムを含む行を追加します。
• - データベース取り込みとレプリケーションタスクが使用する認証IDを持つAUTHIDカラムか、データベース取り込みとレプリケーションタスクと同じパッケージ名を持つRLFPDGカラム、またはこれら両方のカラム。
• - NULLまたはデフォルトの制限値より大きいリソース制限が定義されたASUTIMEカラム。
次に、リソース制限テーブルへの変更を有効にするために、DB2 -START RLIMITコマンドを発行します。

Db2 for z/OS USERJCLデータセット

LOGINVメンバ

LOGINVには、Db2ログインベントリリストを取得するジョブのJCLが含まれています。タスクウィザードで取り込みタスクの［増分ロード操作の当初の開始点］プロパティを［特定の日付と時刻］に設定した場合、インベントリリストを使用して、データベース取り込みとレプリケーションジョブの初回実行時または再開時にログ内の開始点が決定されます。ログインベントリリストはデータベース取り込みとレプリケーションに、開始RBAまたはLSNと終了RBAまたはLRSN、およびDb2サブシステムのすべてのアクティブログとアーカイブログの開始タイムスタンプと終了タイムスタンプを提供します。データベース取り込みとレプリケーションは、この情報を使用して適切なログアーカイブを選択し、要求された開始点を検索します。［増分ロード操作の当初の開始点］プロパティが［特定の日付と時刻］以外のオプションに設定されている場合は、USERJCLライブラリをインストールする必要はありません。

LOGINVメンバの内容:

//<USERID>I JOB 'LOG INVENTORY',MSGLEVEL=(1,1),MSGCLASS=X,
// NOTIFY=&SYSUID,CLASS=A,REGION=0M
//* -------------------------------------------------------
//*
//* PLEASE CHANGE DSN? TO THE DB2 SUBSYSTEM OF YOUR CHOICE.
//*
//* THIS JCL MEMBER CAN BE USED TO RUN A LOG INVENTORY
//* LIST. DBMI WILL REQUEST THIS IF A DBMI JOB IS TRYING TO
//* RETART USING TIME. THE LOG INVERNTORY GIVES DBMI THE
//* ABILITY TO CORRELATE RBA/LSRN TO ACTUAL LOG RESTART
//* POSITIONS. DBMI PARSES THE SYSPRINT OUTPUT TO GET THE
//* REQUIRED INFORMATION.
//*
//*
//* SUBSTITUTION TAGS
//* _________________
//*
//* SUBSTITUTION TAGS ARE USED TO INSERT DATA INTO THE JOB
//* BY DBMI BEFORE IT IS SUBMITTED. YOU MAY COPY THIS JCL
//* INTO ANOTHER MEMBER AND MODIFY ITS CONTENTS. SUBSTITUTION
//* TAGS MAY ALSO BE REMOVED AND HARD CODED FOR INDIVIDUAL
//* JOB NEEDS.
//*
//*
//* <USERID> WILL BE REPLACED WITH THE USER ID.
//*
//* -------------------------------------------------------
//LOGINV EXEC PGM=DSNJU004
//STEPLIB DD DISP=SHR,DSN=DSN?10.SDSNLOAD
// DD DISP=SHR,DSN=DSN?10.DSNC.RUNLIB.LOAD
//SYSUT1 DD DISP=SHR,DSN=DSN?.BSDS01
//SYSPRINT DD SYSOUT=*
//SYSSUMRY DD SYSOUT=*
//

注:

このJCLでは、データベース取り込みとレプリケーションは<USERID>をDb2 for zOS Database Ingestion接続プロパティで指定されたユーザーに置き換えます

1. 1LOGINVメンバの場合、データベース取り込みとレプリケーションタスクウィザードの［ソース］ページで［増分ロード操作の当初の開始点］詳細プロパティが［特定の日付と時刻］に設定されている場合、データベース取り込みとレプリケーションは、ソースに次のカスタムプロパティが指定されているかどうかをチェックします。
• - pwx.cdcreader.ZOS.Db2JobsDSN（インストールされているUSERJCL PDSまたはPDSEdの名前を指定）
• - pwx.cdcreader.ZOS.Db2JobLLOGINVMember（データベース取り込みとレプリケーションジョブに使用されるLOGINVメンバ名を指定）
2. 2データベース取り込みとレプリケーションは、Db2提供のストアドプロシージャADMIN_DS_BROWSEを使用してLOGINVメンバを読み取ります。
3. 3データベース取り込みとレプリケーションは、ジョブの実行に必要なタグを置き換えます。
4. 4データベース取り込みとレプリケーションは、Db2提供のストアドプロシージャADMIN_SUBMIT_JOBを使用して、ジョブをDb2 for z/OSデータベースにサブミットします。
5. 5データベース取り込みとレプリケーションは、Db2提供のストアドプロシージャADMIN_JOB_QUERYを使用して、サブミットされたジョブのステータスを照会します。
6. 6ジョブが完了すると、データベース取り込みとレプリケーションは、Db2提供のストアドプロシージャADMIN_JOB_FETCHを使用して、ジョブ出力を取得します。

DB2 for z/OSの権限

• •初期ロードジョブの場合は、Db2 for zOS Database Ingestion接続プロパティで指定されたユーザーに次の特権を付与します。
SELECT on schema.table TO user
ここで、schema.tableはソーステーブルを表します。
• •ソースのアンロード処理中にDb2カタログテーブルに対してクエリを実行するには、次のカタログテーブルに対するSELECT特権を付与します。
• - SYSIBM.SYSCOLUMNS
• - SYSIBM.SYSINDEXES
• - SYSIBM.SYSKEYS
• - SYSIBM.SYSTABLEPART
• - SYSIBM.SYSTABLES
• - SYSIBM.SYSTABLESPACE

• •ユーザーがDB2 Instrumentation Facility Interface（IFI）から必要な情報を取得できるようにする方法:
GRANT MONITOR2 TO user;
COMMIT;
• •グローバル一時テーブルの権限をユーザーに付与する方法:
GRANT INSERT ON !SCHEMA!.!STRPRC!_RS_TBL to user;
GRANT DELETE ON !SCHEMA!.!STRPRC!_RS_TBL to user;
GRANT EXECUTE ON PROCEDURE !SCHEMA!.!STRPRC! to user;
COMMIT;
ここで、!SCHEMA! および、!STRPRC! はジョブJCLの変数であり、それぞれストアドプロシージャスキーマ名とプロシージャ名を表します。
最初の2つの特権により、ユーザーは、ストアドプロシージャがログデータを書き込んでいるグローバル一時テーブルのコンテンツを読み取り、削除することができます。3番目の特権により、ユーザーはストアドプロシージャを実行できます。
注:
GRANT INSERT ONまたはGRANT DELETE ON文がSQLCode -526で失敗した場合は、代わりに次のGRANTを使用してください。
GRANT ALL PRIVILEGES ON !SCHEMA!.!STRPRC!_RS_TBL to user;
• •ストアドプロシージャがそのDB2プランをバインドできるようにするには、次の権限をPUBLICに付与します。
GRANT BIND, EXECUTE ON PLAN !STRPRC! TO PUBLIC;
COMMIT;
• •ソースのアンロード処理中にDb2カタログテーブルに対してクエリを実行するには、次のカタログテーブルに対するSELECT特権を付与します。
• - SYSIBM.SYSCOLUMNS
• - SYSIBM.SYSDUMMY1
• - SYSIBM.SYSINDEXES
• - SYSIBM.SYSKEYS
• - SYSIBM.SYSTABLEPART
• - SYSIBM.SYSTABLES
• - SYSIBM.SYSTABLESPACE

• •ストアドプロシージャジョブを実行するユーザーにSYSADM権限があることを確認するか、Db2 for z/OSDBAにそれを実行するように依頼してください。
• •ストアドプロシージャを実行するには、#STPINST JCLファイルで指定されたプロシージャスキーマ名に次のDb2権限を付与する必要があります。
• - Db2カタログテーブルに対するSELECT権限:
GRANT SELECT ON SYSIBM.* TO schema;
• - JCLで指定されたパッケージ名に対するEXECUTE権限。
GRANT EXECUTE ON PACKAGE package_name TO user;

Db2 DATA CAPTURE CHANGESの有効化

• •次のシステムカタログテーブルにDATA CAPTURE CHANGESを設定します。
• - SYSIBM.SYSCOLUMNS
• - SYSIBM.SYSINDEXES
• - SYSIBM.SYSKEYS
• - SYSIBM.SYSTABLES
• - SYSIBM.SYSTABLESPACE
選択した対話式z/OSインタフェースから、各カタログテーブルに対して次のSQL文を送信します。
ALTER TABLE SYSIBM.<systable_name> DATA CAPTURE CHANGES
この文を発行するには、ALTER権限が必要です。通常、Db2 DBAがこの権限を持ち、文を発行します。DATA CAPTURE CHANGESを設定する必要があり、ALTER権限を持っていない場合は、次の文を使用して、各カタログテーブルに対するALTER権限を付与してもらうようにDb2 DBAに依頼してください。
GRANT ALTER ON TABLE SYSIBM.<systable_name> TO <user>;
ALTER TABLE SQLを1回実行すると、すべてのデータベース取り込みおよびレプリケーションジョブは、Db2ログストリーム内のCDC処理用のシステムカタログテーブルにアクセスできるようになります。
ただし、スキーマドリフトの変更を検出するためにカタログテーブルを読み取るジョブの場合は、権限レベルの低いユーザーには各カタログテーブルへの読み取りアクセスのためのSELECT権限を付与する必要があります。
GRANT SELECT ON TABLE SYSIBM.<systable_name> TO <user>;
• •ユーザーインタフェースから選択したソーステーブルに対してDATA CAPTURE CHANGESオプションを有効にするCDCスクリプトを生成するには、各テーブルに対して次のSQL文を発行します。
ALTER TABLE schema.table DATA CAPTURE CHANGES <--for each source table
COMMIT;
CDCスクリプトを生成しない場合は、各ソーステーブルに対してこの同じSQL文を発行します。また、このSQL文は、Db2ログ内のテーブルの変更データをストアドプロシージャで使用できるようにします。

Db2 for z/OSソースの変更キャプチャメカニズム

1. 1Secure Agent配下のDBMI Agentサービスで実行されるマルチスレッドログコレクタは、Db2ログデータの複数の同時要求をDb2ストアドプロシージャに発行します。
各要求には、開始RBA、またはログがデータ共有環境にある場合は開始LRSNと、データベース取り込み用のCDC対象のテーブルのリストが含まれます。
一連のログデータの処理中に、ログコレクタは次の一連のログデータを要求できます。
2. 2Db2 Instrumentation Facility Interface（IFI）APIは、アクティブログとアーカイブログから、CDC対象の選択したソーステーブルのデータを抽出します。その後、IFIはデータを未加工のネイティブ形式で、z/OS Workload Manager（WLM）のInformatica Db2ストアドプロシージャに転送します。
3. 3Db2ストアドプロシージャは、キャプチャされたデータとともにUOWをUOWマネージャに返します。
4. 4UOWマネージャは、UOWをコミット順にログパーサーに送信します。
5. 5マルチスレッドログパーサーは、コミットされたUOWからのDML変更を同時に解析します。結果は、ターゲットタイプが期待する形式の未加工のネイティブDb2ログデータです。
注:
このリソース集約型のアクティビティはSecure Agentボックスで発生するため、z/OSシステムのCPU消費は最小限に抑えられます。
6. 6CDCライターが、フォーマットされたデータをターゲットに適用します。