PostgreSQL跨数据库调用存储过程：dblink可行性及替代方案

一、dblink完全支持跨数据库调用存储过程 #

是的，dblink可以实现跨PostgreSQL数据库调用存储过程，前提是先在当前数据库中安装dblink扩展：

CREATE EXTENSION IF NOT EXISTS dblink;

根据存储过程是否返回结果集，有两种调用方式：

1. 调用无返回值的存储过程 #

使用dblink_exec函数执行无返回结果的命令，适合执行仅做数据修改或无输出的存储过程：

SELECT dblink_exec(
    'dbname=target_db user=db_user password=db_pwd host=127.0.0.1 port=5432',
    'CALL your_procedure(''param1'', 123);'
);

• 第一个参数是目标数据库的连接字符串，按需替换参数值
• 第二个参数是调用存储过程的SQL语句，注意字符串参数的转义

2. 调用有返回值的存储过程 #

如果存储过程返回结果集，使用dblink函数配合自定义结果集结构进行接收：

SELECT * FROM dblink(
    'dbname=target_db user=db_user password=db_pwd host=127.0.0.1 port=5432',
    'CALL your_return_procedure(456);'
) AS result_set(id INT, name VARCHAR(50), create_time TIMESTAMP);

• 需要在AS子句中定义与存储过程返回结果匹配的列名和数据类型

注意事项 #

• 确保当前数据库用户拥有dblink扩展的使用权限，同时目标数据库用户拥有调用目标存储过程的权限
• 跨库调用无法参与本地事务的ACID保证，需手动处理事务一致性问题
• 连接字符串可通过~/.pgpass文件存储密码，避免明文暴露

二、不使用dblink的替代方案 #

1. PostgreSQL Foreign Data Wrapper (FDW) #

适合频繁跨库访问的场景，通过映射外部数据库对象实现本地调用：

1. 安装postgres_fdw扩展：

CREATE EXTENSION IF NOT EXISTS postgres_fdw;

2. 创建外部服务器：

CREATE SERVER target_server
FOREIGN DATA WRAPPER postgres_fdw
OPTIONS (dbname 'target_db', host '127.0.0.1', port '5432');

3. 创建用户映射：

CREATE USER MAPPING FOR current_user
SERVER target_server
OPTIONS (user 'db_user', password 'db_pwd');

4. 调用存储过程：

-- 无返回值存储过程
PERFORM dblink_exec('target_server', 'CALL your_procedure(''param1'', 123);');
-- 有返回值存储过程
SELECT * FROM dblink('target_server', 'CALL your_return_procedure(456);') AS result_set(id INT, name VARCHAR(50));

2. 应用层中转 #

如果数据库层面的跨库调用受限于权限或配置，可以在应用程序中分别建立两个数据库的连接，通过代码逻辑依次调用本地逻辑和目标库的存储过程。这种方式更灵活，能更好控制事务流程，但需要在应用层处理跨库交互逻辑。

内容的提问来源于stack exchange，提问作者El_L