Série de UPDATE sur une table [Résolu]

[briochette38]

Bonjour,

Je cherche à faire une série de UPDATE sur ma table QB_INDEX.
Je voudrais obtenir l'équivalent du script suivant :

Code :

1
2
3
4
UPDATE qb_index i SET i.r_part2 = (SELECT  colname FROM dpt_syscolumns s 		WHERE  s.dpt_syscolumns.tabname = i.tabname 			AND s.colno = i.r_part2			AND i.departement = s.departement) WHERE i.r_part2 != 0
UPDATE qb_index i SET i.d_part2 = (SELECT  colname FROM dpt_syscolumns s 		WHERE  s.dpt_syscolumns.tabname = i.tabname 			AND s.colno = i.d_part2			AND i.departement = s.departement) WHERE i.d_part2 != 0
UPDATE qb_index i SET i.r_part1 = (SELECT  colname FROM dpt_syscolumns s 		WHERE  s.dpt_syscolumns.tabname = i.tabname 			AND s.colno = i.r_part1			AND i.departement = s.departement) WHERE i.r_part1 != 0
UPDATE qb_index i SET i.d_part1 = (SELECT  colname FROM dpt_syscolumns s 		WHERE  s.dpt_syscolumns.tabname = i.tabname 			AND s.colno = i.d_part1			AND i.departement = s.departement) WHERE i.d_part1 != 0

J'ai créé un fichier texte qui contient la liste des champs à mettre à jour :

Code :

1
2
3
4
r_part2
d_part2
r_part1
d_part1

Et je cherche à passer mes UPDATE dans un tBaseRow avec le schéma suivant :

tFileInputDelimited-->tFlowToIterate-->tIterateToFlow-->tBaseRow-->tBaseCommit

Dans mes composant iterate, le schéma comporte un seul champ : le nom du champ à mettre à jour.
Dans mon tBaseRow, j'ai la requête suivante :

Code :

1
2
3
4
5
6
7
"UPDATE qb_index i 
SET i."+ row1.nameField+" = 
	(select  colname from dpt_syscolumns s 
		where  s.dpt_syscolumns.tabname = i.tabname 
			and s.colno = i."+row1.nameField+" 
			and i.departement = s.departement) 
WHERE i."+row1.nameField+" != 0"

Quand j'exécute j'ai l'erreur "A syntax error has occurred." à chaque itération.

J'ai contrôlé la construction de mes requêtes UPDATE avec un tMap+tLogRow à la place de mon tBaseRow et mes requêtes sont bonnes.

Quelqu'un voit-il pourquoi ?

Auriez-vous une autre idée (d'autres composants Talend peut-être) pour faire la même chose ?

Merci pour votre aide, mon problème est assez urgent.
Corinne

[haskouse]

Bonjour,

Quand tu as récupéré le texte de ta requête, est ce que tu l'as testé directement sur ta base ??
Est ce que ça a marché ?

[briochette38]

Oups en effet j'ai introduit une erreur de syntaxe en écrivant :

Code :

UPDATE qb_index i SET i.r_part2 = (SELECT  colname FROM dpt_syscolumns s 		WHERE  s.dpt_syscolumns.tabname = i.tabname 			AND s.colno = i.r_part2			AND i.departement = s.departement) WHERE i.r_part2 != 0

au lieu de :

Code :

UPDATE qb_index SET r_part6 = (SELECT  colname FROM dpt_syscolumns WHERE  dpt_syscolumns.tabname = qb_index.tabname AND colno = qb_index.r_part6 AND qb_index.departement = dpt_syscolumns.departement) WHERE r_part6 != 0 ;

Il semble que l'alias de la table qb_index ne soit plus reconnu dans le select de ma table dpt_syscolumns.

Merci pour ta remarque fort judicieuse haskouse

[haskouse]

Y'a pas de quoi
Si c'est résolu merci de mettre le fameux

Bonne chance pour la suite.