Re: Column Filtering in Logical Replication
vignesh C <vignesh21@gmail.com>
On Mon, Aug 22, 2022 at 1:58 PM Peter Smith <smithpb2250@gmail.com> wrote: > > Thanks for the view of v1-0001. > > On Wed, Aug 17, 2022 at 3:04 AM vignesh C <vignesh21@gmail.com> wrote: > ... > > 1) Row filters mentions that "It has no effect on TRUNCATE commands.", > > the same is not present in case of column filters. We should keep the > > changes similarly for consistency. > > --- a/doc/src/sgml/ref/create_publication.sgml > > +++ b/doc/src/sgml/ref/create_publication.sgml > > @@ -90,8 +90,7 @@ CREATE PUBLICATION <replaceable > > class="parameter">name</replaceable> > > <para> > > When a column list is specified, only the named columns are replicated. > > If no column list is specified, all columns of the table are replicated > > - through this publication, including any columns added later. If a column > > - list is specified, it must include the replica identity columns. > > + through this publication, including any columns added later. > > Modified as suggested. > > > > > 2) The document says that "if the table uses REPLICA IDENTITY FULL, > > specifying a column list is not allowed.": > > + publishes only <command>INSERT</command> operations. Furthermore, if the > > + table uses <literal>REPLICA IDENTITY FULL</literal>, specifying a column > > + list is not allowed. > > + </para> > > > > Did you mean specifying a column list during create publication for > > REPLICA IDENTITY FULL table like below scenario: > > postgres=# create table t2(c1 int, c2 int, c3 int); > > CREATE TABLE > > postgres=# alter table t2 replica identity full ; > > ALTER TABLE > > postgres=# create publication pub1 for table t2(c1,c2); > > CREATE PUBLICATION > > > > If so, the document says specifying column list is not allowed, but > > creating a publication with column list on replica identity full was > > successful. > > That patch v1-0001 was using the same wording from the github commit > message [1]. I agree it was a bit vague. > > In fact the replica identity validation is done at DML execution time > so your example will fail as expected when you attempt to do a UPDATE > operation. > > e.g. > test_pub=# update t2 set c2=23 where c1=1; > ERROR: cannot update table "t2" > DETAIL: Column list used by the publication does not cover the > replica identity. > > I modified the wording for this part of the docs. Few comments: 1) I felt no expressions are allowed in case of column filters. Only column names can be specified. The second part of the sentence confuses what is allowed and what is not allowed. Won't it be better to remove the second sentence and mention that only column names can be specified. + <para> + Column list can contain only simple column references. Complex + expressions, function calls etc. are not allowed. + </para> 2) tablename should be table name. + <para> + A column list is specified per table following the tablename, and enclosed by + parenthesis. See <xref linkend="sql-createpublication"/> for details. + </para> We have used table name in the same page in other instances like: a) The row filter is defined per table. Use a WHERE clause after the table name for each published table that requires data to be filtered out. The WHERE clause must be enclosed by parentheses. b) The tables are matched between the publisher and the subscriber using the fully qualified table name. 3) One small whitespace issue: git am v2-0001-Column-List-replica-identity-rules.patch Applying: Column List replica identity rules. .git/rebase-apply/patch:30: trailing whitespace. if the publication publishes only <command>INSERT</command> operations. warning: 1 line adds whitespace errors. Regards, Vignesh
Commits
GET /api/v1/messages/:b64id/commits
the thread's linked commits as JSON, with link sources.
API reference →
-
Doc: Explain about Column List feature.
- f98d07424523 16.0 landed
- 25996a82a446 15.0 landed
-
Doc: fix column list vs. replica identity rules.
- 376af686111e 16.0 landed
- ab3131880d8a 15.0 landed
-
Prohibit combining publications with different column lists.
- fd0b9dcebda7 15.0 cited
-
Fix the check to limit sync workers.
- be46985bed8a 10.21 landed
- a90de822e483 11.16 landed
- 59348fbdeb7b 12.11 landed
- 82d4a17a1750 13.7 landed
- c9dea58e2702 14.3 landed
- dd4ab6fd6528 15.0 landed
-
Wait for subscription to sync in t/031_column_list.sql
- 404f49338fef 15.0 landed
-
Move prattrs to the pg_publication_rel section in docs
- 41b00f8e601f 15.0 landed
-
Allow specifying column lists for logical replication
- 923def9a533a 15.0 landed
-
Fix row filters with multiple publications
- 5a079662256e 15.0 landed
-
Fix publish_as_relid with multiple publications
- 27fafee72d17 13.7 landed
- 677a1dc0ca0f 14.3 landed
- c91f71b9dc91 15.0 landed
-
Add some additional tests for row filters in logical replication.
- ceb57afd3ce1 15.0 cited
-
Add index on pg_publication_rel.prpubid
- 025b920a3d45 15.0 landed
-
Avoid using DefElemAction in AlterPublicationStmt
- 9623d8999603 15.0 landed
-
Small cleanups related to PUBLICATION framework code
- c9105dd3660f 15.0 landed
-
Add PublicationTable and PublicationRelInfo structs
- 0c6828fa987b 15.0 landed
-
Fix various concurrency issues in logical replication worker launching
- de4389712206 10.0 cited