データインポートの設定
手順
-
tFileInputDelimitedコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
-
[File name/Stream] (ファイル名/ストリーム)フィールドで、読み取る従業員データが保存されているCSVファイルへのパスを指定します。
この例に使用している入力CSVファイルは、次のとおりです。
employeeID;employeeName;age;hireDate;salary;managerID 1;Rutherford Roosevelt;38;06-10-2008;13336.58;m5 2;Warren Adams;43;05-22-2008;11626.68;m6 3;Andrew Roosevelt;55;04-01-2007;10052.95;m4 4;Herbert Quincy;54;06-14-2007;10694.71;m6 5;Woodrow Polk;33;08-14-2007;13751.50;m4 6;Theodore Johnson;47;01-26-2008;12426.87;m6 7;Benjamin Adams;32;02-25-2008;10438.65;m4 8;Woodrow Harrison;51;10-11-2008;11188.27;m5 9;George Truman;40;04-28-2008;14254.49;m5 10;Harry Jackson;38;04-01-2008;12798.78;m6
- [Header] (ヘッダー)フィールドで、ヘッダー行としてスキップする行数を指定します。この例では、CSVファイルの最初の行がヘッダー行です。
-
[Edit schema] (スキーマを編集)の横にある[...]ボタンをクリックして[Schema] (スキーマ)ダイアログボックスを開き、入力ファイルのストラクチャーをベースに入力スキーマを定義します。この例では、入力スキーマは次の6つのカラムで構成されています: employeeID (整数)、employeeName (文字列)、age (整数)、hireDate (日付)、salary (倍数)、およびmanagerID (文字列)。
終了したら[OK]をクリックして[Schema] (スキーマ)ダイアログボックスを閉じ、スキーマを次のコンポーネントにプロパゲートします。
-
tNeo4jRowコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
- [Use an existing connection] (既存の接続を使用)チェックボックスをオンにし、tNeo4jConnectionコンポーネントによって開かれたNeo4jデータベース接続を再利用します。このコンポーネントは、この例で使用している唯一の接続コンポーネントです。
-
コンポーネントで実行するCypherクエリーを[Query] (クエリー)フィールドに入力します。
この例では、入力フローからのデータを保存するために、次のクエリーを入力して、ラベルがEmployeesで6つのプロパティがあるノードを作成します。
-
ID。変数パラメーターidの値を取ります。
-
Name。変数パラメーターnameの値を取ります。
-
Age。変数パラメーターageの値を取ります。
-
HireDate。変数パラメーターhire_dateの値を取ります。
-
Salary。変数パラメーターsalaryの値を取ります。
-
ManagerID。変数パラメーターmanager_idの値を取ります。
"CREATE (n:Employees{ID:{id}, Name:{name}, Age:{age}, HireDate:{hire_date}, Salary:{salary}, ManagerID:{manager_id}})"
-
-
[Parameters] (パラメーター)テーブルの[Parameter] (パラメーター)フィールドに、Cypherクエリーに従って変数パラメーターを入力し、[Parameter value] (パラメーター値)リストフィールドから選択することで、それぞれを入力スキーマカラムにマッピングします。