postgres_fdw
模块提供了外部数据包装器postgres_fdw
,它可以被用来访问存储在外部PostgreSQL服务器中的数据。
这个模块提供的功能大体上覆盖了较老的dblink模块的功能。但是postgres_fdw
提供了更透明且更兼容标准的语法来访问远程表,并且可以在很多情况下给出更好的性能。
要使用postgres_fdw
来为远程访问做准备:
使用CREATE EXTENSION来安装postgres_fdw
扩展。
使用CREATE SERVER创建一个外部服务器对象,它用来表示你想连接的每一个远程数据库。指定除了user
和password
之外的连接信息作为该服务器对象的选项。
使用CREATE USER MAPPING创建一个用户映射,每一个用户映射都代表你想允许一个数据库用户访问一个外部服务器。指定远程用户名和口令作为用户映射的user
和password
选项。
为每一个你想访问的远程表使用CREATE FOREIGN TABLE或者IMPORT FOREIGN SCHEMA创建一个外部表。外部表的列必须匹配被引用的远程表。但是,如果你在外部表对象的选项中指定了正确的远程名称,你可以使用不同于远程表的表名和/或列名。
现在,您只需要从外部表中SELECT
来访问存储在其底层远程表中的数据。
您还可以使用INSERT
、UPDATE
、DELETE
、
COPY
或TRUNCATE
修改远程表。
(当然,您在用户映射中指定的远程用户必须具有执行这些操作的权限。)
请注意,在访问或修改远程表时, SELECT
, UPDATE
, DELETE
或TRUNCATE
中指定的ONLY
选项没有效果。
注意当前postgres_fdw
缺少对于带ON CONFLICT DO UPDATE
子句的INSERT
语句的支持。不过,它支持ON CONFLICT DO NOTHING
子句,已提供的唯一索引推断说明会被省略。
请注意,postgres_fdw
还支持由在分区表上执行的UPDATE
语句触发的行移动,但目前不处理远程分区选择插入移动行的情况,并且该远程分区本身也是同一命令中将在其他位置更新的UPDATE
目标分区。
我们通常推荐一个外部表的列被声明为与被引用的远程表列完全相同的数据类型和排序规则(如果可用)。尽管postgres_fdw
目前已经能够容忍在需要时执行数据类型转换,但是当类型或排序规则不匹配时可能会发生奇怪的语义异常,因为远程服务器解释查询条件时可能会与本地服务器有所不同。
注意一个外部表可以被声明比底层的远程表较少的列,或者使用一种不同的列序。与远程表的列匹配是通过名字而不是位置进行的。
使用postgres_fdw
外部数据包装器的外部服务器可以在连接字符串中接受与libpq相同的选项,
如第 34.1.2 节中所述,但是这些选项不允许或具有特殊处理:
user
、password
和sslpassword
(请在用户映射中指定这些,或使用服务文件)
client_encoding
(这将自动从本地服务器编码设置)
application_name
- 这可能出现在连接和postgres_fdw.application_name中的任一或两者。
如果两者都存在,postgres_fdw.application_name
将覆盖连接设置。
与libpq不同,postgres_fdw
允许application_name
包含“转义序列”。
有关详细信息,请参见postgres_fdw.application_name。
fallback_application_name
(始终设置为postgres_fdw
)
sslkey
和sslcert
- 这些可能出现在连接和用户映射中的任一或两者。
如果两者都存在,用户映射设置将覆盖连接设置。
只有超级用户可以使用sslcert
或sslkey
设置创建或修改用户映射。
只有超级用户可以在不经过口令认证的情况下连接到外部服务器,因此应总是为属于非超级用户的用户映射指定password
选项。
超级用户可以通过设置用户映射选项password_required 'false'
在每个用户映射的基础上覆盖此检查,例如,
ALTER USER MAPPING FOR some_non_superuser SERVER loopback_nopw OPTIONS (ADD password_required 'false');
为了防止非特权用户利用正在运行的 postgres 服务器升级到超级用户权限的 unix 用户的身份验证权限,只有超级用户可以在用户映射上设置此选项。
需要小心确保这不会允许映射用户以CVE-2007-3278和CVE-2007-6601的方式连接到映射的数据库作为超级用户。
不要在public
角色上设置password_required=false
。
请记住,映射用户可能会使用任何客户端证书、.pgpass
、
.pg_service.conf
等等,这些文件位于postgres服务器运行的系统用户的unix主目录中。
他们还可以使用由peer
或ident
认证授予的任何信任关系。
这些选项可以被用来控制使用在被发送到远程PostgreSQL服务器的 SQL 语句中使用的名称。当一个外部表被使用不同于底层远程表的名称创建时,就需要这些选项。
schema_name
(string
)这个选项给出用在远程服务器之上的外部表的模式名称,它可以为一个外部表指定。如果这个选项被忽略,该外部表的模式名称将被使用。
table_name
(string
)这个选项给出用在远程服务器上的外部表给出表名,它可以为一个外部表指定。如果这个选项被忽略,该外部表的名字将被使用。
列名
(string
)这个选项给出用在远程服务器上列的列名,它可以为一个外部表的一个列指定。如果这个选项被忽略,该列的名字将被使用。
postgres_fdw
通过在远程服务器上执行查询来检索远程数据,因此理想的扫描一个外部表的估计代价应该是在远程服务器上完成它的花销,外加一些通信开销。得到这样一个估计的最可靠的方法是询问远程服务器并加上一些通信开销 — 但是对于简单查询,不值得为获得一个代价估计而额外使用一次远程查询。因此postgres_fdw
提供了下列选项来控制如何完成代价估计:
use_remote_estimate
(boolean
)
这个选项控制postgres_fdw
是否发出EXPLAIN
命令来获得代价估计,它可以为一个外部表或一个外部服务器指定。一个外部表的设置会覆盖它的服务器的任何设置,但是只用于这个表。默认值是false
。
fdw_startup_cost
(浮点数
)
这个选项是一个要被加到那个服务器上所有外部表扫描的估计启动代价的浮点值。这表示建立一个连接、在远端解析和规查询的额外负荷等。默认值是100
。
fdw_tuple_cost
(浮点数
)
这个选项是一个浮点值,它被用作那个服务器上外部表扫描的每元组额外代价,它可以为一个外部服务器指定。这表示在服务器之间数据传输的额外负荷。你可以增加或减少这个数来反映到远程服务器更高或更低的网络延迟。默认值是0.01
。
当use_remote_estimate
为真时,postgres_fdw
从远程服务器获得行计数和代价估计,然后在代价估计上加上fdw_startup_cost
和fdw_tuple_cost
。当use_remote_estimate
为假时,postgres_fdw
执行本地行计数和代价估计,并且接着在代价估计上加上fdw_startup_cost
和fdw_tuple_cost
。这种本地估计不会很准确,除非有远程表统计数据的本地拷贝可用。在外部表上运行ANALYZE是更新本地统计数据的方法,这将执行远程表的一次扫描并接着计算和存储统计数据,就好像表在本地一样。保留本地统计数据可能是一种有用的方法来减少一个远程表的预查询规划负荷 — 但是如果远程表被频繁更新,本地统计数据将很快就被废弃。
默认情况下,只有使用了内建操作符和函数的WHERE
子句才会被考虑在远程服务器上执行。涉及非内建函数的子句将会在取完行后在本地进行检查。如果这类函数在远程服务器上可用并且可以用来产生和本地执行时一样的结果,则可以通过将这种WHERE
子句发送到远程执行来提高性能。可以用下面的选项控制这种行为:
扩展
(string
)这个选项是一个用逗号分隔的已安装的PostgreSQL扩展名称列表,这些扩展在本地和远程服务器上具有兼容的版本。属于一个该列表中扩展的 immutable 函数和操作符将被考虑转移到远程服务器上执行。这个选项只能为外部服务器指定,无法逐个表指定。
在使用extensions
选项时,用户应该负责确保列出的扩展在本地和远程服务器上都存在且保持一致。否则,远程查询可能失败或者行为异常。
fetch_size
(integer
)
这个选项指定在每次获取行的操作中postgres_fdw
应该得到的行数。可以为一个外部表或者外部服务器指定这个选项。在表上指定的选项将会覆盖在服务器级别上指定的选项。默认值为100
。
batch_size
(integer
)
这个选项指定了每次插入操作中postgres_fdw
的行数。应该在每个插入操作中插入多少行。它可以被指定为一个
可以为一个外域表或一个外域服务器指定。在一个表上指定的选项覆盖为服务器指定的选项,默认是1
。
请注意,postgres_fdw
一次插入的实际行数取决于列数和提供的数据。
取决于列的数量和提供的
batch_size
值。这个批处理是作为一个单一的
查询,并且libpq协议(postgres_fdw
用来连接到远程服务器)。
用于连接到远程服务器)将单个查询中的参数数量限制为65535。
单个查询的参数数量限制为65535。当列的数量*batch_size
超过限制时,batch_size
将被调整以避免错误。
避免出错。
postgres_fdw
支持异步执行,可以并发地运行一个 Append
节点的多个部分,相比串行化的方式能获得更好的性能提升。可以使用以下选项来控制该执行行为:
async_capable
(boolean
)
这个选项控制postgres_fdw
是否允许异步执行的外部表被同时扫描。它可以为一个外部表或一个外部服务器指定。一个表级的选项覆盖一个服务器级的选项。默认是false
。
为了确保从外部服务器返回的数据一致性,postgres_fdw
只会为一个特定的外部服务器打开一个连接,并且顺序运行所有针对该服务器的查询,即使涉及多个外部表也是如此,除非这些表受不同用户映射的影响。在这种情况下,禁用此选项可能更有效,以消除运行异步查询所带来的开销。
在一个Append
节点中,即使有部分子计划是同步执行,也有部分子计划是异步执行,异步执行仍被应用。在这种情况下,如果异步子计划是使用postgres_fdw
处理的,则需要等到至少有一个同步子计划返回所有元组,才能返回异步子计划的元组,因为当异步子计划等待发送给外部服务器的异步查询的结果时,同步子计划正在执行。该行为可能会在未来的版本中更改。
如在事务管理部分所述,在postgres_fdw
中,事务通过创建相应的远程事务来管理,
子事务通过创建相应的远程子事务来管理。当当前本地事务涉及多个远程事务时,默认情况下,
postgres_fdw
在本地事务提交时按顺序提交这些远程事务。当当前本地子事务涉及多个远程子事务时,
默认情况下postgres_fdw
在本地子事务提交时按顺序提交这些远程子事务。可以通过以下选项来提高性能:
parallel_commit
(布尔值
)
这个选项控制在本地事务提交时,postgres_fdw
是否在并行远程事务中提交。
当本地事务提交时,这个选项也适用于远程和本地子事务。这个选项只能针对外部服务器指定,而不是针对每个表。
默认值是false
。
如果启用了此选项的多个外部服务器参与本地事务,则在提交本地事务时,这些外部服务器上的多个远程事务将在这些外部服务器上并行提交。
当启用此选项时,具有许多远程事务的外部服务器在本地事务提交时可能会受到负面性能影响。
默认情况下,所有使用postgres_fdw
的外部表都被假定是可更新的。这可以使用下列选项覆盖:
updatable
(布尔值
)
这个选项控制postgres_fdw
是否允许外部表被使用INSERT
、UPDATE
和DELETE
命令更新。它可以为一个外部表或一个外部服务器指定。一个表级选项会覆盖一个服务器级选项。默认值是true
。
当然,如果远程表实际上并非可更新的,将产生一个错误。这个选项的使用主要是允许在不查询远程服务器的情况下在本地抛出错误。但是要注意information_schema
视图会根据这个选项的设置报告一个postgres_fdw
外部表是可更新的(或者不可更新),而不需要远程服务器的任何检查。
默认情况下,使用 postgres_fdw
的所有外部表都被认为是可截断的。可以使用以下选项覆盖该行为:
truncatable
(布尔值
)
此选项控制postgres_fdw
是否允许使用 TRUNCATE
命令截断外部表。它可以指定为外部表或外部服务器。 表级别的选项将覆盖服务器级别的选项。默认值为true
。
当然,如果远程表实际上无法被清空,那么就会出现错误。该选项的使用主要可以在不查询远程服务器的情况下本地抛出错误。
postgres_fdw
能使用IMPORT FOREIGN SCHEMA导入外部表定义。这个命令会在本地服务器上创建外部表定义,这个定义能匹配存在于远程服务器上的表或者视图。如果要被导入的远程表有用户自定义数据类型的列,本地服务器上也必须具有相同名称的兼容类型。
导入行为可以用下列选项自定义(在IMPORT FOREIGN SCHEMA
命令中给出):
import_collate
(布尔值
)
这个选项控制是否在从外部服务器导入的外部表定义中包括列的COLLATE
选项。默认是true
。如果远程服务器具有和本地服务器不同的排序规则名集合,可能需要关闭这个选项,在不同的操作系统上运行时很可能就是这样。
这么做,然而有一个非常严重的风险,即导入表的列排序规则(collations)将不匹配基础数据,从而导致异常的查询行为。
即使此参数设置为true
,导入远程服务器默认排序规则的列也存在风险。它们将以COLLATE "default"
被导入,这将选择本地服务器的默认排序规则,而这可能是不同的。
import_default
(布尔值
)
这个选项控制是否在从外部服务器导入的外部表定义中包括列的DEFAULT
表达式。默认是false
。如果启用这个选项,要当心在远程服务器和本地服务器上计算表达式的方式不同,nextval()
常会导致这类问题。如果导入的默认值表达式使用了一个本地不存在的函数或者操作符,IMPORT
将整个失败。
import_generated
(布尔值
)
此选项控制导入自外部服务器的外部表定义是否包括列 GENERATED
表达式。 默认值为 true
,如果导入的生成表达式使用本地不存在的函数或运算符,则整个 IMPORT
将失败。
import_not_null
(布尔值
)
这个选项控制是否在从外部服务器导入的外部表定义中包括列的NOT NULL
约束。默认是true
。
注意除NOT NULL
之外的约束将不会从远程表中导入。虽然PostgreSQL确实支持外部表上的检查约束,但不会自动导入它们,因为存在本地和远程服务器计算约束表达式方式不同的风险。检查约束中的任何这类不一致都可能导致查询优化中很难检测的错误。因此,如果你希望导入检查约束,你必须手工来做,并且你应该仔细地验证每一个这种约束的语义。有关处理外部表上检查约束的更多细节,请见CREATE FOREIGN TABLE。
作为其他表的分区的表或外部表只在明确指定它们在限制为LIMIT TO
子句中时才被导入。否则,它们将自动从IMPORT FOREIGN SCHEMA中排除。由于可以通过分区层次结构的根即分区表来访问所有数据,因此仅导入分区表应该允许访问所有数据而不创建额外的对象。
默认情况下,postgres_fdw
连接到外部服务器的所有连接都保持打开状态以便于重复使用。
keep_connections
(布尔值
)
该选项控制postgres_fdw
是否保持与外部服务器的连接,以便后续查询可以重复使用它们。它仅适用于外部服务器。默认情况下为on
。如果设置为off
,则每个事务结束时将丢弃到该外部服务器的所有连接。
postgres_fdw_get_connections(OUT server_name text, OUT valid boolean) returns setof record
此函数返回由postgres_fdw
从本地会话到外部服务器之间建立的,所有打开连接的外部服务器名称。
它还返回每个连接是否有效。如果外部服务器连接在当前本地事务中使用,
但其外部服务器或用户映射已更改或删除,则返回false
(请注意,无效连接的服务器名称将在服务器被删除时为NULL
),
然后这种无效连接将在该事务结束时关闭。否则返回true
。
如果没有打开的连接,则不返回记录。函数的示例用法:
postgres=# SELECT * FROM postgres_fdw_get_connections() ORDER BY 1; server_name | valid -------------+------- loopback1 | t loopback2 | f
postgres_fdw_disconnect(server_name text) returns boolean
此函数会断开由postgres_fdw
从本地会话到指定名称的外部服务器之间建立的,打开连接。
请注意,可以使用不同的用户映射在给定服务器上建立多个连接。
如果这些连接在当前本地事务中被使用,则它们不会被断开,并且会报告警告消息。
如果此函数断开至少一个连接,则返回true
,否则返回false
。
如果找不到具有给定名称的外部服务器,则会报告错误。
函数的示例用法:
postgres=# SELECT postgres_fdw_disconnect('loopback1'); postgres_fdw_disconnect ------------------------- t
postgres_fdw_disconnect_all() returns boolean
此函数会断开由postgres_fdw
从本地会话到外部服务器之间建立的,所有打开连接。
如果这些连接在当前本地事务中被使用,它们不会被断开,并且会报告警告消息。
如果至少断开了一个连接,该函数返回true
,否则返回false
。
函数的示例用法:
postgres=# SELECT postgres_fdw_disconnect_all(); postgres_fdw_disconnect_all ----------------------------- t
postgres_fdw
在第一个使用关联到外部服务器的外部表的查询期间建立一个到外部服务器的连接。默认地这个连接会被保持,并被重用于同一个会话中的后续查询。这个行为可以通过外部服务器的keep_connections
选项来控制,如果使用了多个用户实体(用户映射)来访问外部服务器,会为每一个用户映射建立一个连接。
当更改外部服务器或用户映射的定义或删除它们时,相关的连接可能会关闭。但是请注意,如果在当前本地事务中使用任何连接,则将其保留到事务结束。已关闭的连接将在未来使用一个外部表的查询时重新建立。
一旦与外部服务器建立了连接,默认情况下会一直保持直到相应本地或远程会话退出。如果想显式断开一个连接,可以将外部服务器的keep_connections
选项禁用,或使用postgres_fdw_disconnect
和postgres_fdw_disconnect_all
函数。例如,这些函数对于关闭不再需要的连接很有用,从而释放外部服务器上的连接。
在一个引用外部服务器上任何远程表的查询期间,如果还没有根据当前的本地事务打开一个远程事务,postgres_fdw
将在远程服务器上打开一个事务。当本地事务提交或中止时,远程事务也被提交或中止。保存点也相似地采用创建相应的远程保存点来管理。
当本地事务为SERIALIZABLE
隔离级别时,远程事务使用SERIALIZABLE
隔离级别;否则它使用REPEATABLE READ
隔离级别。如果一个查询在远程服务器上执行多个表查询,这种选择保证它将为所有扫描得到快照一致的结果。一种后果是在单一事务中的后继查询将会看到来自远程服务器的相同数据,即便由于其他活动在远程服务器上发生了其他并发更新。如果本地事务使用SERIALIZABLE
或REPEATABLE READ
隔离级别,这种行为也是可以预期的,但是对于一个READ COMMITTED
本地事务它是奇怪的。一个未来的PostgreSQL发布可能会修改这些规则。
请注意postgres_fdw
当前不支持为两阶段提交准备远程事务。
postgres_fdw
尝试优化远程查询来减少从外部服务器传来的数据量。这可以通过把查询的WHERE
子句发送给远程服务器执行来完成,并且还可以不检索当前查询不需要的表列。为了降低查询被误执行的风险,除非WHERE
子句使用的数据类型、操作符和函数都是内建的或者属于列在该外部服务器的extensions
选项中的一个扩展,将不会把WHERE
子句发送到远程服务器。这些子句中的操作符合函数也必须是IMMUTABLE
。对于UPDATE
或者DELETE
查询,
如果没有不能发送给远程服务器的WHERE
子句、
没有查询的本地连接、目标表上没有本地的行级BEFORE
或AFTER
触发器或存储生成的列,
并且没有来自父视图的CHECK OPTION
约束,postgres_fdw
会尝试通过将整个查询发送给远程服务器来优化查询的执行。在UPDATE
中,赋值给目标列的表达式只能使用内建数据类型、IMMUTABLE
操作符或者IMMUTABLE
操作符,这样能降低查询被误执行的风险。
当postgres_fdw
碰到同一个外部服务器上的外部表之间的连接时,它会把整个连接发送给外部服务器,除非由于某些原因它认为逐个从每一个表取得行的效率更高或者涉及的表引用属于不同的用户映射。在发送JOIN
子句时,它也会采取和上述WHERE
子句相同的预防措施。
实际被发送到远程服务器执行的查询可以使用EXPLAIN VERBOSE
来检查。
在postgres_fdw
开启的远程会话中,search_path参数只被设置为pg_catalog
,因此只有内建对象可以在无模式限定时可见。这对于postgres_fdw
本身产生的查询来说不是问题,因为它总是会提供这样的限定。不过,这可能会对在远程服务器上通过触发器或者远程表上的规则执行的函数带来灾难。例如,如果一个远程表实际是一个视图,任何在该视图中使用的函数都将被在这个受限的搜索路径中执行。我们推荐在这类函数中用模式限定所有名称,或者为这类函数附着SET search_path
选项(见CREATE FUNCTION)来建立它们所期望的搜索路径环境。
postgres_fdw
同样为各种参数建立远程会话设置:
TimeZone设置为UTC
DateStyle设置为ISO
IntervalStyle设置为postgres
对于远程服务器9.0和更新版本,extra_float_digits
设置为3
,并且针对更老版本设置为2
这些不如search_path
有那么多问题,但是如果需要也可以使用函数
SET
选项来处理。
我们不推荐通过更改这些参数的会话级设置来推翻这种行为,这很可能会导致postgres_fdw
故障。
postgres_fdw
能够与最老是PostgreSQL 8.3 的远程服务器一起使用。只读能力则最低可以在 8.1 中使用。但是一个限制是postgres_fdw
通常假定不变的内建函数和操作符是安全的,如果它们出现在一个外部表的WHERE
子句中,它们可以发送给远程服务器执行。因此,由于一个由于远程服务器的发布可能被发送给它来执行而被增加的内建函数,会导致“function does not exist”或一个类似的错误。这类错误可以通过重写查询来解决,例如通过嵌入在一个带OFFSET 0
的子SELECT
中引用的外部表作为一种优化墙,并且把出问题的函数或操作符放在子SELECT
的外部。
postgres_fdw.application_name
(string
)
指定一个值用于application_name配置参数,
当postgres_fdw
建立到外部服务器的连接时使用。
这将覆盖服务器对象的application_name
选项。
请注意,更改此参数不会影响任何现有的连接,直到它们重新建立连接。
postgres_fdw.application_name
可以是任意长度的任意字符串,甚至可以包含非ASCII字符。
但是当它被传递并用作外部服务器中的application_name
时,请注意它将被截断为少于NAMEDATALEN
个字符,
并且除了可打印的ASCII字符之外的任何字符都将被替换为问号(?
)。
有关详细信息,请参见application_name。
%
字符开始“转义序列”,这些序列将被下面概述的状态信息替换。
未识别的转义将被忽略。其他字符将直接复制到应用程序名称中。
请注意,在选项之前和%
之后不允许指定加号/减号或数字文字,用于对齐和填充。
转义 | 效果 |
---|---|
%a | 本地服务器上的应用程序名称 |
%c | 本地服务器上的会话ID (详细信息请参见log_line_prefix) |
%C | 本地服务器上的集群名称 (详细信息请参见cluster_name) |
%u | 本地服务器上的用户名称 |
%d | 本地服务器上的数据库名称 |
%p | 本地服务器上后端的进程ID |
%% | 字面量 % |
例如,假设用户local_user
从数据库local_db
建立连接到foreign_db
,
作为用户foreign_user
,设置'db=%d, user=%u'
被替换为'db=local_db, user=local_user'
。
这里是一个用postgres_fdw
创建外部表的例子。首先安装该扩展:
CREATE EXTENSION postgres_fdw;
然后使用CREATE SERVER创建一个外部服务器。在这个例子中我们希望连接到一个位于主机192.83.123.89
上并且监听5432
端口的PostgreSQL服务器。在该远程服务器上要连接的数据库名为foreign_db
:
CREATE SERVER foreign_server FOREIGN DATA WRAPPER postgres_fdw OPTIONS (host '192.83.123.89', port '5432', dbname 'foreign_db');
需要用CREATE USER MAPPING定义一个用户映射来标识在远程服务器上使用哪个角色:
CREATE USER MAPPING FOR local_user SERVER foreign_server OPTIONS (user 'foreign_user', password 'password');
现在就可以使用CREATE FOREIGN TABLE创建外部表了。在这个例子中我们希望访问远程服务器上名为some_schema.some_table
的表。它的本地名称是foreign_table
:
CREATE FOREIGN TABLE foreign_table ( id integer NOT NULL, data text ) SERVER foreign_server OPTIONS (schema_name 'some_schema', table_name 'some_table');
CREATE FOREIGN TABLE
中声明的列数据类型和其他性质必须要匹配实际的远程表。列名也必须匹配,不过也可以为个别列附上column_name
选项以表示它们在远程服务器上对应哪个列。在很多情况中,要手工构造外部表定义,使用IMPORT FOREIGN SCHEMA
会更好。
Shigeru Hanada <shigeru.hanada@gmail.com>