リジェクトリンクを使用してエラーデータを取得する
このシナリオでは、顧客ファイルからMySQLデータベーステーブルへの移行を実行し、[Reject] (リジェクト)リンクを使用してエラーデータをCSVファイルにリダイレクトする、コンポーネント4つのジョブについて説明します。
-
移行する顧客ファイルメタデータを[Repository] (リポジトリー)で選択し、ワークスペースにドロップします。[Components] (コンポーネント)ダイアログボックスでtFileInputDelimitedを選択し、[OK]をクリックします。コンポーネントプロパティが自動的に入力されます。
-
顧客ファイルに関する情報を [Repository] (リポジトリー)の[Metadata] (メタデータ)ノードの下に保存していない場合には、tFileInputDelimitedコンポーネントをファミリー[File] (ファイル) > [Input] (入力)から[Palette] (パレット)にドロップし、そのプロパティを[Component] (コンポーネント)タブに手動で入力します。
-
[Palette] (パレット)で、tMapを[Processing] (処理中)ファミリーからワークスペースにドロップします。
-
[Repository] (リポジトリー)で[Metadata] (メタデータ)ノード、次に[Db Connections] (データベース接続)ノードを展開し、必要な接続を選択してデータを目的のデータベースに移行します。ワークスペースにドロップします。[Components] (コンポーネント)ダイアログボックスでtMysqlOutputを選択し、[OK]をクリックします。データベース接続のプロパティが自動的に入力されます。
-
データベース接続の詳細を[Repository] (リポジトリー)の[Db Connections] (データベース接続)ノードの下に保存していない場合は、tMysqlOutputを[Databases] (データベース)ファミリーから[Palette] (パレット)にドロップし、[Component] (コンポーネント)タブにプロパティを手動で入力します。
詳細は、データベースメタデータを一元管理をご覧ください。
-
[Palette] (パレット)で、[File] (ファイル) > [Output] (出力)ファミリーからtFileOutputDelimited を選択し、ワークスペースにドロップします。
-
[customers] (顧客)コンポーネントをtMapコンポーネントにリンクし、[Row Main] (行メイン)リンクでtMapとLocalhostをリンクします。この2番目のリンクにoutという名前を付けます。
-
[Row] (行) > [Reject] (リジェクト)リンクを使用して、LocalhostをtFileOutputDelimitedにリンクします。
-
[customers] (顧客)コンポーネントをダブルクリックして、[Component] (コンポーネント)ビューを開きます。
-
[Property Type] (プロパティタイプ)リストで[Repository] (リポジトリー)を選択し、[...]ボタンをクリックして、ファイルへの接続を含むメタデータを選択します。[Built-in] (組み込み)モードを選択してフィールドに手動で入力することもできます。
-
[File Name] (ファイル名)フィールドの横にある[...]ボタンをクリックし、使用するファイルのパスと名前を入力します。
-
[Row] (行)フィールドおよび[Field Separator] (フィールド区切り)フィールドで、逆コンマの間にファイルで使用する行とフィールド区切りを入力します。
-
[Header] (ヘッダー)、[Footer] (フッター)、[Limit] (制限)の各フィールドに、無視するヘッダーとフッターの数と、処理をそこまでに制限する上限の行数を入力します。
-
[Repository] (リポジトリー)の[Metadata] (メタデータ)ノードの下に保存されている場合は、[Schema] (スキーマ)リストで[Repository] (リポジトリー)を選択し、[...]ボタンを選択して、ファイルのスキーマを選択します。[Edit schema] (スキーマを編集)フィールドの横にある[...]ボタンをクリックし、スキーマを手動で設定することもできます。
スキーマは次のとおりです。
-
tMapコンポーネントをダブルクリックして、そのエディターを開きます。
-
左側のテーブルで、id、CustomerName、CustomerAddress、idSate、id2、RegTime、およびRegisterTimeの各カラムを選択し、右側のoutテーブルにドロップします。
-
[Schema editor] (スキーマエディター)エリアのtMapエディターの下部にある右側のテーブルで、エラーの発生するCustomerNameカラムの長さを28に変更します。このように設定することで、長さが28文字を超えるデータはエラーを発生させます。エラーは[Reject] (リジェクト)リンクで取得できます。
-
[OK]をクリックします。
-
ワークスペースで出力Localhostコンポーネントをダブルクリックし、その[Component] (コンポーネント)ビューを表示します。
-
[Property Type] (プロパティタイプ) リストで[Repository] (リポジトリー)を選択し、[...]ボタンをクリックして、データベースメタデータへの接続を選択します。接続の詳細が自動的に入力されます。[Built-in] (組み込み)モードを選択してフィールドを手動で設定することもできます。
-
[Table] (テーブル)フィールドに、作成するテーブルの名前を入力します。このシナリオではcustomers_dataという名前にしています。
-
[Action on data] (データでのアクション)リストで、[Create table] (テーブルの作成)オプションを選択します。
-
[Sync columns] (カラムを同期)ボタンをクリックして、先行コンポーネントからスキーマを取得します。
-
[Die on error] (エラー発生時に強制終了)チェックボックスは必ずオフにしておきます。これは、作成したエラーによってジョブの実行が妨げられないようにするためです。
-
[Component] (コンポーネント)ビューの[Advanced settings] (詳細設定) タブをクリックして、コンポーネントの詳細パラメーターを設定するために使われます。
-
行を一括で挿入するための[Extend Insert] (挿入の拡張)チェックボックスはオフにします。このオプションが[Reject] (リジェクト)リンクには対応していないためです。
-
tFileOutputDelimited コンポーネントをダブルクリックして、[Component] (コンポーネント)ビューでそのプロパティを設定するために使われます。
-
[File name/Stream] (ファイル名/ストリーム)フィールドの横にある[...]ボタンをクリックし、出力ファイルのパスと名前を入力します。
-
[Sync columns] (カラムを同期)ボタンをクリックし、前のコンポーネントのスキーマを取得します。
-
ジョブを保存し、F6を押して実行します。
エラーのあるデータがエラータイプと共に区切り付きファイルに送信されます。ここで[Data truncation] (データの切り捨て)が表示されます。