メイン コンテンツをスキップする 補完的コンテンツへスキップ

コンポーネントの設定

手順

  1. tFileRowCountをダブルクリックして、[Basic settings] (基本設定)ビューを開きます。
  2. [File name] (ファイル名)フィールドで、入力ファイルへのパスを入力します。[...]ボタンをクリックして、このファイルを参照することもできます。
    [Ignore empty rows] (空の行を無視)チェックボックスをオンにします。
  3. tJavaをダブルクリックして、[Basic settings] (基本設定)ビューを開きます。
    [Code] (コード)ボックスに、ファイル内の行数を出力するファンクションを入力します。
    System.out.println(globalMap.get("tFileRowCount_1_COUNT"));
  4. ifトリガーコンポーネントをクリックして、[Basic settings] (基本設定)ビューを開きます。
    [Condition] (条件)ボックスに、行数が2であるかどうかを判断する文を入力します。
    ((Integer)globalMap.get("tFileRowCount_1_COUNT"))==2
    このifトリガーは、行数が2の場合、.txtファイルの行がMySQLに書き込まれることを意味します。
  5. tFlieInputDelimitedをダブルクリックして[Basic settings] (基本設定)ビューを開きます。
    [File name/Stream] (ファイル名/ストリーム)フィールドで、.txtファイルへの完全パスを入力します。[...]ボタンをクリックして、このファイルを参照することもできます。
  6. [Edit schema] (スキーマを編集)をクリックし、スキーマエディターを開きます。
  7. [+]ボタンをクリックすると、整数型と文字列型の2つのカラム、つまりIDとnameが追加されます。
  8. ポップアップボックスの[Yes] (はい)ボタンをクリックして、スキーマ設定を次のコンポーネントにプロパゲートします。
  9. tMysqlOutputをダブルクリックして、[Basic settings] (基本設定)ビューを開きます。
  10. [Host] (ホスト)と[Port] (ポート)フィールドに、接続の詳細を入力します。
    [Database] (データベース)フィールドに、データベース名を入力します。
    [Username] (ユーザー名)と[Password] (パスワード)フィールドに、認証の詳細を入力します。
    [Table] (テーブル)フィールドに、テーブル名（「staff」など）を入力します。
  11. [Action on table] (テーブルのアクション)リストで、[Create table if not exists] (テーブルが存在しない場合は作成)を選択します。
    [Action on data] (データでのアクション)リストで、[Insert] (挿入)を選択します。

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

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

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