Re: Column Filtering in Logical Replication
vignesh C <vignesh21@gmail.com>
Attachments
- Generic_object_type_parser_001_table_publication.patch (text/x-patch) patch
- Generic_object_type_parser_002_table_schema_publication.patch (text/x-patch) patch
On Wed, Sep 15, 2021 at 5:20 PM Alvaro Herrera <alvherre@alvh.no-ip.org> wrote: > > On 2021-Sep-15, Amit Kapila wrote: > > > On Mon, Sep 6, 2021 at 11:21 PM Alvaro Herrera <alvherre@alvh.no-ip.org> wrote: > > > > > > I pushed the clerical part of this -- namely the addition of > > > PublicationTable node and PublicationRelInfo struct. > > > > One point to note here is that we are developing a generic grammar for > > publications where not only tables but other objects like schema, > > sequences, etc. can be specified, see [1]. So, there is some overlap > > in the grammar modifications being made by this patch and the work > > being done in that other thread. > > Oh rats. I was not aware of that thread, or indeed of the fact that > adding multiple object types to publications was being considered. > > I do see that 0002 there contains gram.y changes, but AFAICS those > changes don't allow specifying a column list for a table, so there are > some changes needed in that patch for that either way. > > I agree that it's better to move forward in unison. > > I noticed that 0002 in that other patch uses a void * pointer in > PublicationObjSpec that "could be either RangeVar or String", which > strikes me as a really bad idea. (Already discussed in some other > thread recently, maybe this one or the row filtering one.) I have extracted the parser code and attached it here, so that it will be easy to go through. We wanted to support the following syntax as in [1]: CREATE PUBLICATION pub1 FOR TABLE t1,t2,t3, ALL TABLES IN SCHEMA s1,s2, SEQUENCE seq1,seq2, ALL SEQUENCES IN SCHEMA s3,s4; Columns can be added to PublicationObjSpec data structure. The patch Generic_object_type_parser_002_table_schema_publication.patch has the changes that were used to handle the parsing. Schema and Relation both are different objects, schema is of string type and relation is of RangeVar type. While parsing, schema name is parsed in string format and relation is parsed and converted to rangevar type, these objects will be then handled accordingly during post processing. That is the reason it used void * type which could hold both RangeVar and String. Thoughts? [1] - https://www.postgresql.org/message-id/877603.1629120678%40sss.pgh.pa.us 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