出版社機能

create_publisher

各データベースでは、変更を別のサブスクライバーに公開するために、複数のパブリケーションを作成することができます。

Arguments:

    publisher_name               The Unique name of publisher.
    for table                    To publish single/list of tables
    for all table                To publish all tables, along with future tables.
    for all tables in schema     To publish all tables in schema, along wth future tables.

Usage:
    exampledb=> create publication my_publication for all tables ;
    CREATE PUBLICATION

list_publisher

各データベースで実行中のパブリケーションの数を列挙する。

Usage:
   exampledb=# select * from pg_publication;
   oid  |    pubname     | pubowner | puballtables | pubinsert | pubupdate | pubdelete | pubtruncate
   -------+----------------+----------+--------------+-----------+-----------+-----------+-------------
   16401 | my_publication |       10 | t            | t         | t         | t         | t

alter_publisher

出版物の定義を変更する。

Syntax:
ALTER PUBLICATION name ADD publication_object [, ...]
ALTER PUBLICATION name SET publication_object [, ...]
ALTER PUBLICATION name DROP publication_object [, ...]
ALTER PUBLICATION name SET ( publication_parameter [= value] [, ... ] )
ALTER PUBLICATION name OWNER TO { new_owner | CURRENT_ROLE | CURRENT_USER | SESSION_USER }
ALTER PUBLICATION name RENAME TO new_name


 Usage:
    exampledb=# ALTER PUBLICATION my_publication RENAME TO my_publication_new;
    ALTER PUBLICATION

drop_publisher

使用していないパブリケーションは取り外します。

Usage:
    exampledb=# drop publication my_publication_new;
    DROP PUBLICATION

以下の事項を前提条件として考慮してください

1. 外部（パブリッシャー）を設定する PostgreSQL wal_level=logical。
2. レプリケーション対象として選択されたテーブルにはすべて 、主キー が含まれているか、設定されている必要があります。 REPLICA IDENTITY 設定されている必要があります。
3. お客様の外部（パブリッシャー） PostgreSQL は、 PostgreSQL 権限 REPLICATION を持つレプリケーションユーザーを持つ必要があります。また、そのユーザーは、レプリケーション権限に加えて、データベースに対するSELECT権限とUSAGE権限を持つ必要があります。
4. 複製元の PostgreSQL は、 TLS/SSLを有効にする必要があります。
5. 行レベルセキュリティが有効になっている場合、外部（パブリッシャー） PostgreSQL レプリケーションユーザーに BYPASSRLS 権限を付与します。

PostgreSQL のドキュメントで説明されている論理レプリケーションには、固有の制限事項やいくつかの制約があります。 論理レプリケーションが貴社のユースケースに適切かどうかを判断する前に、これらの事項を確認してください。

サブスクライバーの関数

create_subscription

Arguments:
    subscription_name   Unique name to create the subscription channel with
    host_ip             Publisher hostname or public IP address
    port                Port number publisher is running on
    username            `admin` user created on the publisher
    password            Password of the `admin` user on the publisher
    db_name             The name of the database to be replicated
    publisher_name      The name of publisher channel on the publisher

Usage:
    exampledb=> SELECT create_subscription('subs1','130.215.223.184','5432','password','admin','exampledb','my_publication');

delete_subscription

Arguments:
    subscription_name   Name the subscription channel to delete
    db_name             The name of the replicated database

Usage:
exampledb=> SELECT delete_subscription('subs1', 'exampledb');

list_subscriptions

Arguments:
    None

Usage:
    exampledb=> SELECT * FROM list_subscriptions();

disable_subscription

Arguments:
    subscription_name   Name the subscription channel to disable
    db_name             The name of the replicated database

Usage:
    exampledb=> SELECT disable_subscription('subs1','exampledb');

enable_subscription

Arguments:
    subscription_name   Name the subscription channel to enable
    db_name             The name of the replicated database

Usage:
    exampledb=> SELECT enable_subscription('subs1','exampledb');

subscription_slot_none

この関数は、サブスクリプションのスロット名をNONEに設定するために使用される。 これは、サブスクリプションを削除して、リモートレプリケーションスロットがドロップされないようにするか、存在しないか、存在したことがないようにするために必要である。

Arguments:
    subscription_name   Name the subscription channel to alter
    db_name             The name of the replicated database

Usage:
    exampledb=> SELECT subscription_slot_none('subs1','exampledb');

refresh_subscription

この関数は、パブリッシャーで表の追加や削除などの変更が行われた後で、サブスクライバーのサブスクリプションをリフレッシュするために使用されます。

Arguments:
    subscription_name   Name the subscription channel to refresh
    db_name             The name of the replicated database

Usage:
    exampledb=> SELECT refresh_subscription('subs1','exampledb');