CREATE SUBSCRIPTION

CREATE SUBSCRIPTION
上一页	上一级	SQL 命令	起始页	下一页

CREATE SUBSCRIPTION — 定义一个新的订阅

大纲

CREATE SUBSCRIPTION subscription_name
    CONNECTION 'conninfo'
    PUBLICATION publication_name [, ...]
    [ WITH ( subscription_parameter [= value] [, ... ] ) ]

描述

CREATE SUBSCRIPTION 添加一个新的逻辑复制订阅。创建订阅的用户成为该订阅的所有者。订阅名称必须与当前数据库中任何现有订阅的名称不同。

订阅表示与发布者的复制连接。因此，除了在本地目录中添加定义外，该命令通常会在发布者上创建一个复制槽。

逻辑复制工作者将在运行此命令的事务提交时开始为新订阅复制数据，除非订阅最初被禁用。

要能够创建订阅，您必须具有pg_create_subscription角色的权限，以及当前数据库的CREATE权限。

关于订阅和逻辑复制的更多信息，请参见第 31.2 节和第 31 章。

参数

subscription_name #

新订阅的名称。

CONNECTION 'conninfo' #

定义如何连接到发布者数据库的libpq连接字符串。详情请参见第 34.1.1 节。

PUBLICATION publication_name [, ...] #

要订阅的发布者上的发布名称。

WITH ( subscription_parameter [= value] [, ... ] ) #

本条款指定了订阅的可选参数。

以下参数控制订阅创建期间发生的情况：

connect (boolean) #

指定CREATE SUBSCRIPTION命令是否应连接到发布者。默认值是true。将此设置为false 会强制create_slot、enabled和 copy_data的值为false。（不能将connect设置为false 与将create_slot、enabled或 copy_data设置为true结合使用。）

当此选项设置为false时，由于未建立连接，因此不会订阅任何表。要启动复制，您必须手动创建复制槽、启用订阅并刷新订阅。参见第 31.2.3 节获取示例。

create_slot (boolean) #

指定命令是否应在发布者上创建复制槽。默认值是 true。

如果设置为false，您需要以其他方式负责创建发布者的槽。参见第 31.2.3 节获取示例。

enabled (boolean) #

指定订阅是否应主动进行复制，或者是否仅设置但尚未启动。默认值是true。

slot_name (string) #

要使用的发布者复制槽的名称。默认值是使用订阅的名称作为槽名称。

将slot_name设置为NONE表示订阅不会关联任何复制槽。此类订阅还必须将 enabled和create_slot都设置为 false。在您稍后手动创建复制槽时使用此选项。参见第 31.2.3 节获取示例。

以下参数控制订阅在创建后的复制行为：

binary (boolean) #

指定订阅是否请求发布者以二进制格式（而不是文本格式）发送数据。默认值为 false。任何初始表同步副本（参见copy_data）也使用相同的格式。二进制格式可能比文本格式更快，但在不同的机器架构和 PostgreSQL版本之间的可移植性较差。二进制格式对数据类型非常具体；例如，它不允许从smallint列复制到 integer列，即使在文本格式下这可以正常工作。即使启用了此选项，只有具有二进制发送和接收函数的数据类型才会以二进制方式传输。请注意，初始同步要求所有数据类型都具有二进制发送和接收函数，否则同步将失败（参见CREATE TYPE以了解更多关于发送/接收函数的信息）。

在进行跨版本复制时，可能出现这样的情况：发布者对某种数据类型有二进制发送功能，但订阅者缺乏该类型的二进制接收功能。在这种情况下，数据传输将失败，且binary选项无法使用。

如果发布者是PostgreSQL 16版本之前的版本，那么即使binary = true，任何初始表同步也将使用文本格式。

copy_data（boolean） #

指定在复制开始时是否复制正在订阅的publication中的预先存在的数据。默认值为true。

如果publication包含WHERE子句，它将影响复制的数据。请参考 Notes获取详细信息。

请参阅Notes了解 copy_data = true如何与 origin参数交互的详细信息。

流式处理 (enum) #

指定是否为此订阅启用正在进行的事务的流式传输。默认值为 off，这意味着所有事务都会在发布者上完全解码，然后作为一个整体发送给订阅者。

如果设置为on，传入的更改将被写入临时文件，并且只有在发布者提交事务并由订阅者接收后才会应用。

如果设置为parallel，传入的更改将直接通过一个并行应用工作线程（如果可用）进行应用。如果没有空闲的并行应用工作线程来处理流式事务，则更改会被写入临时文件，并在事务提交后应用。请注意，如果在并行应用工作线程中发生错误，远程事务的完成LSN可能不会在服务器日志中报告。

synchronous_commit (enum) #

此参数的值将覆盖此订阅的应用工作进程中的 synchronous_commit设置。默认值为 off。

使用off对于逻辑复制是安全的：如果订阅者由于缺少同步而丢失事务，则数据将再次从发布者发送。

在进行同步逻辑复制时，可能需要使用不同的设置。逻辑复制工作者会向发布者报告写入和刷新的位置，在使用同步复制时，发布者将等待实际的刷新。这意味着当订阅用于同步复制时，将订阅者的 synchronous_commit设置为off可能会增加发布者上 COMMIT的延迟。在这种情况下，将synchronous_commit 设置为local或更高可能是有利的。

two_phase（boolean） #

指定是否为此订阅启用两阶段提交。默认值为false。

当启用两阶段提交时，准备好的事务会在PREPARE TRANSACTION时发送给订阅者，并在订阅者上也作为两阶段事务处理。否则，准备好的事务只有在提交时才会发送给订阅者，然后由订阅者立即处理。

两阶段提交的实现要求复制已成功完成初始表同步阶段。因此，即使为订阅启用了two_phase，内部的两阶段状态仍会暂时保持“挂起”，直到初始化阶段完成。参见pg_subscription的subtwophasestate列，以了解实际的两阶段状态。

disable_on_error（boolean） #

指定是否应在发布者进行数据复制期间，如果订阅工作者检测到任何错误，则自动禁用订阅。默认值为 false。

password_required (boolean) #

如果设置为true，则由于此订阅建立的与发布者的连接必须使用密码认证，并且密码必须作为连接字符串的一部分指定。当订阅由超级用户拥有时，此设置将被忽略。默认值为true。只有超级用户可以将此值设置为false。

run_as_owner (boolean) #

如果为 true，所有复制操作都将以订阅者的身份执行。如果为 false，复制工作者将在每个表上以该表的所有者身份执行操作。后一种配置通常更加安全；详情请参见第 31.9 节。默认值为 false。

origin (string) #

指定订阅是否会请求发布者仅发送没有来源的更改，或者无论来源如何都发送更改。将origin设置为none表示订阅会请求发布者仅发送没有来源的更改。将origin设置为any 表示发布者会发送无论来源如何的更改。默认值是any。

请参阅Notes了解 copy_data = true如何与 origin参数交互的详细信息。

当指定类型为boolean的参数时， =值 部分可以省略，这等同于指定TRUE。

注意

有关如何在订阅和发布实例之间配置访问控制的详细信息，请参见第 31.9 节。

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

创建一个连接到同一数据库集群的订阅（例如，在同一集群中的数据库之间进行复制或在同一数据库内进行复制）只有在复制槽未作为同一命令的一部分创建时才会成功。否则，CREATE SUBSCRIPTION 调用将会挂起。为了使其正常工作，请单独创建复制槽（使用函数 pg_create_logical_replication_slot，插件名称为 pgoutput），并使用参数 create_slot = false 创建订阅。请参阅第 31.2.3 节以获取示例。这是一个实现限制，可能会在未来的版本中解除。

如果发布中的任何表包含WHERE子句，则对于 表达式计算结果为假或空的行将不会被发布。如果订阅包含多个发布，并且同一表在不同的WHERE子句下被发布，那么如果任何表达式（与该发布操作相关）满足条件，则该行将被发布。在不同WHERE子句的情况下，如果其中一个发布没有 WHERE子句（与该发布操作相关），或者该发布被声明为 FOR ALL TABLES 或 FOR TABLES IN SCHEMA，则无论其他表达式的定义如何，行始终会被发布。如果订阅者是PostgreSQL 15 之前的版本，那么在初始数据同步阶段会忽略任何行过滤。对于这种情况，用户可能需要考虑删除任何最初复制的数据，这些数据可能与后续过滤不兼容。因为初始数据同步在复制现有表数据时不会考虑发布的 publish 参数，所以可能会复制一些不会通过 DML 复制的行。有关示例，请参见第 31.2.2 节。

具有多个publication的订阅，其中同一表以不同的列列表发布，不受支持。

我们允许指定不存在的publication，以便用户稍后添加。这意味着 pg_subscription 可以有不存在的publication。

当使用订阅参数组合copy_data = true和 origin = NONE时，初始同步表数据直接从发布者复制，这意味着无法得知这些数据的真正来源。如果发布者也有订阅，那么复制的表数据可能来自更上游的来源。此场景会被检测到，并向用户记录一条 WARNING，但该警告仅是潜在问题的提示；用户有责任进行必要的检查，以确保复制的数据来源确实符合预期。

要查找哪些表可能包含非本地来源（由于发布者上创建的其他订阅），可以尝试以下SQL查询：

# substitute <pub-names> below with your publication name(s) to be queried
SELECT DISTINCT PT.schemaname, PT.tablename
FROM pg_publication_tables PT,
     pg_subscription_rel PS
     JOIN pg_class C ON (C.oid = PS.srrelid)
     JOIN pg_namespace N ON (N.oid = C.relnamespace)
WHERE N.nspname = PT.schemaname AND
      C.relname = PT.tablename AND
      PT.pubname IN (<pub-names>);

示例

创建一个到远程服务器的订阅，复制发布mypublication和 insert_only中的表，并在提交时立即开始复制：

CREATE SUBSCRIPTION mysub
         CONNECTION 'host=192.168.1.50 port=5432 user=foo dbname=foodb'
        PUBLICATION mypublication, insert_only;

创建一个到远程服务器的订阅，复制insert_only发布中的表，并且不开始复制直到稍后启用复制。

CREATE SUBSCRIPTION mysub
         CONNECTION 'host=192.168.1.50 port=5432 user=foo dbname=foodb'
        PUBLICATION insert_only
               WITH (enabled = false);

兼容性

CREATE SUBSCRIPTION是一个PostgreSQL 扩展。

又见

ALTER SUBSCRIPTION, DROP SUBSCRIPTION, CREATE PUBLICATION, ALTER PUBLICATION