CREATE SUBSCRIPTION

    注意事项

    创建复制槽时(默认行为),CREATE SUBSCRIPTION不能在事务块内部执行。

    参数说明

    • subscription_name

      新订阅的名称。

    • CONNECTION ‘conninfo’

      连接发布端的字符串。

      如’host=1.1.1.1,2.2.2.2 port=10000,20000 dbname=postgres user=repusr1 password=password_123’。

      • host

        发布端IP地址,可以同时指定发布端主机和备机的IP地址,如果同时指定了多个IP,以英文逗号分隔。

      • port

        发布端端口,此处的端口不能使用主端口,而应该使用主端口+1端口,否则会与线程池冲突。可以同时指定发布端主机和备机的端口,如果同时指定了多个端口,以英文逗号分隔。

      • user和password

        用于连接发布端且具有系统管理员权限(SYSADMIN)或者运维管理员权限(OPRADMIN)的用户名和密码。password需要加密,创建订阅前需要在订阅端执行gs_guc generate -S xxxxxx -D $GAUSSHOME/bin -o subscription。

    • PUBLICATION publication_name

      要订阅的发布端的发布名称,一个订阅可以对应多个发布。

    • WITH ( subscription_parameter [= value] [, … ] )

      该子句指定订阅的可选参数。支持的参数有:

      • copy_data (boolean)

        指定在复制启动后是否应复制正在订阅的发布中的现有数据。默认值是true。

      • 指定订阅是否应该主动复制,或者是否应该只是设置,但尚未启动。默认值是true。

      • slot_name (string)

        要使用的复制插槽的名称。默认使用订阅名称作为复制槽的名称。

        如果创建订阅时设置enable为false,则slot_name将被强制设置为NONE,即空值,即使用户指定了slot_name的值,表示复制槽不存在。

      • synchronous_commit (enum)

        该参数的值会覆盖synchronous_commit设置。 默认值是off。

        对于逻辑复制使用off是安全的,如果订阅端由于缺少同步而丢失事务,数据将从发布者再次发送。进行同步逻辑复制时,一个不同的设置可能是合适的。逻辑复制线程向发布端报告写入和刷新的位置,当使用同步复制时,发布端将等待订阅端的事务日志完成实际刷新。这意味着,当订阅用于同步复制时,将订阅者的synchronous_commit设置为off可能会增加发布端服务器上COMMIT的延迟,原因是off可能会增加事务日志刷盘的延迟,从而导致发布端可能需要花费更多的时间等待订阅者完成事务日志刷盘。在这种情况下,将synchronous_commit设置为local或更高是有利的。

      • binary (boolean)

        该参数指定是否需要该订阅对应的发布端以二进制格式发送数据,为true表示需要以二进制发送,为false表示不以二进制格式而知以默认的文本格式发送。默认值false。

    1. CREATE SUBSCRIPTION mysub
    2. PUBLICATION mypublication, insert_only;
    3. --创建一个到远程服务器的订阅,复制insert_only发布中的表, 并且不开始复制直到稍后启用复制。
    4. CONNECTION 'host=192.168.1.50 port=5432 user=foo dbname=foodb password=xxxx '
    5. PUBLICATION insert_only
    6. WITH (enabled = false);
    7. --修改订阅的连接信息。
    8. --激活订阅。
    9. ALTER SUBSCRIPTION mysub SET(enabled=true);
    10. DROP SUBSCRIPTION mysub;

    相关链接

    ALTER SUBSCRIPTION