tMysqlLastInsertIdで最後に挿入したレコードのIDの取得

以下のJavaシナリオでは、Mysqlデータベースへの接続を開き、定義済みのデータをデータベースに書き込み、最終的に既存の接続で最後に挿入されたIDをフェッチするジョブを作成します。

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

[Palette] (パレット)から、tMysqlConnection、tMysqlCommit、tFileInputDelimited、tMysqlOutput、tMysqlLastInsertId、tLogRowというコンポーネントをデザインワークスペースにドロップします:
[On Subjob Ok] (サブジョブがOKの場合)リンクを使って、tMysqlConnectionをtFileInputDelimited に接続させます。
[On Subjob Ok] (サブジョブがOKの場合)リンクを使って、tFileInputDelimitedをtMysqlCommitに接続させます。
[Row Main] (行>メイン)リンクを使用して、tFileInputdelimitedを他の3つのコンポーネントに接続します。

デザインワークスペースでtMysqlConnectionを選択します。
[Component] (コンポーネント)タブをクリックして、tMysqlConnectionの基本設定を定義します。
[Basic settings] (基本設定)ビューで、接続の詳細を手動で設定します。メタデータデータベース接続エントリーとしてローカルに保存した場合は、コンテキスト変数リストから選択し、Ctrl + スペースを使って対応するフィールドをクリックします。メタデータの詳細は、Talend Studioユーザーガイドをご覧ください。

処理されたファイルへのパスを[File Name] (ファイル名)フィールドに入力します。このサンプルで使用しているファイルはCustomersです。
行末を識別できる[Row separator] (行区切り)を定義します。行内のフィールドの区切りに使用する[Field separator] (フィールド区切り)を定義します。
必要に応じて、ヘッダー、フッター、処理される行数を設定するために使われます。このシナリオでは、ヘッダーは1つです。
[Edit Schema] (スキーマを編集)の横にある[...]ボタンをクリックして、次のコンポーネントに渡すデータを定義します。

関連項目: Talend Studioユーザーガイドをご覧ください。

このシナリオでは、スキーマはnameおよびageという2つのカラムで構成されています。前者には従業員3人の名前、後者にはそれぞれの対応する年齢が保存されています。

[Use an existing] (既存の接続を使用)チェックボックスをオンにします。
[Table] (テーブル)フィールドで、従業員のリストを書き込むテーブルの名前を入力します。このサンプルではemployeeです。
[Action on table] (テーブルでのアクション)リストおよび[Action on data] (データでのアクション)リストで、該当するアクションを選択します。このサンプルでは、テーブルでのアクションはなく、データでのアクションはInsertです。
[Sync columns] (カラムを同期)をクリックして、カラムを前のコンポーネントと同期します。この例では、MySqlデータベーステーブルに挿入するスキーマは、nameおよびageという2つのカラムで構成されています。

複数の接続を使用している場合は、[Component List] (コンポーネントリスト)で該当するtMysqlConnectionを選択します。
[Sync columns] (カラムを同期)をクリックして、カラムを前のコンポーネントと同期します。tMysqlLastInsertIdの出力スキーマで、既存の接続に最後に挿入されたIDを取得する読み取り専用のカラムlast_insert_idを確認できます。

エントリー数が非常に多い場合は、[Type] (タイプ)ドロップダウンリストからデータ型Longを選択できます。

デザインワークスペースで、tLogRowを選択して、[Component] (コンポーネント)タブをクリックし、基本設定を定義します。詳細は、tLogRowをご覧ください。
ジョブを保存し、F6を押して実行します。

tMysqlLastInsertIdは、既存の接続の各行に、最後に挿入したIDを取得しました。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。