migration de séquences postgres

Bonjour à tous,

J'ai réalisé une série de jobs qui réalisent la migration (et transformation) de tables postgres d'une instance vers une autre instance disposant d'un schéma de base différent.
Le script fonctionne parfaitement.

Le "hic" est que la plupart de mes tables utilise des auto-incréments comme clé primaires. Auto-incréments gérés par des séquences.
Du coup, il faut également que je migre l'état courant de ces séquences dans la nouvelle base sinon, les futurs inserts dans ces tables reprendront à 1 ce qui va créer des conflits lors des inserts.

Je cherche donc à migrer ces séquences. Pour cela, il faut que je récupère la valeur courante pour chaque séquence dans la base source et que j'update cette valeur courante dans la base cible.
Une idée de la solution ?

Merci par avance pour votre aide.

Je me répond à moi même.
En fait, au lieu d'essayer de récupérer la valeur des séquences dans la base source, j'ai plutôt positionné la valeur courante des séquences en prenant la plus grande valeur des id dans les tables.

Pour ce faire, j'ai utilisé le job suivant :

Pièce jointe 228733

Dans mon tPostgresInput, j'exécute la requête suivante :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

"SELECT 'SELECT SETVAL(' || quote_literal(quote_ident(PGT.schemaname) || '.' || quote_ident(S.relname)) || ', COALESCE(MAX(' ||quote_ident(C.attname)|| '), 1) ) FROM ' || quote_ident(PGT.schemaname)|| '.'||quote_ident(T.relname)|| ';' as querysequence FROM pg_class AS S, pg_depend AS D, pg_class AS T, pg_attribute AS C, pg_tables AS PGT WHERE S.relkind = 'S' AND S.oid = D.objid AND D.refobjid = T.oid AND D.refobjid = C.attrelid AND D.refobjsubid = C.attnum AND T.relname = PGT.tablename ORDER BY S.relname;"

---

Elle permet de créer des requetes qui vont positionner la valeur de chaque séquence à la valeur max pour chaque id auto-incrément.

Ensuite, j'utilise un tFlowIterate pour positionner une variable globale qui va contenir la requête à exécuter.
Enfin, j'utilise un tPostgresFlow qui dans la query va juste contenir "(String)globalMap.get("querysequence")"

Le job va donc itérer sur chaque requête créée et l'exécuter. Et ainsi, mes valeurs de séquences seront mises à jour avec la bonne valeur.
Attention : Cette méthode ne fonctionne que pour les séquences qui sont rattachées à une table.