PostgreSQL中如何通过源数据名称匹配目标表名并查询对应表数据

我明白你遇到的困扰了——你想通过source_name找到对应的目标表名，然后直接查询那张表的数据，但之前尝试的静态SQL和DO块都没法返回你需要的结果。让我一步步拆解问题，给你靠谱的解决方案：

为什么之前的方法行不通？ #

• CTE/子查询的问题：这些写法只是把target_name作为字符串返回，PostgreSQL在静态SQL中不会自动把字符串解析成表名。静态SQL要求表名是固定的标识符，不能是动态计算出来的字符串值。
• DO块的问题：DO块是用来执行无返回值的PL/pgSQL代码的，它确实会执行你写的动态SELECT语句，但不会把查询结果返回给客户端，所以你看不到任何输出。

解决方案1：创建PL/pgSQL函数返回动态结果 #

最可靠的方式是写一个自定义函数，它接收source_name参数，动态生成查询并返回对应表的数据。因为不同业务表的结构可能不一样，这里提供两种灵活的实现方式：

方式A：返回通用record类型（需调用时指定列结构） #

CREATE OR REPLACE FUNCTION get_table_data(p_source_name text)
RETURNS SETOF record AS $$
DECLARE
    v_target_table text;
BEGIN
    -- 先获取对应的目标表名
    SELECT target_name INTO v_target_table
    FROM all_table
    WHERE source_name = p_source_name;

    -- 处理找不到对应表的情况
    IF v_target_table IS NULL THEN
        RAISE EXCEPTION 'No target table found for source: %', p_source_name;
    END IF;

    -- 执行动态查询并返回结果（%I自动转义标识符，避免SQL注入）
    RETURN QUERY EXECUTE format('SELECT * FROM %I', v_target_table);
END;
$$ LANGUAGE plpgsql;

调用示例（需要指定返回列的名称和类型，匹配目标表结构）：

SELECT * FROM get_table_data('personal data') AS t(first_name text, second_name text, birthday timestamp);

方式B：返回游标（适合应用程序场景） #

如果你的业务表结构多变，或者需要在应用中灵活处理结果，用游标会更方便：

CREATE OR REPLACE FUNCTION get_table_data_cursor(p_source_name text, OUT ref refcursor) AS $$
DECLARE
    v_target_table text;
BEGIN
    SELECT target_name INTO v_target_table
    FROM all_table
    WHERE source_name = p_source_name;

    IF v_target_table IS NULL THEN
        RAISE EXCEPTION 'No target table found for source: %', p_source_name;
    END IF;

    OPEN ref FOR EXECUTE format('SELECT * FROM %I', v_target_table);
END;
$$ LANGUAGE plpgsql;

psql中调用示例：

BEGIN;
SELECT get_table_data_cursor('login data');
FETCH ALL FROM "<unnamed portal 1>"; -- 游标名称以实际返回值为准
COMMIT;

解决方案2：在psql客户端用变量快速实现 #

如果你只是在psql命令行中临时操作，可以用psql的变量功能简化流程：

-- 第一步：将目标表名存入变量
\set target_table `SELECT target_name FROM all_table WHERE source_name='personal data';`

-- 第二步：执行动态查询
SELECT * FROM :"target_table" LIMIT 10;

关键注意事项 #

• 始终用%I代替%s：在format函数中使用%I会自动对表名、列名这类标识符进行转义，避免SQL注入风险，同时兼容包含特殊字符的标识符。
• 必须做空值检查：如果传入的source_name不存在，一定要抛出明确错误，避免执行无效的SQL语句。

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