PostgreSQL：如何将dblink查询结果存储至数组？

错误原因 #

你遇到的错误是因为dblink返回的是多行单个UUID值，但你在定义远程结果列时错误地指定为UUID ARRAY类型。PostgreSQL会尝试把每行的单个UUID字符串解析成数组，而单个UUID并不符合数组字面量（需要以{开头），因此抛出格式错误。

正确实现方式 #

有两种可行的方法将远程查询的UUID结果存入数组：

方法一：远程端聚合为数组（推荐，减少数据传输） #

在远程查询中使用array_agg()函数直接将所有UUID聚合为一个数组，再返回给本地：

DO $$
DECLARE
    my_arr UUID ARRAY;
    i UUID;
BEGIN
    -- 先确保dblink扩展已启用：CREATE EXTENSION IF NOT EXISTS dblink;
    SELECT * INTO my_arr
    FROM dblink('my_conn', 'SELECT array_agg(uuid_column) FROM my_table') 
    AS remote_result(agg_uuids UUID ARRAY);

    FOREACH i IN ARRAY my_arr
    LOOP
        RAISE NOTICE '%', i;
    END LOOP;
END $$;

方法二：本地端聚合多行结果 #

如果需要先对远程返回的每行数据做额外处理，再在本地聚合为数组：

DO $$
DECLARE
    my_arr UUID ARRAY;
    i UUID;
BEGIN
    SELECT array_agg(uuid_col) INTO my_arr
    FROM dblink('my_conn', 'SELECT uuid_column FROM my_table') 
    AS remote_result(uuid_col UUID);

    FOREACH i IN ARRAY my_arr
    LOOP
        RAISE NOTICE '%', i;
    END LOOP;
END $$;

注意事项 #

• 如果远程表的uuid_column存在NULL值，array_agg()会自动忽略这些NULL。若需保留NULL，可使用array_agg(uuid_column ORDER BY uuid_column)（排序可选），或添加过滤条件array_agg(uuid_column) FILTER (WHERE uuid_column IS NOT NULL)按需筛选。
• 执行前需确保已启用dblink扩展，若未启用，执行CREATE EXTENSION IF NOT EXISTS dblink;即可。

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