-
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] (挿入)を選択します。
[Code] (コード)ボックスに、ファイル内の行数を出力するファンクションを入力します。
[Condition] (条件)ボックスに、行数が2であるかどうかを判断する文を入力します。
[File name/Stream] (ファイル名/ストリーム)フィールドで、.txtファイルへの完全パスを入力します。[...]ボタンをクリックして、このファイルを参照することもできます。
