Discussion :

[b1510]

Bonjour à tous,
J'ai un job qui fonctionne avec le composant tOracleOutputBulkExec. Le job utilise donc sql loader. Une fois mon job fini, j'ai un message de ce style dans la console de Talend:
"Point de validation (COMMIT) atteint - nombre d'enregis. logiques 7"
Et un code de sortie 0.
Parfait, sauf que mes 7 enregistrements ne se sont pas si bien passé que ca puisque en fait j'ai 7 erreurs de ce genre :
"ORA-00001: violation de contrainte unique".
Je peux lire ces erreurs en allant visualiser le fichier "monfichier.ctl.log" que génère sql loader.
Ma question : Quelle est la meilleure façon de récupérer les erreurs présente dans le fichier que génère sql loader (monfichier.ctl.log) à la fin de l'insert puis de les envoyer au tLogCatcher pour qu'elles s'affichent de la même façon que toutes les autres erreurs de mes jobs ?

PS : J'utilise Java 1.5.0_22

[l4r3nZu]

Je n'ai pas testé mais ton composant te retourne cette globalVar : ((String)globalMap.get("tMysqlBulkExec_1_ERROR_MESSAGE"))

A tester ...

Bon courage

[b1510]

Malheureusement, un

Code :

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

System.out.println("tMysqlBulkExec_1_ERROR_MESSAGE="+((String)globalMap.get("tMysqlBulkExec_1_ERROR_MESSAGE")));

renvoie un :
tMysqlBulkExec_1_ERROR_MESSAGE=null

Alors qu'il y a bien eu des erreurs d'insert avec Sql Loader

[haskouse]

Pourquoi tu ne lis pas "monfichier.ctl.log" avec un tFileInput tout simplement.

[b1510]

Je vous présente ma solution (sans tFileInput, j'ai vu le message bien après ) :
J'ai utilisé un composant tJava avec ce code (simplifié) :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
 
java.util.Scanner scanner = new java.util.Scanner(new java.io.FileReader(context.MONFIC +".ctl.log"));
String line = null;
Integer errorSqlLoader = 0;
while (scanner.hasNextLine()) {
	line = scanner.nextLine();
	if (line.matches(".*ORA-.*")){
		errorSqlLoader++;
	}
}
 
globalMap.put("errorSqlLoader",errorSqlLoader);

Puis un If entre le tJava et le tWarn qui sera catché par le tLog avec ce code :

Code :

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

1
2
 
((Integer)globalMap.get("errorSqlLoader")) != 0

C'est pas parfait, mais ca fonctionne. Si ça peut aider quelqu'un.