DataWorks:Db2データソース

サポートされているDb2バージョン

Db2 ReaderとDb2 Writerが使用するDb2 JDBCドライバーのバージョンは、IBM Data Server Driver for JDBC and SQLJ 4.11.77です。Db2 JDBCドライバーのバージョンとDb2バージョンのマッピングの詳細については、IBM Supportをご参照ください。

制限事項

• Db2 ReaderとDb2 Writerは、Data Integrationの排他リソースグループのみをサポートし、Data Integrationの共有リソースグループまたはData Integrationのカスタムリソースグループはサポートしていません。

• Db2 Writerは、リーダーからデータを取得し、INSERT INTOステートメントを実行して、データを宛先データベースに書き込みます。主キーの競合または一意のインデックスの競合が発生した場合、競合する行にデータを書き込むことはできません。パフォーマンスを向上させるために、Db2 WriterはPreparedStatementオブジェクトを使用してバッチ更新を実行し、rewriteBatchedStatementsパラメーターをtrueに設定します。これにより、Data Integrationは、蓄積されたバッファリングされたデータの量が特定のしきい値に達すると、書き込みリクエストをコミットします。

  説明

  Db2 Writerを使用する同期タスクには、少なくともINSERT INTOステートメントを実行するための権限が必要です。他の権限が必要かどうかは、タスクの構成時にpreSqlパラメーターとpostSqlパラメーターで指定するSQLステートメントによって異なります。

• バッチ同期中にビューのデータを読み取ることができます。

• Db2 AES 暗号化アルゴリズムはサポートされていません。

データ型マッピング

バッチデータの読み取りと書き込み

Db2 Readerと Db2 Writerは、ほとんどの Db2 データ型をサポートしています。データベースのデータ型がサポートされていることを確認してください。

データ同期タスクの開発

データ同期タスクの開始点と構成手順については、以下のセクションを参照してください。パラメーター設定については、タスクの構成タブにある各パラメーターのヒントをご覧ください。

データソースの追加

特定のデータソースとのデータ同期のためにデータ同期タスクを構成する前に、DataWorksにデータソースを追加する必要があります。詳細については、データソースの追加と管理をご参照ください。

単一テーブルのデータを同期するためのバッチ同期タスクの構成

• 構成手順の詳細については、コードレスUIを使用したバッチ同期タスクの構成とコードエディターを使用したバッチ同期タスクの構成をご参照ください。

• コードエディターを使用してバッチ同期タスクを構成する場合に構成されるすべてのパラメーターと実行されるコードについては、付録：コードとパラメーターをご参照ください。

データベース内のすべてのデータのバッチ同期を実装するための同期設定の構成

構成手順の詳細については、Data Integrationでの同期タスクの構成をご参照ください。

追加情報

• プライマリデータベースとセカンダリデータベース間のデータ同期

  災害復旧のためにセカンダリDb2データベースをデプロイできます。セカンダリデータベースは、バイナリログに基づいてプライマリデータベースから継続的にデータを同期します。プライマリデータベースとセカンダリデータベース間のデータ遅延を防ぐことはできません。これにより、データの不整合が発生する可能性があります。

• データ整合性制御

  Db2は、データクエリの強い整合性をサポートするリレーショナルデータベース管理システム（RDBMS）です。同期タスクが開始される前に、データベーススナップショットが作成されます。Db2 Readerは、データベーススナップショットからデータを読み取ります。したがって、データ同期の間に新しいデータがデータベースに書き込まれた場合、Db2 Readerは新しいデータを取得できません。

  単一の同期タスクでDb2 Readerが並列スレッドを使用できるようにすると、データの整合性を確保できません。

  Db2 Readerは、splitPkパラメーターの値に基づいてソーステーブルをシャーディングし、並列スレッドを使用してデータを読み取ります。これらの並列スレッドは異なるトランザクションに属し、異なる時点でデータを読み取ります。したがって、並列スレッドは異なるスナップショットを観測します。

  同期タスクに並列スレッドを使用すると、データの不整合を防ぐことはできません。次の回避策を使用できます。

  • 同期タスクでDb2 Readerが単一スレッドを使用してデータを読み取るようにします。これは、Db2 Readerにシャードキーを指定する必要がないことを示します。これにより、データの整合性は確保されますが、データの同期効率は低下します。

  • データ同期中にソーステーブルにデータが書き込まれないようにします。これにより、データ同期中にソーステーブルのデータが変更されないことが保証されます。たとえば、ソーステーブルをロックしたり、プライマリデータベースとセカンダリデータベース間のデータ同期を無効にすることができます。これにより、データは効率的に同期されますが、実行中のサービスが中断される可能性があります。

• 文字エンコーディング

  Db2 ReaderはJDBCを使用してデータを読み取ります。これにより、Db2 Readerは文字のエンコード形式を自動的に変換できます。したがって、エンコード形式を指定する必要はありません。

• 増分データ同期

  Db2 ReaderはJDBCを使用してデータベースに接続し、WHERE句を含むSELECTステートメントを使用して増分データを読み取ります。

  • バッチデータの場合、増分の追加、更新、および削除操作（論理削除操作を含む）はタイムスタンプによって区別されます。特定のタイムスタンプに基づいてWHERE句を指定します。タイムスタンプで示される時間は、前回の同期の最新のタイムスタンプで示される時間よりも後である必要があります。

  • ストリーミングデータの場合、特定のレコードのIDに基づいてWHERE句を指定します。 IDは、前回の同期に含まれる最大IDよりも大きい必要があります。

  追加または変更されたデータを区別できない場合、Db2 Readerは完全なデータのみを読み取ることができます。

• 構文検証

  Db2 Readerでは、querySqlパラメーターを使用してカスタムSELECTステートメントを指定できますが、これらのステートメントの構文は検証されません。

付録：コードとパラメーター

付録：コードエディターを使用したバッチ同期タスクの構成

コードエディターを使用してバッチ同期タスクを構成する場合は、コードエディターの形式要件に基づいて、関連データソースのリーダーとライターのパラメーターを構成する必要があります。形式要件の詳細については、コードエディターを使用したバッチ同期タスクの構成をご参照ください。以下の情報は、コードエディターのリーダーとライターのパラメーターの構成の詳細について説明しています。

Db2 Readerのコード

{
    "type":"job",
    "version":"2.0",// バージョン番号。
    "steps":[
        {
            "stepType":"db2",// プラグイン名。
            "parameter":{
                "password":"",// Db2 データベースへの接続に使用するパスワード。
                "jdbcUrl":"",// Db2 データベースの JDBC URL。
                "column":[
                    "id"
                ],
                "where":"",// WHERE 句。
                "splitPk":"",// シャードキー。
                "table":"",// テーブルの名前。
                "username":""// Db2 データベースへの接続に使用するユーザー名。
            },
            "name":"Reader",
            "category":"reader"
        },
        { 
            "stepType":"stream",
            "parameter":{},
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"// 許容されるダーティデータレコードの最大数。
        },
        "speed":{
             "throttle":true,// スロットリングを有効にするかどうかを指定します。値 false はスロットリングが無効であることを示し、値 true はスロットリングが有効であることを示します。 mbps パラメーターは、throttle パラメーターが true に設定されている場合にのみ有効になります。
             "concurrent":1, // 並列スレッドの最大数。
             "mbps":"12"// 最大伝送速度。単位：MB/s。
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

Db2 Readerのコードのパラメーター

Db2 Writerのコード

{
    "type":"job",
    "version":"2.0",// バージョン番号。
    "steps":[
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"db2",// プラグイン名。
            "parameter":{
                "postSql":[],// 同期タスクの実行後に実行する SQL ステートメント。
                "password":"",// Db2 データベースへの接続に使用するパスワード。
                "jdbcUrl":"jdbc:db2://ip:port/database",// Db2 データベースの JDBC URL。
                "column":[
                    "id"
                ],
                "batchSize":1024,// 一度に書き込むデータレコードの数。
                "table":"",// テーブルの名前。
                "username":"",// Db2 データベースへの接続に使用するユーザー名。
                "preSql":[]// 同期タスクの実行前に実行する SQL ステートメント。
            },
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"// 許容されるダーティデータレコードの最大数。
        },
        "speed":{
            "throttle":true,// スロットリングを有効にするかどうかを指定します。値 false はスロットリングが無効であることを示し、値 true はスロットリングが有効であることを示します。 mbps パラメーターは、throttle パラメーターが true に設定されている場合にのみ有効になります。
            "concurrent":1, // 並列スレッドの最大数。
            "mbps":"12"// 最大伝送速度。単位：MB/s。
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

Db2 Writerのコードのパラメーター