Discussion :

[fetano]

Bonjour talend pro
j'ai une liste des fichiers(8 fichiers) que je voudrais l'insérer dans une table oracle
et pour controler si les tt les lignes sont inséréers pour chaque fichier, j'ai creé une autre table trace(nom_fichier, nbre_lignes_fichier,nbre_lignes_inserées)
ci-joint capture de mon travail



dans le toraclerow2 j'ai fait la premiére requete

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
"INSERT INTO  KPI.HTTP_TRACE(name, nbre_lines_file)
  values (
                   ((String)globalMap.get("tFileList_1_CURRENT_FILE")),
                   ((Integer)globalMap.get("tFileInputDelimited_1_NB_LINE"))
                 )"

et dans l toraclerow4 je voudrais faire update pour insérer le nombre de lignes insérées par le composant toracleoutput
mais quand rien ne marche
pouvez vous m'aider svp
Merci

[XxArchangexX]

Bonjour,

mais quand rien ne marche

ça n'est pas très précis pour t'aider, message d'erreur? aucun changement en base ? autres ?

Au vue de ton schéma, j'orienterai quand même vers le fait que ta colonne reste à null. C'est dû au fait que la variable des tOutput pour avoir le nombre de ligne insert ne s'actualise qu'une fois le flux changé, la donnée n'est pas disponible dans le même flux.

Il te faut donc un OnSubJobOk, puis tu peux faire le tRow pour l'update. Revenant de vacances , à valider, mais un onComponentOk devrait fonctionner le flux étant en iterate, il faut faire l'update pour chaque fichier.

[fetano]

Merci XxArchangexX,

au fait j'ai corrigé le lien iterate vers on component ok et dans toraclerow pour l'update de la table http_trace j'ai fait

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
"UPDATE   KPI.HTTP_TRACE
  SET                                                 
            'nbre_lignes_table' =" + ((Integer)globalMap.get("tOracleOutput_1_NB_LINE")) + ",
            'nbre_lignes_inser'=" + ((Integer)globalMap.get("tOracleOutput_1_NB_LINE_INSERTED")) + ",
            'nbre_lignes_rejet'=" + ((Integer)globalMap.get("tOracleOutput_1_NB_LINE_REJECTED")) + ",                                     
             'enter_date' = " + TalendDate.getCurrentDate()+"
where 
            'nom'='"+ ((String)globalMap.get("tFileList_1_CURRENT_FILE")) + "'"

mais quandd je fais run le premier composant toraclerow insère les enregistrements nom de fichier et nombre de lignes et pour le
composantd'update j'ai cet erreur :

ORA-01747: invalid user.table.column, table.column, or column specification
ORA-01747: invalid user.table.column, table.column, or column specification

pouvez vous m'aider et merci

[XxArchangexX]

Bonjour,

ça ne concerne plus Talend pour le moment, c'est une erreur côté SGBD, et je n'ai jamais travaillé avec oracle, mais il y a une erreur dans ta requête.

Essaye sans les quote (') autour des noms des champs.