Discussion :

[WC2007]

Bonjour,

Je souhaiterais savoir comment avec 2 tMSSqlInput arriver au schéma suivant:
pour chaque n-uplet du 1er tMSSqlInput, le 2e tMSSqlInput génère une requête qui dépend du n-uplet

Exemple:
tMSSqlInput1
select salesId as salesIdInput1 from salesTable

tMSSqlInput2
Pour chaque salesId de tMySqlInput1 générer une requête du type:
select lineNum from salesLine where salesId = salesIdInput1

Merci

[smallet]

L'idée est d'utiliser les liens 'iterate'
Ton job devrait ressembler à ça :
tMysqlInput1 -> tFlowToIterate -> tMysqlInput2

Je te renvois à la doc du tFlowToIterate pour savoir comment récupérer la valeur actuelle de tMysqlInput1 dans le tMysqlInput2

Dit moi si tu as besoin de plus d'infos

[co2]

Bonjour WC2007,

Est-ce que la réponse de smallet te satisfait?
Si OUI, merci de mettre résolu à ton thread, si NON indique nous ce qui ne va pas!
Merci

[WC2007]

Merci pour ta réponse smallet,

Néanmoins, je souhaiterais également dans un deuxième temps pouvoir utiliser les flux tMSSqlInput1 et tMSSqlInput2 dans un tMap avec une jointure. Il me semble qu'avec la méthode que tu m'as donné ceci n'est pas possible.

En fait, si on reprend l'exemple, je souhaiterais obtenir quelque chose de similaire à la requête:
select tMSSqlInput1.*, tMSSqlInput2.* from tMSSqlInput1, tMSSqlInput2 where tMSSqlInput2.salesId = salesIdInput1
mais ceci à partir de talend.

[Marcsup]

L'idée est d'utiliser les liens 'iterate'
Ton job devrait ressembler à ça :
tMysqlInput1 -> tFlowToIterate -> tMysqlInput2

Je te renvois à la doc du tFlowToIterate pour savoir comment récupérer la valeur actuelle de tMysqlInput1 dans le tMysqlInput2

Dit moi si tu as besoin de plus d'infos

Bonjour,

J'ai exactement le même besoin en avec une base postgreSQL, et je fouille depuis ce matin ce forum pour trouver une solution. Ce sujet est le plus proche de mon soucis, je crois.
Je m'en suis inspiré et j'ai tenté d'utiliser une chaîne de ce genre :
tPostgresqlInput_1 -> tFlowToIterate_1 -> tPostgresqlInput_2 -> tPostgresqloutput_1

J'essaye en fait de lire dans une première table d'une première BDD un ensemble d'identifiant de personne (tPostgresqlInput_1) puis de lire dans une deuxième table d'une deuxième BDD des informations sur ces personnes avec mon tPostgresqlInput_2 en lui précisant une clause du genre where Id_personne = (Iterate.Id_personne) pour ensuite les stocker dans une table de mon entrepôt (tPostgresqloutput_1)

Le but est d'éviter de remonter l'ensemble de la table 2 située dans la BDD 2, qui contient un très grand nombre de ligne, alors que l'on en a besoin que d'une centaine lié à une dizaine de personnes situées dans la table, BDD 1.
(J'espère que je ne suis pas trop vague )


Seulement, je n'ai pas compris la documentation du tFlowToIterate_1 pour savoir ce que je dois réellement mettre à la place de mon (Iterate.Id_personne) pour que cela fonctionne.

Je vous remercie d'avance pour votre aide.