Discussion :

[jj4822]

Bonjour.

Je cherche a ne lancer un job Talend que si une table MySQL n'est pas vide. Si cette table Mysql est vide, on ne lance rien.

J'ai essaye avec un tJava. Problemes :

- je ne maitrise pas java et ce que j'ai ecrit est rejete par Talend
- je suis, sauf erreur de ma part, oblige de definir un fichier bat a executer et le repertoire ou il se trouve. Je cherche plutot a pouvoir lancer le 2eme job en etant directement dans Talend sans l'exporter, dezipper les fichiers, et les copier a un autre endroit designe dans le tJava.

Un tRunJob ne semble pas convenir, je n'ai pas trouve le moyen d'y inclure une condition (si table Mysql non vide, lance le job intel, sinon ne lance rien).

Est-il possible de faire ce genre de choses dans Talend ?

Merci,
Cdlt

[kayim]

Hello tu peux faire un :

tMysqlInput--------main---tSetGlobalVar
|
IF
|
tRunJob

Dans ton tMysqlInput, tu calcul le nombre de lignes "Select count(*) from ma_table" et le résultat est injecté dans le tSetGlobalVar
Dans ton trigger IF, tu testes, si la valeur est >0 au quel cas le job du tRunJob est exécuté

[emenuet]

Bonjour,

Tu peux utiliser les composants suivant :

tWaitForSqlData -- iterate --> tRunjob


tu paramètres le tWaitForSqlData "greater than" "0" et "exit loop", dans la partie avancé du composant tu peux même faire ta propre requête.

[jj4822]

Bonjour.

Merci pour ces reponses.

J'ai d'abord essaye :

tWaitForSqlData -- iterate --> tRunjob

Probleme : il est obligatoire de definir une "Connection list". L'option "Use an existing connection" est selectionnee et grisee. Je ne peux pas la deselectionner. De plus, le champ a cote de "Connection list" est vide.

Lorsque je lance le job, Talend m'affiche une fenetre d'erreur et m'indique pour tWaitForSqlData : "Parameter (Connection list) is empty but is required".


J'ai ensuite essaye :

tMysqlInput--------main---tSetGlobalVar
|
IF
|
tRunJob

Dans le tMysqlInput j'ai relie a ma base Mysql et j'ai, comme requete sql : "SELECT COUNT(*) FROM ma_table WHERE Nr_soc=960"
Dans le tSetGlobalVar, je n'ai pas vu quoi mettre, j'ai donc dans les champs Key et Value la meme valeur : "COUNT(*)". J'ai mis cette valeur car, lorsque je lance la requete sql dans Mysql, j'obtient, comme nom de champ : "COUNT(*)"
Dans le IF j'ai essaye avec "COUNT(*)<>0" puis avec "<>0"
Dans le tRunJob j'ai le nom du job a lancer.

Lorsque je lance le job, Talend m'affiche une fenetre d'erreur m'indiquant :
"General" : Type mismatch: cannot convert from String to boolean
"tMysqlInput" : No schema has been defined yet

Ces deux erreurs sont signalees quelque soit le contenu du IF.

Cdlt.

[emenuet]

Pour tes erreurs :

pour le "Use an existing connection", il suffit de poser au début du job le composant tMysqlConnection qui permet d'ouvrir une connexion a la base et de la réutiliser. Le composant tWaitForSqlData récupère automatiquement l'information.

Pour le tSetGlobalVar, le nom de la variable doit être une constante key = "nbligne" par exemple. Et dans valeur tu récupère le nom de la colonne du schema que tu as du déclarer de type intéger value = row1.count par exemple. Les valeurs dépendent de tes paramètres.
Dans la condition du va avoir quelques chose comme cela :
(Integer)globalMap.get("nbligne") != 0


Je te conseil d'avoir le guide des composants a porté de main, il donne les informatisions de paramétrage, ainsi que des exemples d'utilisation des composants

[Chris L' Arabis]

Bonjour,
dans la solution proposée par emenuet, ajoute un composant tMysqlConnection.
Tu aura quelque chose de ce genre :

dans le composant tMysqlConnection, tu renseigne les paramètres de connexion à ta base de données.
dans le tWaitForSqlData, tu sélectionne cet élément de connexion dans le champ "Connection list".
Essaye à nouveau, ça devrait marcher !

[jj4822]

En rajoutant le tMysqlConnection, ca a fonctionne sans que je n'ai a rajouter la valeur dans Connection List du tWaitForSqlData. Talend a mis lui meme a jour.

Ca fonctionne.

J'ai essaye de modifier le job contenant le tSetGlobalVar sans succes, il y a surement quelque chose que je ne fais pas correctement. L'aide Talend ne montre que le lancement d'un tJava suite a un tSetGlobalVar. Je chercherai sur internet de plus amples infos concernant ce tSetGlobalVar. Talend me signale actuellement un probleme entre le tMysqlInput et le tSetglobalVar.

Merci pour votre aide, j'ai resolu mon probleme en utilisant l'une des solutions.

Merci.
Cdlt.

[Titou82]

Hello tu peux faire un :

tMysqlInput--------main---tSetGlobalVar
|
IF
|
tRunJob

Dans ton tMysqlInput, tu calcul le nombre de lignes "Select count(*) from ma_table" et le résultat est injecté dans le tSetGlobalVar
Dans ton trigger IF, tu testes, si la valeur est >0 au quel cas le job du tRunJob est exécuté

Je ne suis pas pro mais avec le "If" c'est la solution en effet. On peut même simplifier en enlevant le tSetGlobalVar et en utilisant directement la variable globalMap sur la condition du "If" :

((Integer)globalMap.get("tPostgresqlInput_1_NB_LINE")) != 0

Si le résultat renvoyé est différent de 0 ligne => on exécute

En espérant que ça aidera certains!