PL/pgSQL函数跨表查询报错：列不存在问题解决咨询

核心思路：根据列名规则定位目标表 #

你的表与列的命名有明确规律，完全可以在单函数内通过解析列名，将查询精准定位到对应表，避免在不存在目标列的表中执行查询，无需为每个表单独编写函数。

具体实现步骤 #

1. 解析列名提取数字：从传入的列名（如t1010）中剥离前缀t，转换为整数后判断其所属区间。
2. 匹配对应表名：根据数字区间映射到目标表：
   • 1-1000 → Table_1_Furnace_n
   • 1001-2000 → Table_2_Furnace_n
   • 2001-3000 → Table_3_Furnace_n
   • 3001-4000 → Table_4_Furnace_n
3. 生成并执行动态SQL：仅在匹配到的表中执行查询，规避列不存在的报错。

单列查询示例代码 #

CREATE OR REPLACE FUNCTION query_furnace_column(p_col_name text, p_furnace_num int)
RETURNS TABLE (value numeric) AS $$
DECLARE
    v_col_num int;
    v_table_name text;
    v_sql text;
BEGIN
    -- 解析列名，提取数字部分
    v_col_num := regexp_replace(p_col_name, '^t', '', 'g')::int;
    
    -- 根据数字区间确定目标表
    CASE
        WHEN v_col_num BETWEEN 1 AND 1000 THEN
            v_table_name := format('Table_1_Furnace_%s', p_furnace_num);
        WHEN v_col_num BETWEEN 1001 AND 2000 THEN
            v_table_name := format('Table_2_Furnace_%s', p_furnace_num);
        WHEN v_col_num BETWEEN 2001 AND 3000 THEN
            v_table_name := format('Table_3_Furnace_%s', p_furnace_num);
        WHEN v_col_num BETWEEN 3001 AND 4000 THEN
            v_table_name := format('Table_4_Furnace_%s', p_furnace_num);
        ELSE
            RAISE EXCEPTION 'Invalid column name: %', p_col_name;
    END CASE;
    
    -- 生成动态SQL并执行（%I用于标识符转义，避免SQL注入）
    v_sql := format('SELECT %I FROM %I', p_col_name, v_table_name);
    RETURN QUERY EXECUTE v_sql;
END;
$$ LANGUAGE plpgsql;

多跨表列查询扩展 #

如果需要同时查询多个跨表列，可扩展函数逻辑，按列所属表分组查询后合并结果：

CREATE OR REPLACE FUNCTION query_multiple_furnace_columns(p_col_names text[], p_furnace_num int)
RETURNS TABLE (col_name text, value numeric) AS $$
DECLARE
    v_col text;
    v_col_num int;
    v_table_name text;
    v_sql_parts text[];
BEGIN
    FOREACH v_col IN ARRAY p_col_names LOOP
        v_col_num := regexp_replace(v_col, '^t', '', 'g')::int;
        
        CASE
            WHEN v_col_num BETWEEN 1 AND 1000 THEN
                v_table_name := format('Table_1_Furnace_%s', p_furnace_num);
            WHEN v_col_num BETWEEN 1001 AND 2000 THEN
                v_table_name := format('Table_2_Furnace_%s', p_furnace_num);
            WHEN v_col_num BETWEEN 2001 AND 3000 THEN
                v_table_name := format('Table_3_Furnace_%s', p_furnace_num);
            WHEN v_col_num BETWEEN 3001 AND 4000 THEN
                v_table_name := format('Table_4_Furnace_%s', p_furnace_num);
            ELSE
                RAISE EXCEPTION 'Invalid column name: %', v_col;
        END CASE;
        
        -- 生成单表查询语句，附带列名标识
        v_sql_parts := array_append(v_sql_parts, 
            format('SELECT %L AS col_name, %I FROM %I', v_col, v_col, v_table_name));
    END LOOP;
    
    -- 合并所有查询并执行
    RETURN QUERY EXECUTE array_to_string(v_sql_parts, ' UNION ALL ');
END;
$$ LANGUAGE plpgsql;

内容的提问来源于stack exchange，提问作者Mr.Database