Avoid syncing data twice for the 'publish_via_partition_root' option.
authorAmit Kapila <[email protected]>
Wed, 29 Mar 2023 05:16:58 +0000 (10:46 +0530)
committerAmit Kapila <[email protected]>
Wed, 29 Mar 2023 05:16:58 +0000 (10:46 +0530)
commit062a8444242404242f7c2b814fed37b329639408
treea797106924ef0b7ee1779b4341f20a78fc1bd9b1
parentde5a47af2d8003dee123815bb7e58913be9a03f3
Avoid syncing data twice for the 'publish_via_partition_root' option.

When there are multiple publications for a subscription and one of those
publishes via the parent table by using publish_via_partition_root and the
other one directly publishes the child table, we end up copying the same
data twice during initial synchronization. The reason for this was that we
get both the parent and child tables from the publisher and try to copy
the data for both of them.

This patch extends the function pg_get_publication_tables() to take a
publication list as its input parameter. This allows us to exclude a
partition table whose ancestor is published by the same publication list.

This problem does exist in back-branches but we decide to fix it there in
a separate commit if required. The fix for back-branches requires quite
complicated changes to fetch the required table information from the
publisher as we can't update the function pg_get_publication_tables() in
back-branches. We are not sure whether we want to deviate and complicate
the code in back-branches for this problem as there are no field reports
yet.

Author: Wang wei
Reviewed-by: Peter Smith, Jacob Champion, Kuroda Hayato, Vignesh C, Osumi Takamichi, Amit Kapila
Discussion: https://postgr.es/m/OS0PR01MB57167F45D481F78CDC5986F794B99@OS0PR01MB5716.jpnprd01.prod.outlook.com
doc/src/sgml/ref/create_publication.sgml
src/backend/catalog/pg_publication.c
src/backend/commands/subscriptioncmds.c
src/include/catalog/catversion.h
src/include/catalog/pg_proc.dat
src/test/regress/expected/rules.out
src/test/subscription/t/013_partition.pl
src/test/subscription/t/028_row_filter.pl
src/test/subscription/t/031_column_list.pl
src/tools/pgindent/typedefs.list