基本的な検証ルールを使用

検証ルールを設定したら、そのルールをジョブデザインに適用できます。ここでは例として、データベーステーブルを読み取る際に正しい値かどうかをチェックする、基本的な検証ルールを使用します。このシナリオは、Talend Studioユーザーガイドの[Basic rule] (基本ルール)セクションで作成された基本チェック検証ルールに基づいています。

基本検証ルール用にジョブ環境を設定

Procedure

[Palette] (パレット)からデザインワークスペースに、次のコンポーネントを配置します: データベース入力コンポーネント(ここではtMysqlInputで、値を読み取ってチェックする)、2つのtFileOutputDelimitedコンポーネント(有効なデータを1つのファイルに抽出し、リジェクトされたデータを別のファイルに抽出する)、tJavaコンポーネント(処理された行の数をコンソールに表示する)。
[Row] (行) > [Main] (メイン)接続を使って入力データベースコンポーネントを最初のtFileOutputDelimitedコンポーネントに接続し、[Trigger] (トリガー) > [OnSubjobOk]接続を使って、tMysqlInputコンポーネントをtJavaコンポーネントに接続します。

情報メモNote:
tMysqlInputコンポーネントに検証ルールを適用する場合のみ、tMysqlInputコンポーネントと2番目のtFileOutputDelimitedコンポーネントとの間にリジェクトリンクを作成できます。

tMysqlInputを設定

Procedure

tMysqlInputコンポーネントをダブルクリックし、[Basic settings] (基本設定)を開きます。
[Property type] (プロパティタイプ)として[Repository] (リポジトリー)を選択し、フィールドの横にある[...]ボタンをクリックして、確認するメタデータに対応する接続のプロパティを取得します。
[Schema] (スキーマ)ドロップダウンリストから[Repository] (リポジトリー)を選択し、フィールドの横にある[...]ボタンをクリックして、データベーステーブルに対応するスキーマを取得します。
[Table] (テーブル)フィールドの横にある[...]ボタンをクリックし、確認するテーブルを選択します。
[Guess Query] (クエリーを推測)をクリックし、テーブルスキーマに対応するクエリーを自動的に取得します。

検証ルールを適用してリジェクトリンクを作成

この検証ルールには[On select] (選択時)オプションを選択したので、検証ルールは入力コンポーネントに適用する必要があります。

Procedure

tMysqlInputの[Component] (コンポーネント)ビューで[Validation Rules] (検証ルール)タブをクリックします。
[Use an existing validation rule] (既存の検証ルールを使用)チェックボックスをオンにし、コンポーネントに検証ルールを適用します。
[Validation Rule Type] (検証ルールタイプ)リストで[Repository] (リポジトリー)を選択し、[...]ボタンをクリックして、[Repository Content] (リポジトリーコンテンツ)ウィンドウで検証ルールを選択します。
tMysqlInputコンポーネントを右クリックし、メニューで[Row] (行) > [Rejects] (リジェクト)の順に選択し、このコンポーネントを2番目のtFileOutputDelimitedコンポーネントにドラッグして、この2つのコンポーネントの間にリジェクトリンクを作成します。

この検証ルールで[Reject link] (リジェクトリンク)オプションを有効にしている場合、リジェクトされたデータを取得して、リジェクトフローに流すことができます。

出力コンポーネントを設定してジョブ実行結果を表示

Procedure

tFileOutputDelimitedコンポーネントをダブルクリックし、[Basic settings] (基本設定)を開きます。
[File Name] (ファイル名)フィールドに、有効なデータを書き込むファイルのパスと名前を指定します。
該当するフィールドに、行とフィールドの区切りを定義します。
[Include Header] (ヘッダーを含める)チェックボックスをオンにして、出力データにカラムヘッダーを含めます。
2番目のtFileOutputDelimitedコンポーネントに前述のステップを繰り返し、リジェクトされたデータの出力を設定します。
tJavaコンポーネントをダブルクリックし、[Basic settings] (基本設定)を開きます。

[Code] (コード)フィールドには、アップデート行数、挿入行数、リジェクト行数を表示するコードを入力します。

System.out.println("Valid data: "+((Integer)globalMap.get("tFileOutputDelimited_1_NB_LINE"))+"\nRejected
data: "+((Integer)globalMap.get("tFileOutputDelimited_2_NB_LINE")));

ジョブを保存し、F6を押して実行します。

Results

有効なデータが最初の区切り付きファイルに出力され、リジェクトされたデータが2つの目の区切り付きファイルに出力されます。コンソールには、ジョブで処理された有効な行の数、およびリジェクト回数が表示されます。

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

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

こちらにフィードバックをお寄せください