このシナリオでは、準備されたステートメントに基き、区切り付きファイルを使って、SQLiteデータベースファイルをアップデートするジョブについて説明します。
Talendがサポートしているテクノロジーの詳細は、Talendコンポーネントをご覧ください。
-
コンポーネントtFileInputDelimitedとtSQLiteRowを[Palette] (パレット)からデザインワークスペースにドロップします。
-
tFileInputDelimitedの[Basic settings] (基本設定)パネルで、データベースの行のアップデートに使う入力ファイルを参照します。
-
[Header] (ヘッダー)も[Footer] (フッター)もありません。[Row separator] (行区切り)はキャリッジリターンで、[Field separator] (フィールド区切り)はセミコロンです。
-
[Edit schema] (スキーマを編集)の横にある[...]ボタンをクリックして、スキーマストラクチャーが[Repository] (リポジトリー)に保管されていない場合は、スキーマストラクチャーを定義します。
-
長さとタイプがそれぞれ正しく、カラムを定義するのに十分な大きさであることを確認します。
-
次に、tSQLiteRowの[Basic settings] (基本設定)パネルで、アップデートするファイルに[Database] (データベース)ファイルパスを設定するために使われます。
-
入力スキーマと一致させる必要があるため、スキーマは読み取り専用です。
-
クエリーを入力するか、リポジトリーから取得します。このユースケースでは、type_osを入力フローで定義されたidに合わせてアップデートしました。ステートメントは次のとおりです:
"Update download set type_os=? where id=?" -
次に、[Use PreparedStatement] (PreparedStatementを使う)チェックボックスをオンにして、プレースホルダーのパラメーターテーブルを表示します。
-
入力パラメーターテーブルに、すべてのプレースホルダーをカバーするために必要な数の行を追加します。このシナリオでは、type_osとidを定義します。
-
[Commit every] (コミットする間隔)フィールドを設定するために使われます。
-
ジョブを保存し、[F6]を押して実行します。
これで、SQLiteデータベースからのdownloadテーブルが、区切り付き入力ファイルに従って新しいtype_osコードでアップデートされました。