3.5. Debezium コネクターを実行するための Db2 の設定

手順

1. Db2 で提供される bldrtn コマンドを使用して、Db2 サーバーホストで Debezium 管理 UDF をコンパイルします。

   cd $HOME/asncdctools/src

   ./bldrtn asncdc

2. データベースが稼働していない場合は起動します。DB_NAME は、Debezium が接続するデータベースの名前に置き換えます。

   db2 start db DB_NAME

3. JDBC が Db2 メタデータカタログを読み取りできるようにします。

   cd $HOME/sqllib/bnd

   db2 bind db2schema.bnd blocking all grant public sqlerror continue

4. データベースが最近バックアップされたことを確認します。ASN エージェントには、読み取りを始める最新の開始点が必要です。バックアップを実行する必要がある場合は、以下のコマンドを実行して、最新のバージョンのみを利用できるようにデータをプルーニングします。古いバージョンのデータを保持する必要がない場合は、バックアップの場所に dev/null を指定します。

   1. データベースをバックアップします。DB_NAME および BACK_UP_LOCATION を適切な値に置き換えます。

      db2 backup db DB_NAME to BACK_UP_LOCATION

   2. データベースを再起動します。

      db2 restart db DB_NAME

5. データベースに接続して、Debezium 管理 UDF をインストールします。db2instl ユーザーとしてログインしていることを前提とするため、UDF が db2inst1 ユーザーにインストールされている必要があります。

   db2 connect to DB_NAME

6. Debezium 管理 UDF をコピーし、その権限を設定します。

   cp $HOME/asncdctools/src/asncdc $HOME/sqllib/function

   chmod 777 $HOME/sqllib/function

7. ASN キャプチャーエージェントを開始および停止する Debezium UDF を有効にします。

   db2 -tvmf $HOME/asncdctools/src/asncdc_UDF.sql

8. ASN 制御テーブルを作成します。

   $ db2 -tvmf $HOME/asncdctools/src/asncdctables.sql

9. テーブルをキャプチャーモードに追加し、キャプチャーモードからテーブルを削除する Debezium UDF を有効にします。

   $ db2 -tvmf $HOME/asncdctools/src/asncdcaddremove.sql

   Db2 サーバーを設定したら、UDF を使用して SQL コマンドで Db2 レプリケーション (ASN) を制御します。UDF によっては戻り値が必要な場合があります。この場合、SQL の VALUE ステートメントを使用して呼び出します。その他の UDF には、SQL の CALL ステートメントを使用します。

10. ASN エージェントを起動します。

    VALUES ASNCDC.ASNCDCSERVICES('start','asncdc');

    前述のステートメントは、以下のいずれかの結果を返します。

    • asncap is already running

    • start --> <COMMAND>

      この場合は、以下の例のように、ターミナルウィンドウに指定の <COMMAND> を入力します。

      /database/config/db2inst1/sqllib/bin/asncap capture_schema=asncdc capture_server=SAMPLE &

11. テーブルをキャプチャーモードにします。キャプチャーする各テーブルに対して、以下のステートメントを呼び出します。MYSCHEMA は、キャプチャーモードにするテーブルが含まれるスキーマの名前に置き換えます。同様に、MYTABLE は、キャプチャーモードにするテーブルの名前に置き換えます。

    CALL ASNCDC.ADDTABLE('MYSCHEMA', 'MYTABLE');

12. ASN サービスを再初期化します。

    VALUES ASNCDC.ASNCDCSERVICES('reinit','asncdc');