Discussion :

[paris11]

J'ai un trt qui me parait tout à fait classique mais que je n'ai jamais fait avec Talend, ça doit bien être possible.

Je balaye une table transaction mais je dois gérer un changement de transaction (plusieurs enreg par transaction) et manipuler une variable

En gros ça ressemble à ca

Balayage table transactions

Variable_Montant = 0

Tant qu'il s'agit de la même transaction (donc il faut que je teste si numéro de transaction lu est différent du précédent)

Variable_Montant = Total ( donnée du mapping en entrée) + Variable_Montant
...

Ecrire 1 ligne en sortie
Fin tant que
Variable_Montant = 0

Fin balayage de la table

[emenuet]

Bonjour,

En fait tu veux agréger ton montant par transaction ?

Donc le composant tAggregateRow est la réponse

[paris11]

Non j'ai du mal m'expliquer.
Je ne veux pas agréger, j 'ai n lignes par transaction en entrée et n lignes pareillement en sortie.

Par contre je dois alimenter une zone en sortie à partir d'une variable que je remets à 0 à chaque rupture de transaction.

Pour faire simple quand j'arrive à la dernière ligne de transaction , je dois alimenter une zone avec 'champ1 - Total des montants des lignes précédentes' donc je sais pas trop comment alimenter le montant des lignes précédentes dans une variable et je ne sais pas trop non plus comment gérer le changement de transaction et remettre la variable à 0

[emenuet]

Ok, c'est plus clair :

la difficulté est de détecter la dernière ligne de ta rupture, par défaut avec Talend, c'est très difficile voir impossible.

Donc voici ce que je propose :
tu télécharges mon composant sur la forge :
http://www.talendforge.org/exchange/...view&nav=1,1,1
Il permet de déterminer les clefs de rupture - il se paramètre comme un tSort, il y a juste une colonne en plus pour la clef de rupture.

Pour le calcul tu peux utiliser un tMap ou un tJavaRow.
Dans le tMap tu crées une variable de type object avec ce code :

(Integer)globalMap.get(TransactionID) == null ? globalMap.put(TransactionID, tonMontant ) : globalMap.put( TransactionID, (Integer)globalMap.get(TransactionID) + tonMontant )

TransactionID est une String a partir de ta clef de transaction.
Quand tu détecte la rupture, tu récupères la valeur (Integer)globalMap.get(TransactionID)

remarques :
Tu changes Integer en BigDecimal si cela est néccessaire.

[paris11]

la difficulté est de détecter la dernière ligne de ta rupture, par défaut avec Talend, c'est très difficile voir impossible.

--> c'est fou cela , ça fait un bout de temps que je n'ai pas programmé mais c'est un truc basique pourtant

[emenuet]

--> c'est fou cela , ça fait un bout de temps que je n'ai pas programmé mais c'est un truc basique pourtant

C'est pour cela que j'ai créé le composant. Avec le tBreakRow cela fonctionne tout seul