更新时间：2026-07-28 GMT+08:00
操作指导
前置操作
- 连接GaussDB数据库时，需要在远程数据库节点机器上设置允许DATABASE LINK进行访问，并配置远程连接。某些情况集群白名单中也需要添加DN的IP。
- 创建DATABASE LINK。
- 创建DATABASE LINK对象，具体语法请参见《参考》中“SQL参考 > SQL语法 > C > CREATE DATABASE LINK”章节。
- 创建DATABASE LINK时可指定PUBLIC或PRIVATE，PRIVATE DATABASE LINK仅能被创建者进行访问，PUBLIC DATABASE LINK可被所有用户进行访问。所有已创建的DATABASE LINK信息都存放在本地数据库的系统视图GS_DB_LINKS中。
- 修改DATABASE LINK信息。
修改指定DATABASE LINK对象信息，具体语法请参见《参考》中“SQL参考 > SQL语法 > A > ALTER DATABASE LINK”章节。
- 删除指定DATABASE LINK。
删除指定DATABASE LINK对象，具体语法请参见《参考》中“SQL参考 > SQL语法 > D > DROP DATABASE LINK”语句。
- 通过DATABASE LINK进行SELECT操作。
[ WITH [ RECURSIVE ] with_query [, ...] ] SELECT [/*+ plan_hint */] [ ALL | DISTINCT [ ON ( expression [, ...] ) ] ] { * | {expression [ [ AS ] output_name ]} [, ...] } [ FROM from_item [, ...] ] [ WHERE condition ] [ [ START WITH condition ] CONNECT BY [NOCYCLE] condition [ ORDER SIBLINGS BY expression ] ] [ GROUP BY grouping_element [, ...] ] [ HAVING condition [, ...] ] [ { UNION | INTERSECT | EXCEPT | MINUS } [ ALL | DISTINCT ] select ] [ ORDER BY {expression [ [ ASC | DESC | USING operator ] | nlssort_expression_clause ] [ NULLS { FIRST | LAST } ]} [, ...] ] [ LIMIT { [offset,] count | ALL } ] [ OFFSET start [ ROW | ROWS ] ] [ {FOR { UPDATE | SHARE } [ OF table_name [, ...] ] } [...] ]; {[ ONLY ] table_name [ * ] @ dblink [ [ AS ] alias [ ( column_alias [, ...] ) ] ] |( select ) [ AS ] alias [ ( column_alias [, ...] ) ] |with_query_name [ [ AS ] alias [ ( column_alias [, ...] ) ] ] | [function_name] ( [ argument [, ...] ] ) [ AS ] alias [ ( column_alias [, ...] | column_definition [, ...] ) ] | [function_name] ( [ argument [, ...] ] ) AS ( column_definition [, ...] ) |from_item [ NATURAL ] join_type from_item [ ON join_condition | USING ( join_column [, ...] ) ]}; - 通过DATABASE LINK进行INSERT操作。
[ WITH [ RECURSIVE ] with_query [, ...] ] INSERT [/*+ plan_hint */] INTO table_name @ dblink [ ( column_name [, ...] ) ] { DEFAULT VALUES | VALUES {( { expression | DEFAULT } [, ...] ) }[, ...] | query } [ RETURNING { {output_expression [ [ AS ] output_name ] }[, ...]} ]; - 通过DATABASE LINK进行UPDATE操作。
UPDATE [/*+ plan_hint */] [ ONLY ] table_name @ dblink [ [ AS ] alias ] SET {column_name = { expression | DEFAULT } |( column_name [, ...] ) = {( { expression | DEFAULT } [, ...] ) |sub_query }}[, ...] [ FROM from_list] [ WHERE condition ] [ ORDER BY {expression [ [ ASC | DESC | USING operator ] | nlssort_expression_clause ] [ NULLS { FIRST | LAST } ]} [, ...] ] [ LIMIT { [offset,] count | ALL } ] [ RETURNING { {output_expression [ [ AS ] output_name ]} [, ...] }]; where sub_query can be: SELECT [ ALL | DISTINCT [ ON ( expression [, ...] ) ] ] { * | {expression [ [ AS ] output_name ]} [, ...] } [ FROM from_item [, ...] ] [ WHERE condition ] [ GROUP BY grouping_element [, ...] ] [ HAVING condition [, ...] ]; - 通过DATABASE LINK进行DELETE操作。
[ WITH [ RECURSIVE ] with_query [, ...] ] DELETE [/*+ plan_hint */] FROM [ ONLY ] table_name @ dblink [ [ AS ] alias ] [ USING using_list ] [ WHERE condition] [ ORDER BY {expression [ [ ASC | DESC | USING operator ] | nlssort_expression_clause ] [ NULLS { FIRST | LAST } ]} [, ...] ] [ LIMIT { [offset,] count | ALL } ] [ RETURNING { { output_expr [ [ AS ] output_name ] } [, ...] } ]; - 通过DATABASE LINK进行LOCK TABLE操作。
LOCK [ TABLE ] {[ ONLY ] name @ dblink [, ...]} [ IN {ACCESS SHARE | ROW SHARE | ROW EXCLUSIVE | SHARE UPDATE EXCLUSIVE | SHARE | SHARE ROW EXCLUSIVE | EXCLUSIVE | ACCESS EXCLUSIVE} MODE ] [ NOWAIT ]; - 调用远程数据库的存储过程或函数。
1CALL | SELECT [ schema. ] { func_name@dblink | procedure_name@dblink } ( param_expr );
- 使用已创建的DATABASE LINK对远程数据库对象进行访问的语法和访问本地对象的语法基本一致，区别在于，当访问远程数据库对象时，需在被访问的远程数据库对象名称后添加@dblink。SQL语句具体支持情况存在部分约束条件，具体请参见表2。
- 上述语法中SQL语句涉及到的DATABASE LINK无关参数含义与原SQL语句中含义相同。
- 执行涉及到远程表的连接查询，需要指定列名时，可以在列名后添加“@dblink”，表示指定的列为DATABASE LINK指向的远程表的列，远程表的列不支持*写法，如：remote_t1.*@dblink。
规格约束
- 兼容性约束
- DATABASE LINK特性仅在ORA兼容模式数据库下可以使用。
- DATABASE LINK特性只支持连接GaussDB。
- 当通过DATABASE LINK连接GaussDB时，用户需要保证本地和远程数据库的兼容性参数DBCOMPATIBILITY和GUC参数behavior_compat_options、a_format_dev_version、a_format_version取值一致。
- 连接GaussDB时，DATABASE LINK开启远程连接事务前，会自动设置如下GUC参数：
SET search_path=pg_catalog, '$user', 'public'; SET explain_perf_mode='normal'; SET session_timeout=0; SET datestyle=ISO; SET intervalstyle=postgres; SET extra_float_digits=3;
其余参数为远程数据库设置的参数，远程参数与本地参数不同时，可能会出现数据显示格式不一致等情况，使用时应尽量保证远程与本地参数相同。
- 连接GaussDB时，远程数据库与本地数据库需要保证相同的datea类型，GUC参数mapping_date_to_datea才能正常使用。
- 字符集约束
当连接GaussDB时，如果本地数据库和远程数据库字符集不同，可能会出现无法转换，并返回远程的报错信息的情况。当本地数据库字符编码为GB18030_2022时，发送到远程的请求字符编码会被转换为GB18030。因此，若本地数据库的字符集为GB18030_2022时，远程数据库字符集只能是GB18030或GB18030_2022。
- 权限约束
- 禁止使用DATABASE LINK连接初始用户。禁止初始用户进行创建、修改和删除DATABASE LINK对象的操作。
- 创建DATABASE LINK权限需要使用GRANT语法赋予，新建用户默认无权限，系统管理员拥有权限。具体请参见《参考》中“SQL参考 > SQL语法 > G > GRANT”章节。
- 当赋予用户创建DATABASE LINK权限时，即默认许可用户使用远程数据库的IP地址对其进行访问。若不希望存在该情况，请不要使用GRANT对用户赋权。
- 连接约束
- 当未指定CURRENT_USER或CONNECT TO连接串时（即使用当前数据库初始用户名和空的密码连接），会连接失败。
- 非透明多写特性下，使用本机IP及对应端口可连接当前实例数据库。由于CN和DN可能分布在不同服务器中，建议host参数不要使用127.0.0.1和localhost，可能会出现连接失败的情况。
- DATABASE LINK创建时，不会对其是否可连接成功进行验证，如果缺乏相关的关键字，可能会在使用时报错。
- 如果在创建DATABASE LINK对象后重新生成密钥文件，使用DATABASE LINK时将会报错。因为创建DATABASE LINK时使用的密钥文件与后续解密时使用的密钥文件不一致。
- OPTION选项中conn_opt不支持设置密码且传入的libpq参数不能和原有参数重复。
- 升级约束
- 元数据和锁相关约束
- 使用DATABASE LINK对远程表操作时，会在本地创建与远程对应的Schema，若本地不存在该表的元数据信息，会将元数据信息写入本地系统表中，此时会使用7级锁保证写入的一致性，持续到事务结束后释放锁，删除DATABASE LINK时会将相应的元数据信息删除。
- 使用DATABASE LINK时，在本地创建的表仅用于存储远程表的元数据信息，无法通过\d或pg_get_tabledef函数查询该表的结构。
- 如果业务中存在长事务首次使用DATABASE LINK操作远程对象时，会持续持锁直到事务结束，其他首次使用DATABASE LINK的事务会被阻塞。可通过对远程对象进行简单查询操作，使其元数据快速缓存到本地进行规避该情况。另外，远程表结构发生变化时，本地要更新存储的元数据信息，也会有类似阻塞情况。
- 在本地创建与远程对应的Schema时，本地的Schema名称长度上限为63，格式为“[username#]远程Schema@dblink_name”，其中DATABASE LINK为PRIVATE时，username#不可省略。
- 由于部分谓词无法下推，通过DATABASE LINK在使用UPDATE、DELETE及FOR UPDATE功能时，加锁的范围可能会扩大，可通过打印计划查询下推语句判断加锁范围。
- 使用DATABASE LINK对远程表操作时，会创建一个单节点的node group随机绑定一个DN。
- 事务约束
使用DATABASE LINK时，本地事务和远程事务存下以下关系：
- 本地事务会同步控制远程事务的提交/回滚状态。
- 隔离级别的对应关系如表1所示。
表1 连接非透明多写特性下GaussDB数据库隔离级别对应关系表 本地隔离级别
远程隔离级别
Read Uncommitted
Repeatable Read
Read Committed
Repeatable Read
Repeatable Read
Repeatable Read
Serializable
Serializable
- 本地事务提交过程中会向远程发送事务提交请求，如果远程事务提交成功后出现异常情况导致本地的事务提交失败（如连接异常、本地集群实例异常等情况），远程的事务提交无法被撤回，可能出现本地事务与远程事务不一致的情况。
- DATABASE LINK不支持XA协议接口，可能出现本地事务与远程事务不一致的情况。
- 支持SQL范围约束
- DATABASE LINK函数和存储过程调用约束
- 仅在非透明多写特性下支持通过DATABASE LINK连接调用远程函数或者存储过程。
- 当通过DATABASE LINK调用远程数据库中的函数时，本地数据库需创建与远程函数名称和参数列表完全一致的函数，若远程函数存在重载，则需要在本地数据库创建对应的所有重载函数，否则会导致参数匹配失败。
- DATABASE LINK调用远程数据库的存储过程和函数时，参数或返回值类型不能包含自定义类型，不支持OUT/INOUT参数或有默认值的参数，并且不能为PACKAGE内函数、聚集函数、窗口函数以及返回集合的函数；不支持使用SELECT * FROM func@dblink();形式调用远程函数。
- PLSQL_BODY内通过DATABASE LINK调用远程数据库的存储过程或函数时，参数或返回值类型不能包含自定义类型，不支持OUT/INOUT参数或有默认值的参数，并且不能为PACKAGE内函数、重载函数、聚集函数、窗口函数以及返回集合的函数。
- DATABASE LINK调用远程数据库的存储过程和函数不指定Schema，默认调用PUBLIC下的函数或存储过程。
- DATABASE LINK调用远程数据库的存储过程和函数时，参数列表不支持通过“:=”或者“=>”的方式为参数赋值。
- PLSQL_BODY内调用远程数据库的存储过程或函数时，应使用[CALL | SELECT] [ schema. ] { func_name@dblink | procedure_name@dblink } ( param_expr )的语法格式调用。
- PLSQL_BODY内调用远程数据库的无参存储过程或函数时，应使用[CALL | SELECT] [ schema. ] { func_name@dblink | procedure_name@dblink } ( )的语法格式调用。
- 同义词
- 不支持将DATABASE LINK名创建为一个同义词的使用方法。
- 当使用DATABASE LINK访问的远程对象创建为同名词时，若未指定远程对象的Schema，则默认采用创建同义词的当前Schema作为远程对象的Schema。
- 不支持通过DATABASE LINK调用远程数据库中指向一个DATABASE LINK对象的同义词。例如：
- 在数据库a（db1）中创建表a（table1）。
- 在数据库b（db2）中创建连接数据库a（db1）的DATABASE LINK对象（dblink1），并创建同义词（CREATE SYNONYM table11 FOR user1.table1@dblink1";）。
- 在数据库c（db3）创建连接数据库b（db2）的DATABASE LINK对象（dblink2），通过dblink2调用数据库b（db2）上的同义词table11（执行SELECT * FROM table11 @dblink2;，会返回“If the remote synonym is a dblink object, dblink access is not supported”的报错信息）。
- 创建同义词的注意事项请参见《参考》中 “SQL参考 > SQL语法 > C > CREATE SYNONYM”章节。
- 表类型约束
- 视图约束 目前支持对DATABASE LINK的远程表创建视图，当远程表本身的结构发生变化时，该视图使用时会触发视图重编译，支持视图失效重编译后均为该行为，不受参数enable_view_invalidation影响。例如：
- 在数据库db1中创建表table1。
- 在数据库db2中创建连接数据库db1的DATABASE LINK对象dblink1，并创建视图view1（CREATE VIEW view1 AS SELECT * FROM table1@dblink1;）。
- 在数据库db1中删除表table1的一列，在数据库db2上查询视图view1会重编译该视图，且重编译失败，并产生重编译失败报错。
- 在数据库db1中恢复表table1删除列，在数据库db2上查询视图view1会重编译该视图，且重编译成功，并正常返回查询结果。
- 其他场景
- DATABASE LINK表不支持触发器，包括触发器调用函数内使用DATABASE LINK场景、触发器调用函数为DATABASE LINK函数、在DATABASE LINK上定义触发器等情况。
- 暂不支持UPSERT、MERGE语法。
- 不支持CURRENT CURSOR语法。
- 不支持查询表的隐藏字段。
- 不支持DATABASE LINK访问远端类型。
- 直连DN无法使用DATABASE LINK功能。
- DUMP与备份约束
- 不支持DATABASE LINK相关数据库对象的DUMP，备机不支持DATABASE LINK调用，也不支持被DATABASE LINK连接。
- 不支持DATABASE LINK相关数据库对象的集群备份后恢复使用。因为不同集群的密钥文件不同，在使用 DATABASE LINK 时需要使用集群密钥文件进行解密。
- JOIN下推约束
- 谓词下推约束
- 仅支持WHERE子句使用数据库内置的数据类型、操作符和函数，并且使用的函数为IMMUTABLE类型。
- 不支持WHERE子句中同时使用到多张表的条件下推。
- 聚集函数下推约束
仅支持单表且没有GROUP子句、ORDER BY子句、HAVING子句、LIMIT子句的SELECT语句，并且不支持窗口函数。
- HINT下推 支持针对DATABASE LINK表对象的Hint条件下推，仅限Scan方式的Hint下推，语法格式如下：
[no] tablescan|indexscan|indexonlyscan(table [index])
并要求在一个queryblock中的表名或表别名不能重复。
表2 支持SQL范围 SQL类型
操作对象
支持选项说明
执行上下文
创建DATABASE LINK
DATABASE LINK
-
普通事务块、存储过程、函数以及高级包。
修改DATABASE LINK
DATABASE LINK
仅支持用户名、密码的修改。
普通事务块、存储过程、函数以及高级包。
删除DATABASE LINK
DATABASE LINK
-
普通事务块、存储过程、函数以及高级包。
SELECT语句
普通表、普通视图、全量物化视图
- WHERE子句
- DATABASE LINK表和内部表JOIN
- DATABASE LINK表和DATABASE LINK表JOIN
- 聚集函数
- ORDER BY子句
- WINDOW子句
- LIMIT、OFFSET、FETCH子句
- GROUP BY子句、HAVING子句
- UNION子句
- WITH子句
- START WITH子句和CONNECT BY子句
- ROWNUM使用
- PIVOT子句
- UNPIVOT子句
- FOR UPDATE子句 说明：
仅支持FOR UPDATE、FOR UPDATE NOWAIT、 FOR UPDATE WAIT用法。
普通事务块、存储过程、函数、高级包以及逻辑视图。
INSERT语句
普通表
- WITH子句
- 多VALUE插入
- RETURNING子句
说明：- 不支持ON DUPLICATE KEY UPDATE子句。
- 不支持INSERT ALL语句。
普通事务块、存储过程、函数以及高级包。
UPDATE语句
普通表
- WITH子句
- LIMIT子句
- ORDER BY子句
- WHERE子句
- RETURNING子句
说明：不支持多表UPDATE操作。
普通事务块、存储过程、函数以及高级包。
DELETE语句
普通表
- WITH子句
- LIMIT子句
- ORDER BY子句
- WHERE子句
- RETURNING子句
说明：不支持多表DELETE操作。
普通事务块、存储过程、函数以及高级包。
LOCK TABLE语句
普通表
- LOCKMODE子句
- NOWAIT子句
普通事务块。
对于分区表，支持PARTITION子句指定分区。
使用示例
连接GaussDB数据库
-- DATABASE LINK相关DDL语句。
-- 前置操作。
gaussdb=# CREATE USER jack WITH PASSWORD '********';
CREATE ROLE
-- 赋予用户创建DATABASE LINK对象的权限。
gaussdb=# GRANT CREATE PUBLIC DATABASE LINK TO jack;
GRANT
-- 赋予用户删除DATABASE LINK对象的权限。
gaussdb=# GRANT DROP PUBLIC DATABASE LINK TO jack;
GRANT ROLE
-- 赋予用户修改DATABASE LINK对象的权限。
gaussdb=# GRANT ALTER PUBLIC DATABASE LINK TO jack;
GRANT ROLE
-- 回收用户创建DATABASE LINK对象的权限。
gaussdb=# REVOKE CREATE PUBLIC DATABASE LINK FROM jack;
REVOKE
-- 回收用户删除DATABASE LINK对象的权限。
gaussdb=# REVOKE DROP PUBLIC DATABASE LINK FROM jack;
REVOKE ROLE
-- 回收用户修改DATABASE LINK对象的权限。
gaussdb=# REVOKE ALTER PUBLIC DATABASE LINK FROM jack;
REVOKE ROLE
-- 清理环境。
gaussdb=# DROP USER jack;
DROP ROLE
-- 前置操作。
-- 创建一个兼容性为ORA的数据库。
gaussdb=# CREATE DATABASE ora_test_db DBCOMPATIBILITY 'ORA';
CREATE DATABASE
-- 切换数据库。
gaussdb=# \c ora_test_db
-- 创建拥有系统管理员权限的用户。
ora_test_db=# CREATE USER local_user WITH SYSADMIN PASSWORD '********';
CREATE ROLE
ora_test_db=# SET ROLE local_user PASSWORD '********';
SET
-- 创建DATABASE LINK对象，host也可以是IPv6地址。
ora_test_db=> CREATE PUBLIC DATABASE LINK dblink CONNECT TO 'remote_user' IDENTIFIED BY '********' USING (host '***.***.***.***', port '*****', dbname 'remote_db');
CREATE DATABASE LINK
-- 修改DATABASE LINK信息。
ora_test_db=> ALTER PUBLIC DATABASE LINK dblink CONNECT TO 'remote_user' IDENTIFIED BY '********';
ALTER DATABASE LINK
-- 删除DATABASE LINK对象。
ora_test_db=> DROP PUBLIC DATABASE LINK dblink;
DROP DATABASE LINK
-- 清理环境。
ora_test_db=> RESET ROLE;
RESET
ora_test_db=# DROP USER local_user;
DROP ROLE
ora_test_db=# \c postgres
gaussdb=# DROP DATABASE ora_test_db;
DROP DATABASE
-- DATABASE LINK具体操作语句。
-- 前置操作。
gaussdb=# CREATE USER local_user WITH SYSADMIN PASSWORD '********';
CREATE ROLE
gaussdb=# CREATE USER remote_user WITH SYSADMIN PASSWORD '********';
CREATE ROLE
-- 创建远程数据库。
gaussdb=# CREATE DATABASE remote_db DBCOMPATIBILITY = 'ORA';
CREATE DATABASE
-- 创建测试DATABASE LINK数据库。
gaussdb=# CREATE DATABASE local_db DBCOMPATIBILITY = 'ORA';
CREATE DATABASE
gaussdb=# \c remote_db
remote_db=# SET ROLE remote_user PASSWORD '********';
SET
remote_db=> CREATE SCHEMA remote_user;
CREATE SCHEMA
-- 创建普通表。
remote_db=> CREATE TABLE remote_tb(f1 int, f2 text, f3 text[]) WITH (STORAGE_TYPE = ASTORE);
CREATE TABLE
remote_db=> INSERT INTO remote_tb VALUES (0,'a','{"a0","b0","c0"}');
INSERT 0 1
remote_db=> INSERT INTO remote_tb VALUES (1,'bb','{"a1","b1","c1"}');
INSERT 0 1
remote_db=> INSERT INTO remote_tb VALUES (2,'cc','{"a2","b2","c2"}');
INSERT 0 1
-- 创建函数。
remote_db=> CREATE OR REPLACE FUNCTION f(a in int, b in int)
RETURN int AS
tmp int := a + b;
BEGIN
RETURN tmp;
END;
/
CREATE FUNCTION
-- 创建同义词。
remote_db=> CREATE SYNONYM remote_sy FOR remote_tb;
CREATE SYNONYM
remote_db=> \c local_db
local_db=# SET ROLE local_user PASSWORD '********';
SET
local_db=> CREATE SCHEMA local_user;
CREATE SCHEMA
local_db=> CREATE TABLE local_tb(f1 int, f2 text, f3 text[]) WITH (STORAGE_TYPE = ASTORE);
CREATE TABLE
local_db=> INSERT INTO local_tb VALUES (2,'c','{"a2","b2","c2"}');
INSERT 0 1
local_db=> CREATE PUBLIC DATABASE LINK dblink CONNECT TO 'remote_user' IDENTIFIED BY '********' USING (HOST '***.***.***.***', PORT '*****', DBNAME 'remote_db'); --host和port需要根据实际情况填写。
CREATE DATABASE LINK
-- 查询远程表。
local_db=> SELECT * FROM remote_tb@dblink ORDER BY f1;
f1 | f2 | f3
----+----+------------
0 | a | {a0,b0,c0}
1 | bb | {a1,b1,c1}
2 | cc | {a2,b2,c2}
(3 rows)
-- 向远程表插入数据。
local_db=> INSERT INTO remote_tb@dblink VALUES (4,'d','{"a1","b2","c3"}');
INSERT 0 1
-- 更新远程表。
local_db=> UPDATE remote_tb@dblink SET f2 = 'aa' WHERE f1 = 0;
UPDATE 1
-- 删除远程表数据。
local_db=> DELETE remote_tb@dblink WHERE f1 = 1;
DELETE 1
-- 本地表JOIN远程表。
local_db=> SELECT * FROM remote_tb@dblink JOIN local_tb ON local_tb.f1 = remote_tb.f1@dblink;
f1 | f2 | f3 | f1 | f2 | f3
----+----+------------+----+----+------------
2 | cc | {a2,b2,c2} | 2 | c | {a2,b2,c2}
(1 row)
-- AGG函数。
local_db=> SELECT count(*) FROM remote_tb@dblink;
count
-------
3
(1 row)
-- 访问远程函数。
local_db=> SELECT f@dblink(1,2);
f
---
3
(1 row)
-- PLSQL_BODY内访问远程函数。
local_db=> CREATE OR REPLACE FUNCTION call_f(a in int, b in int)
RETURN INT AS
tmp int;
BEGIN
tmp := f@dblink(a, b);
RETURN tmp;
END;
/
CREATE FUNCTION
local_db=> SELECT call_f(1, 2);
call_f
--------
3
(1 row)
-- 创建DATABASE LINK对象的同义词。
local_db=> CREATE SYNONYM local_sy FOR remote_user.remote_tb@dblink;
CREATE SYNONYM
local_db=> SELECT * FROM local_sy ORDER BY f1;
f1 | f2 | f3
----+----+------------
0 | aa | {a0,b0,c0}
2 | cc | {a2,b2,c2}
4 | d | {a1,b2,c3}
(3 rows)
-- 访问远程数据库的同义词。
local_db=> SELECT * FROM remote_sy@dblink ORDER BY f1;
f1 | f2 | f3
----+----+------------
0 | aa | {a0,b0,c0}
2 | cc | {a2,b2,c2}
4 | d | {a1,b2,c3}
(3 rows)
-- DATABASE LINK支持部分Hint下推。
local_db=> EXPLAIN (VERBOSE, COSTS off) SELECT /*+ tablescan(remote_sy) */ * FROM remote_sy@dblink;
QUERY PLAN
-----------------------------------------------------------------------------------------
Foreign Scan on "remote_user@dblink".remote_tb remote_sy
Output: f1, f2, f3
Exec Nodes: (dblink#nodegroup#0) datanode1
Remote SQL: SELECT /*+ tablescan(remote_tb) */ f1, f2, f3 FROM remote_user.remote_tb
(4 rows)
-- 查看DATABASE LINK系统表gs_database_link。
local_db=> SELECT dlname,dlowner,options FROM gs_database_link;
dlname | dlowner | options
--------+---------+----------------------------------------------------
dblink | 0 | {host=***.***.***.***,port=*****,dbname=remote_db}
(1 row)
-- 查看DATABASE LINK系统视图gs_db_links。
local_db=> START TRANSACTION;
START TRANSACTION
local_db=> SELECT * FROM remote_sy@dblink ORDER BY f1;
f1 | f2 | f3
----+----+------------
0 | aa | {a0,b0,c0}
2 | cc | {a2,b2,c2}
4 | d | {a1,b2,c3}
(3 rows)
local_db=> SELECT intransaction FROM gs_db_links;
intransaction
---------------
t
(1 row)
local_db=> END;
COMMIT
-- 清理环境。
local_db=> \c postgres
gaussdb=# DROP DATABASE local_db;
DROP DATABASE
gaussdb=# DROP DATABASE remote_db;
DROP DATABASE
gaussdb=# DROP USER local_user;
DROP ROLE
gaussdb=# DROP USER remote_user;
DROP ROLE 父主题： DATABASE LINK
