方法一：使用 dblink 擴展
dblink 是 PostgreSQL 的內置擴展，允許在一個數據庫會話中執行遠程 SQL 查詢。
步驟 1：在源數據庫中啟用 dblink 擴展
CREATE EXTENSION IF NOT EXISTS dblink;
步驟 2：執行跨庫查詢
-- 簡單查詢示例（需提供目標數據庫連接信息）
SELECT *
FROM dblink('dbname=target_db user=username password=password host=localhost port=5432','SELECT column1, column2 FROM target_table'
) AS remote_table(column1 datatype, column2 datatype);-- 帶參數的查詢示例
SELECT *
FROM dblink('dbname=target_db user=username password=password',format('SELECT * FROM target_table WHERE id = %L', 1)
) AS t(column1 datatype, column2 datatype);
優點
- 無需在目標數據庫上進行任何配置。
- 簡單靈活，適合臨時查詢。
缺點
- 需要在每個 SQL 語句中顯式提供連接信息（或使用
dblink_connect預先建立連接）。 - 性能相對較低，適合小規模數據交互。
方法二：使用外部數據包裝器（FDW）
FDW 提供更高級的跨庫訪問能力，允許將遠程表映射為本地表。
步驟 1：在源數據庫中啟用 postgres_fdw 擴展
CREATE EXTENSION IF NOT EXISTS postgres_fdw;
步驟 2：創建服務器對象
CREATE SERVER target_server
FOREIGN DATA WRAPPER postgres_fdw
OPTIONS (host 'localhost', port '5432', dbname 'target_db');
步驟 3：創建用戶映射
CREATE USER MAPPING FOR current_user
SERVER target_server
OPTIONS (user 'username', password 'password');
步驟 4：導入遠程表
-- 手動創建外部表
CREATE FOREIGN TABLE remote_table (column1 datatype,column2 datatype
)
SERVER target_server
OPTIONS (schema_name 'public', table_name 'target_table');-- 或批量導入遠程模式中的所有表
IMPORT FOREIGN SCHEMA public
FROM SERVER target_server
INTO current_schema;
步驟 5：查詢外部表
SELECT * FROM remote_table;
優點
- 遠程表被映射為本地表，查詢語法更自然。
- 支持事務和分布式查詢。
- 性能較好，適合頻繁訪問。
缺點
- 需要在目標數據庫上有訪問權限。
- 配置相對復雜，需要維護服務器和用戶映射。
安全注意事項
- 連接信息存儲：避免在代碼中硬編碼用戶名和密碼，建議使用環境變量或配置文件。
- 權限控制：
- 對
dblink或外部表的訪問權限應僅授予需要的用戶。 - 在目標數據庫上創建只讀用戶，減少安全風險。
- 對
- 連接池：高并發場景下建議使用連接池工具（如 PgBouncer）管理跨庫連接。
選擇建議
- 臨時查詢：使用
dblink。 - 頻繁數據交互：使用 FDW。
- 跨版本兼容：優先使用 FDW（支持不同版本的 PostgreSQL 互訪）。
根據具體場景選擇合適的方法，可有效提升跨庫操作的效率和安全性。
