Discussion :

[a.BIntelligence]

Bonjour à tous,

j'ai un petit problème avec mes jobs Talend. (job père et plusieurs jobs fils)
contexte : J’ai une base de données (mysql) qui contient plusieurs tables.
Dans Talend je crée plusieurs jobs (fils) qui ont la même structure décrite ci-dessous.
1er partie : tMysqlInput (requete pour sélectionner le nom du site + pays) -> tMap_1 (concaténation site_pays) -> tFlowToIterate_1 (permet de stocker la valeur de la requête concaténée « identifiant_site »
2ième partie : tMysqlInput (select * from table_name) -> tMap_2 (je reprends toutes les colonnes de ma table et j'ajoute une variable dans une colonne appelée « id_site » -> et j'écris dans un fichier ma nouvelle table
voici ma variable dans mon tMAp_2 : String.valueOf(Numeric.sequence("s1",1,1))+"_"+((String)globalMap.get("identifiant_site"))

Chaque job fils exécuté séparément fonctionne correctement.

Mon problème survient dans mon job père qui contient les jobs fils.
Je m’aperçois que l’id auto généré de chaque job n’est pas propre à sa table.
Le résultat est table_1 id_site va de 1 à 10
La table_2 son id_site va de 11 à 30 et ainsi de suite.
Hors moi je voudrais que chaque table soit un id auto généré unique à sa table. (j'ai essayé d'ajouter dans ma variable le nom de la table :String.valueOf(Numeric.sequence("s1",1,1))+"_"+((String)globalMap.get("identifiant_site"))+"_table_name" pour voir si c'était la cause du problème mais non)

Je joins deux exemples de mes jobs.

j'ai une seconde question concernant ce type de job. Y-a-t-il une limite de job fils a ne pas dépasser dans un job père ? (version libre)

Je vous remercie pour votre aide !!! Merci.

[NFHnv]

Bonjour,

Je ne sais pas si je vais répondre exactement à ta question ....mais si tu crées une séquence séparée pour chaque table table_1 et table_2 alors tu auras ce que tu veux.
Crées dans ta base de données, deux séquences. Puis sous Talend , dans "Requêtes" tu crées deux requêtes portant les mêmes noms que les séquences crées.
Ces requêtes sont alors de la forme: select toto.nextval from dual.
Dans un job, tu utilises alors un tmap où tu mets pour la table_1 la requête correspondante ( en mettant recharger à chaque fois) et le résultat tu l'envoies dans ton id.
Voilà,

NFHnv