MySQL 出力コンポーネントは、MySQL データソースにデータを書き込みます。他のデータソースからのデータを MySQL データソースに同期するシナリオでは、ソースデータソース情報を設定した後、MySQL 出力コンポーネントのターゲットデータソースを設定する必要があります。このトピックでは、MySQL 出力コンポーネントを設定する方法について説明します。
前提条件
MySQL データソースが追加されていること。詳細については、「MySQL データソースを作成する」をご参照ください。
MySQL 出力コンポーネントのプロパティを設定するために使用するアカウントが、データソースに対するライトスルー権限を持っていること。権限がない場合は、データソース権限をリクエストする必要があります。詳細については、「データソース権限のリクエスト、更新、および返却」をご参照ください。
手順
Dataphin ホームページの上部ナビゲーションバーで、[開発] > [Data Integration] を選択します。
この方法を使用すると、WordPress のコンテンツ管理機能を活用しながら、Static Web Apps のパフォーマンスとスケーラビリティのメリットを享受できます。アプリケーションをデプロイします。統合ページの上部ナビゲーションバーで、 を選択します（開発-本番モードでは、 を選択する必要があります）。
左側のナビゲーションバーで、[バッチパイプライン] をクリックします。[バッチパイプライン] リストで、開発する オフライン パイプライン をクリックして構成ページを開きます。
ページの右上隅にある [コンポーネントライブラリ] をクリックして、[コンポーネントライブラリ] パネルを開きます。
[コンポーネントライブラリ] パネルの左側のナビゲーションバーで、[出力] を選択します。右側の出力コンポーネントリストで [MySQL] コンポーネントを見つけ、キャンバスにドラッグします。
ターゲットの入力、変換、またはフローコンポーネントの
アイコンをクリックしてドラッグし、現在の MySQL 出力コンポーネントに接続します。MySQL 出力コンポーネントカードの
アイコンをクリックして、[MySQL 出力設定] ダイアログボックスを開きます。
[MySQL 出力設定] ダイアログボックスで、パラメーターを設定します。
パラメーター
説明
基本設定
[ステップ名]
MySQL 出力コンポーネントの名前。Dataphin は自動的にステップ名を生成しますが、ビジネスシナリオに基づいて変更できます。名前は次の要件を満たしている必要があります。
漢字、英字、アンダースコア (_)、および数字のみを含めることができます。
長さは 64 文字を超えることはできません。
[データソース]
データソースのドロップダウンリストには、ライトスルー権限を持っているデータソースと持っていないデータソースを含む、すべての MySQL データソースが表示されます。
アイコンをクリックして、現在のデータソース名をコピーします。ライトスルー権限を持っていないデータソースの場合、データソースの横にある [リクエスト] をクリックして、ライトスルー権限をリクエストできます。詳細については、「データソース権限のリクエスト、更新、および返却」をご参照ください。
MySQL データソースがない場合は、[データソースの作成] をクリックして作成します。詳細については、「MySQL データソースを作成する」をご参照ください。
[タイムゾーン]
時間形式のデータを処理するために使用されるタイムゾーン。デフォルト値は、選択したデータソースで設定されているタイムゾーンです。このパラメーターは変更できません。
説明V5.1.2 より前に作成されたタスクの場合、[データソースのデフォルト設定] または [チャネル設定のタイムゾーン] を選択できます。デフォルト値は [チャネル設定のタイムゾーン] です。
[データソースのデフォルト設定]：選択したデータソースのデフォルトのタイムゾーン。
[チャネル設定のタイムゾーン]：現在の統合タスクの [プロパティ] > [チャネル設定] で設定されているタイムゾーン。
[データベース] (オプション)
テーブルが配置されているデータベースを選択します。データベースを指定しない場合、データソースの登録時に指定されたデータベースが使用されます。
[テーブル]
出力データのターゲットテーブルを選択します。 キーワードを入力してテーブルを検索するか、正確なテーブル名を入力して [完全一致] をクリックします。テーブルを選択すると、システムは自動的にテーブルの状態をチェックします。
アイコンをクリックして、選択したテーブルの名前をコピーします。データ同期のターゲットテーブルが MySQL データソースに存在しない場合は、ワンクリックテーブル作成機能を使用してターゲットテーブルを迅速に生成できます。ワンクリックでテーブルを作成するには、次の手順を実行します。
[ワンクリックでテーブルを作成] をクリックします。Dataphin は、ターゲットテーブル名 (デフォルトはソーステーブル名)、フィールドタイプ (最初は Dataphin フィールドに基づいて変換されます)、およびその他の情報を含む、ターゲットテーブルを作成するためのコードを自動的に生成します。
ビジネス要件に基づいてターゲットテーブルを作成するための SQL スクリプトを変更し、[作成] をクリックします。
ターゲットテーブルが作成されると、Dataphin は自動的にそれを出力データのターゲットテーブルとして設定します。ワンクリックテーブル作成機能は、開発環境と本番環境でデータ同期のターゲットテーブルを作成するために使用されます。Dataphin はデフォルトで本番環境をテーブル作成用に選択します。同じ名前と構造のテーブルが本番環境に既に存在する場合は、本番環境をテーブル作成用に選択する必要はありません。
説明同じ名前のテーブルが開発環境または本番環境に存在する場合、[作成] をクリックすると、テーブルが既に存在することを示すエラーが Dataphin によって報告されます。
一致するテーブルが見つからない場合は、統合用のテーブル名を手動で入力することもできます。
[ロードポリシー]
ターゲットテーブルにデータを書き込むためのポリシーを選択します。[ロードポリシー] には以下が含まれます。
[データの追加 (insert Into)]：既存データを変更せずに、ターゲットテーブルの既存データにデータを追加します。プライマリキーまたは制約違反が発生した場合、ダーティデータエラーが報告されます。
[プライマリキーの競合時に上書き (replace Into)]：プライマリキーまたは制約違反が発生した場合、システムは最初に重複するプライマリキーを持つ古いデータの行全体を削除し、次に新しいデータを挿入します。
[プライマリキーの競合時に更新 (on Duplicate Key Update)]：プライマリキーまたは制約違反が発生した場合、システムは既存のレコードでマップされたフィールドのデータを更新します。
[バッチ書き込みデータサイズ] (オプション)
一度に書き込むデータのサイズ。[バッチ書き込みレコード数] も設定できます。2 つの制限のいずれかに達すると、システムはデータを書き込みます。デフォルト値は 32M です。
[バッチ書き込みレコード数] (オプション)
デフォルト値は 2048 レコードです。データが同期および書き込みされるとき、バッチ書き込み戦略が使用されます。パラメーターには、[バッチ書き込みレコード数] と [バッチ書き込みデータサイズ] が含まれます。
累積データが 2 つの制限 (バッチ書き込みのデータサイズまたはレコード数の制限) のいずれかに達すると、システムはデータのバッチがいっぱいになったとみなし、すぐにバッチデータを宛先に一度に書き込みます。
バッチ書き込みデータサイズを 32 MB に設定することをお勧めします。バッチ書き込みレコード数の制限については、1 レコードの実際のサイズに基づいて柔軟に調整でき、通常は大きな値に設定してバッチ書き込みの利点を最大限に活用します。たとえば、1 レコードのサイズが約 1 KB の場合、バッチ書き込みデータサイズを 16 MB に設定できます。この条件を考慮して、バッチ書き込みレコード数を 16 MB を 1 レコードのサイズ 1 KB で割った結果よりも大きい値 (つまり、16384 レコードよりも大きい値) に設定します。たとえば、20000 レコード です。この設定では、システムはバッチ書き込みデータサイズに基づいてバッチ書き込みをトリガーします。累積データが 16 MB に達するたびに、書き込み操作が実行されます。
[準備ステートメント] (オプション)
データインポートの前にデータベースで実行される SQL スクリプト。
たとえば、継続的なサービスの可用性を確保するために、現在のステップでデータを書き込む前に、最初にターゲットテーブル Target_A を作成し、次に Target_A にデータを書き込みます。現在のステップでデータの書き込みが完了した後、Service_B テーブル (データベースで継続的にサービスを提供) の名前を Temp_C に変更し、次に Target_A テーブルの名前を Service_B に変更し、最後に Temp_C を削除します。
[完了ステートメント] (オプション)
データインポート後にデータベースで実行される SQL スクリプト。
フィールドマッピング
[入力フィールド]
上流コンポーネントの出力に基づいて入力フィールドを表示します。
[出力フィールド]
出力フィールドを表示します。次の操作を実行できます。
フィールド管理：[フィールド管理] をクリックして出力フィールドを選択します。
アイコンをクリックして、[選択された入力フィールド] を [選択されていない入力フィールド] に移動します。
アイコンをクリックして、[選択されていない入力フィールド] を [選択された入力フィールド] に移動します。
一括追加：[一括追加] をクリックして、JSON、TEXT、または DDL 形式でフィールドを設定します。
JSON 形式でフィールドを設定するには、次の例を使用します。
// 例: [{ "name": "user_id", "type": "String" }, { "name": "user_name", "type": "String" }]説明name はインポートされたフィールドの名前を示し、type はインポート後のフィールドのタイプを示します。たとえば、
"name":"user_id","type":"String"は、user_id という名前のフィールドがインポートされ、そのタイプが String に設定されていることを示します。TEXT 形式でフィールドを設定するには、次の例を使用します。
// 例: user_id,String user_name,String行区切り文字は、各フィールドの情報を区切るために使用されます。デフォルトは改行 (\n) です。改行 (\n)、セミコロン (;)、およびピリオド (.) がサポートされています。
列区切り文字は、フィールド名とフィールドタイプを区切るために使用されます。デフォルトはカンマ (,) です。
DDL 形式でフィールドを設定するには、次の例を使用します。
CREATE TABLE tablename ( id INT PRIMARY KEY, name VARCHAR(50), age INT );
出力フィールドの作成：[+ 出力フィールドの作成] をクリックし、プロンプトに従って [列] 名を入力し、[タイプ] を選択します。現在の行の設定が完了したら、
アイコンをクリックして保存します。
[マッピング]
上流の入力とターゲットテーブルのフィールドに基づいて、フィールドマッピングを手動で選択できます。[マッピング] には、[同じ行のマッピング] と [同じ名前のマッピング] が含まれます。
同じ名前のマッピング：同じ名前のフィールドをマップします。
同じ行のマッピング：ソーステーブルとターゲットテーブルのフィールド名が異なるが、対応する行のデータをマップする必要がある場合、同じ行のフィールドをマップします。
[OK] をクリックして、[MySQL] 出力コンポーネントのプロパティ設定を完了します。