Configurer le deuxième sous-Job
Procédure
-
Double-cliquez sur le tFixedFlowInput_1 pour ouvrir sa vue Basic settings et procédez comme suit :
- Ouvrez l'éditeur du schéma en cliquant sur le bouton […] près de Edit schema et ajoutez les deux colonnes suivantes dans l'éditeur du schéma : name, de type String et gender de type String.
- Dans le champ Number of rows, saisissez 5.
-
Sélectionnez Use Inline Content(delimited file) et saisissez le contenu suivant dans le champ Content.
Jane;f John;m Marry;
- Laissez les valeurs par défaut des autres options.
Ce composant génère 15 enregistrements. Chacun de ces enregistrements contient deux champs : name et gender (facultatif).
-
Double-cliquez sur le tMap_1 pour ouvrir son éditeur de mapping et procédez comme suit :
-
Ajoutez trois lignes dans la table out1. Leur colonne Column est respectivement seq, lastname et age. Leur Type est respectivement Integer, String et Integer.
Vous pouvez ajouter une ligne dans la table en cliquant sur le bouton + qui se trouve sous la table.
-
Mappez la colonne name de la section row1 à la colonne name de la section out1.
Vous pouvez mapper une colonne en glissant-déposant la colonne source de la section row1 au champ Expression de la colonne cible de la section out1.
- Mappez la colonne gender de la section row1 à la colonne gender de la section out1.
- Saisissez Numeric.sequence("s1",0,1) dans le champ Expression de la colonne seq.
- Saisissez TalendDataGenerator.getLastName() dans le champ Expression de la colonne lastname.
- Saisissez Numeric.random(25,99) dans le champ Expression de la colonne age.
- Cliquez sur OK pour fermer l'éditeur de mapping.
Ce composant reçoit les informations relatives au nom et au genre depuis le tFixedFlowInput_1 et ajoute les informations supplémentaires pour créer des nœuds dans la base de données Neo4jv4, y compris le numéro de séquence, lastname et age.
-
Ajoutez trois lignes dans la table out1. Leur colonne Column est respectivement seq, lastname et age. Leur Type est respectivement Integer, String et Integer.
-
Double-cliquez sur le tNeo4jv4Output_1 pour ouvrir sa vue Basic settings et procédez comme suit :
- Cochez la case Use an existing connection et sélectionnez le composant tNeo4jv4Connection_1 dans la liste déroulante Component List.
- Cliquez sur le bouton Sync columns pour vous assurer que le schéma du composant a bien les mêmes colonnes que celui du tMap_1.
-
Sélectionnez Send data as list et saisissez rows dans Data list name.
Cette étape indique de traiter les données d'entrée comme une liste et d'attribuer un nom à cette liste (rows), pour pouvoir référencer la liste.
-
Saisissez les clauses suivantes dans le champ Query.
UNWIND $rows as row MERGE (p:Person:UpdateMe {id: row.seq} ) SET p.name = row.name, p.lastName = row.lastname, p.age = row.age, p.gender = row.gender
- Laissez les valeurs par défaut des autres options.
Cette page vous a-t-elle aidé ?
Si vous rencontrez des problèmes sur cette page ou dans son contenu – une faute de frappe, une étape manquante ou une erreur technique – faites-le-nous savoir.