一.安装下载 dblink
create extension if not exists dblink
查看是否已经安装
select * from pg_extension;
二.运行,查询数据
其中,第一个参数是dblink名字,也可以是连接字符串。
第二个参数是要执行的SQL查询语句。AS子句用于指定返回结果的列名和数据类型。
SELECT *
FROM dblink('dbname=xxx user=xxx password=xxxx host=xxx port=xxxx',
'SELECT tablename FROM pg_catalog.pg_tables WHERE schemaname=''public''')
AS t(tablename text);
长期连接注意需要关闭连接,本身不会自动关闭连接
SELECT dblink_connect(text connstr)
-- 使用一个单独的查询来关闭连接
SELECT dblink_disconnect();
另外需要注意是否在public下,不在public下,在public下运行会错误
查询在哪个模式下
SELECT n.nspname as "Schema",
p.proname as "Name",
pg_catalog.pg_get_function_result(p.oid) as "Result data type",
pg_catalog.pg_get_function_arguments(p.oid) as "Argument data types"
FROM pg_catalog.pg_proc p
LEFT JOIN pg_catalog.pg_namespace n ON n.oid = p.pronamespace
WHERE p.proname = 'dblink'
ORDER BY 1, 2, 4;