レコードの数が参照値と一致する場合、MySQLにファイルを書き込む

このシナリオでは、tFileRowCountは.txtファイルのレコード数をカウントし、tJavaを介して参照値と比較します。2つの値が一致すると、.txtファイルがMySQLテーブルに書き込まれます。

.txtファイルには2つのレコードがあります。

1;andy
         2;mike

コンポーネントをリンク

Procedure

[Palette] (パレット)からtFileRowCount、tJava、tFlieInputDelimited、tMysqlOutputをデザインワークスペースにドロップします。
OnSubjobOkトリガーを使用して、tFileRowCountをtJavaにリンクします。
Run ifトリガーを使用してtJavaをtFlieInputDelimitedにリンクします。
Row > Main接続を使用して、tFlieInputDelimitedをtMysqlOutputに接続します。

コンポーネントを設定

Procedure

tFileRowCountをダブルクリックして、[Basic settings] (基本設定)ビューを開きます。
[File name] (ファイル名)フィールドで、入力ファイルへのパスを入力します。[...]ボタンをクリックして、このファイルを参照することもできます。
[Ignore empty rows] (空の行を無視)チェックボックスをオンにします。
tJavaをダブルクリックして、[Basic settings] (基本設定)ビューを開きます。

[Code] (コード)ボックスに、ファイル内の行数を出力するファンクションを入力します。
```
System.out.println(globalMap.get("tFileRowCount_1_COUNT"));
```
ifトリガーコンポーネントをクリックして、[Basic settings] (基本設定)ビューを開きます。

[Condition] (条件)ボックスに、行数が2であるかどうかを判断する文を入力します。
```
((Integer)globalMap.get("tFileRowCount_1_COUNT"))==2
```
このifトリガーは、行数が2の場合、.txtファイルの行がMySQLに書き込まれることを意味します。
tFlieInputDelimitedをダブルクリックして[Basic settings] (基本設定)ビューを開きます。

[File name/Stream] (ファイル名/ストリーム)フィールドで、.txtファイルへの完全パスを入力します。[...]ボタンをクリックして、このファイルを参照することもできます。
[Edit schema] (スキーマを編集)をクリックし、スキーマエディターを開きます。
[+]ボタンをクリックすると、整数型と文字列型の2つのカラム、つまりIDとnameが追加されます。
ポップアップボックスの[Yes] (はい)ボタンをクリックして、スキーマ設定を次のコンポーネントにプロパゲートします。
tMysqlOutputをダブルクリックして、[Basic settings] (基本設定)ビューを開きます。
[Host] (ホスト)と[Port] (ポート)フィールドに、接続の詳細を入力します。
[Database] (データベース)フィールドに、データベース名を入力します。

[Username] (ユーザー名)と[Password] (パスワード)フィールドに、認証の詳細を入力します。

[Table] (テーブル)フィールドに、テーブル名（「staff」など）を入力します。
[Action on table] (テーブルのアクション)リストで、[Create table if not exists] (テーブルが存在しない場合は作成)を選択します。
[Action on data] (データでのアクション)リストで、[Insert] (挿入)を選択します。

ジョブを実行

Procedure

Ctrl + Sを押してジョブを保存します。
[F6]を押してジョブを実行します。

上記のように、ジョブは正しく実行され、.txtファイルの行数が出力されました。
MySQL GUIに移動し、テーブル[staff] (スタッフ)を開きます。

上記のように、2つのレコードが挿入されたテーブルが作成されます。

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

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

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