Introduce "REFRESH SEQUENCES" for subscriptions. This patch adds support for a new SQL command: ALTER SUBSCRIPTION ... REFRESH SEQUENCES This command updates the sequence entries present in the pg_subscription_rel catalog table with the INIT state to trigger resynchronization.
In addition to the new command, the following subscription commands have been enhanced to automatically refresh sequence mappings: ALTER SUBSCRIPTION ... REFRESH PUBLICATION ALTER SUBSCRIPTION ... ADD PUBLICATION ALTER SUBSCRIPTION ... DROP PUBLICATION ALTER SUBSCRIPTION ... SET PUBLICATION These commands will perform the following actions: Add newly published sequences that are not yet part of the subscription. Remove sequences that are no longer included in the publication. This ensures that sequence replication remains aligned with the current state of the publication on the publisher side. Note that the actual synchronization of sequence data/values will be handled in a subsequent patch that introduces a dedicated sequence sync worker. Author: Vignesh C <[email protected]> Reviewed-by: Amit Kapila <[email protected]> Reviewed-by: shveta malik <[email protected]> Reviewed-by: Masahiko Sawada <[email protected]> Reviewed-by: Hayato Kuroda <[email protected]> Reviewed-by: Dilip Kumar <[email protected]> Reviewed-by: Peter Smith <[email protected]> Reviewed-by: Nisha Moond <[email protected]> Reviewed-by: Shlok Kyal <[email protected]> Reviewed-by: Chao Li <[email protected]> Reviewed-by: Hou Zhijie <[email protected]> Discussion: https://postgr.es/m/caa4ek1lc+kjiaksrpe_nwvndidw9f2os7geruesxskv71gx...@mail.gmail.com Branch ------ master Details ------- https://git.postgresql.org/pg/commitdiff/f0b3573c3aac6c0ea4cbc278f98178516579d370 Modified Files -------------- doc/src/sgml/catalogs.sgml | 29 +- doc/src/sgml/ref/alter_subscription.sgml | 42 ++- src/backend/catalog/pg_subscription.c | 53 ++- src/backend/commands/subscriptioncmds.c | 480 ++++++++++++++++++++++------ src/backend/executor/execReplication.c | 28 +- src/backend/parser/gram.y | 9 + src/backend/replication/logical/proto.c | 3 + src/backend/replication/logical/relation.c | 12 + src/backend/replication/logical/syncutils.c | 5 +- src/backend/replication/logical/tablesync.c | 2 +- src/backend/replication/logical/worker.c | 2 + src/backend/replication/pgoutput/pgoutput.c | 6 +- src/bin/psql/tab-complete.in.c | 10 +- src/include/catalog/pg_subscription_rel.h | 3 +- src/include/executor/executor.h | 4 +- src/include/nodes/parsenodes.h | 1 + src/test/subscription/meson.build | 1 + src/test/subscription/t/036_sequences.pl | 55 ++++ src/tools/pgindent/typedefs.list | 1 + 19 files changed, 607 insertions(+), 139 deletions(-)
