Procédure
-
Cliquez sur l'onglet Validation Rules dans la vue Component du composant tMysqlOutput.
-
Cochez la case Use an existing validation rule pour appliquer la règle de validation au composant.
-
Dans la liste Validation Rule Type, sélectionnez Repository et cliquez sur le bouton [...] pour sélectionner la règle de validation dans la boîte de dialogue [Repository Content].
-
Cliquez-droit sur le tMysqlOutput, sélectionnez dans le menu et glissez jusqu'au tLogRow pour créer un lien de rejet entre les deux composants.
Si vous avez activé l'option Reject link pour cette règle de validation, vous pouvez récupérer les données rejetées dans un flux de rejet.
-
Double-cliquez sur le composant tJava afin d'afficher ses paramètres (Basic settings).
-
Dans le champ Code, saisissez le code qui affichera le nombre de lignes traitées mises à jour, insérées et rejetées :
System.out.println("Updates: "+((Integer)globalMap.get("tMysqlOutput_1_NB_LINE_UPDATED"))+"\nInserts:
"+((Integer)globalMap.get("tMysqlOutput_1_NB_LINE_INSERTED"))+"\nRejects:
"+((Integer)globalMap.get("tLogRow_1_NB_LINE")));
-
Sauvegardez votre Job et appuyez sur F6 pour l'exécuter.
Résultats
Les données valides sont insérées ou mises à jour dans la table de la base de données et la console affiche les lignes rejetées par la règle de validation, ainsi que le nombre de mises à jour, d'insertions et de rejets traités dans le Job.
