ソースファイルからデータベースにダイナミックカラムを書き込む

このシナリオは、全Talend製品に適用されます。

Talendでサポートされているテクノロジーの詳細は、Talendコンポーネントをご覧ください。

このシナリオでは、デモンストレーションの目的でMySQLを使用しています。ソースファイルからダイナミックカラムを読み取り、マッピングして[MySQL]データベースのテーブルに書き込みます。ダイナミックなカラムを既知のカラム名と合わせて定義することにより、不明なカラムを含め、すべてのカラムをソースファイルから取得できます。

• tFileInputDelimited、tMap、およびtMysqlOutputコンポーネントをワークスペースにドロップします。

• [Row] (行) > [Main] (メイン)接続を使用して、tFileInputDelimitedをtMapにリンクします。
• [Row] (行) > [*New Output* (Main)] (*新規出力*: メイン)接続を使用して、tMapをtMysqlOutputにリンクします。
• tFileInputDelimitedをダブルクリックし[Component] (コンポーネント)タブの[Basic Settings] (基本設定)ビューを開きます。

• [Property Type] (プロパティタイプ)リストから[Built-In] (組み込み)を選択します。
• [File name/Stream] (ファイル名/ストリーム)フィールドの横にある[...]ボタンをクリックし、入力ファイルを参照します。
• [Row Separator] (行区切り)および[Field Separator] (フィールド区切り)フィールドのとなりで、区切りとして使用する文字を入力します。
• [Edit Schema]をクリックして、ソースファイルスキーマを定義します。

  [Edit Schema] (スキーマを編集)ダイアログボックスが開きます。

• 必要な数の行を追加するか、およびボタンを使用して行を削除します。
• ボタンとボタンを使って、カラムの順番を変更できます。
• [Column] (カラム)の下に、既知のカラムの名前をそれぞれ別々の行に入力します。
• 最後の行の[Column] (カラム)の下に、ダイナミックカラムの名前を入力します。
• [Type]の下で、フィールドをクリックして、対応するカラムのデータの種類を定義します。

  矢印をクリックして、正しいデータ型を選択します。

• ソーススキーマの定義が完了したら、[OK]をクリックしてダイアログボックスを閉じます。
• tMapをクリックして、[Component] (コンポーネント)タブの[Basic Settings] (基本設定)ビューを開きます。

• [Map Editor]の横にある[...]をクリックして、ソースファイルのカラムをマッピングします。

• ウィンドウの右上の[Output Panel] (出力パネル)の上部のツールバーで、ボタンをクリックします。

  [Add an Output] (出力の追加)でスキーマダイアログボックスが表示されます。

• [New output] (新規出力)のとなりで、出力スキーマの名前を入力します。
• [OK]をクリックしてダイアログボックスを閉じます。
• [Ctrl + クリック]で、左側の入力スキーマのカラム名をすべてハイライトし、出力スキーマにドロップします。

  出力カラムにドロップされたカラムは元の値を保持し、1対1で自動的にマッピングされます。

• 出力スキーマで[Expression] (式)の下の該当する行をクリックし、[Expression Builder] (式ビルダー)を使用して、出力の対応するカラムの詳細パラメーターを設定するために使われます。
• [...]ボタンをクリックすると、[Expression Builder] (式ビルダー)が開き、必要に応じてパラメーターを設定できます。

[Expression Builder] (式ビルダー)の使用方法は、Studio Talendユーザーガイドをご覧ください。

• [OK]をクリックして、[Map Editor] (マップエディター)を閉じます。
• tMysqlOutputをダブルクリックし、[Component] (コンポーネント)タブの[Basic Settings] (基本設定)を設定するために使われます。

• [Property Type] (プロパティタイプ)として[Built-In] (組み込み)を選択します。
• 対応するリストから[DB Version] (データベースバージョン)を選択します。
• [Host] (ホスト)のとなりにデータベースサーバーのIPアドレスを入力します。
• [Port] (ポート)のとなりにデータベースサーバーのリスニングポート番号を入力します。
• [Username] (ユーザー名)および[Password] (パスワード)フィールドに認証データを入力します。
• [Action on data] (データでのアクション)のとなりで必要な操作を選択します。
• [Action on data] (データでのアクション)のとなりで必要な操作を選択します。
• [Schema type]を[Built-in]として設定し、 [Edit schema] (スキーマを編集)をクリックして、必要に応じてスキーマを変更します。
• F6を押してジョブを実行します。

  テーブルは、不明だったカラムのデータおよびカラム名と共にMySQLデータベースに書き込まれます:

ダイナミックスキーマの定義とマッピングの詳細は、Studio Talendユーザーガイドをご覧ください。

ダイナミックカラムを出力ファイルに書き込む方法の例は、データベースから出力ファイルにダイナミックカラムを書き込みをご覧ください。