DataWorks:GBase 8a データソース

制限事項

• GBase 8a Reader と GBase 8a Writer は、Data Integration 専用リソースグループのみをサポートしています。

• INSERT INTO: プライマリキーの競合または一意のインデックスの競合が発生した場合、競合する行にデータを書き込むことはできません。

• プライマリデータベースに格納されているテーブルにのみデータを書き込むことができます。

  説明

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

• GBase 8a Writer は、writeMode パラメーターをサポートしていません。

データ同期タスクの開発

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

データソースの追加

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

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

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

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

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

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

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

GBase 8a Reader のコード

{
    "type": "job",
    "steps": [
        {
            "stepType": "gbase8a", // プラグイン名。
            "parameter": {
                "datasource": "", // データソースの名前。
                "username": "",
                "password": "",
                "where": "",
                "column": [ // 列の名前。
                    "id",
                    "name"
                ],
                "splitPk": "id",
                "connection": [
                    {
                        "table": [ // テーブルの名前。
                            "table"
                        ],
                        "datasource":""
                    }
                ]
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "stream",
            "parameter": {
                "print": false,
                "fieldDelimiter": ","
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "version": "2.0",
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    },
    "setting": {
        "errorLimit": {
            "record": "0" // 許容されるダーティデータレコードの最大数。
        },
        "speed": {
            "throttle": true, // スロットリングを有効にするかどうかを指定します。値 false はスロットリングが無効であることを示し、値 true はスロットリングが有効であることを示します。mbps パラメーターは、throttle パラメーターが true に設定されている場合にのみ有効になります。
            "concurrent": 1, // 並列スレッドの最大数。
            "mbps":"12"// 最大転送速度。単位: MB/s。
        }
    }
}

GBase 8a Reader のコードのパラメーター

GBase 8a Writer のコード

{
    "type":"job",
    "version":"2.0",// バージョン番号。
    "steps":[
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"gbase8a",// プラグイン名。
            "parameter":{
                "datasource": "データソースの名前",
                "username": "",
                "password": "",
                "column": [// 列の名前。
                    "id",
                    "name"
                ],
                "connection": [
                    {
                        "table": [// テーブルの名前。
                            "Gbase8a_table"
                        ],
                        "datasource":""
                    }
                ],
                "preSql": [ // 同期タスクの実行前に実行する SQL ステートメント。
                    "delete from @table where db_id = -1"
                ],
                "postSql": [// 同期タスクの実行後に実行する SQL ステートメント。
                    "update @table set db_modify_time = now() where db_id = 1"
                ]
            },
            "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"
            }
        ]
    }
}

GBase 8a Writer のコードのパラメーター