Postgres存储过程动态插入报错，如何正确实现跨年份表数据导入？

报错原因分析 #

你遇到的ERROR: string between dollars did not end in or near "$$"，是因为存储过程的美元引号（$$）匹配错误，加上变量赋值时的引号使用混乱（比如原代码里nametab TEXT := 'dbo.B3_HIST_'"多了一个未配对的双引号），导致Postgres无法正确解析存储过程体。

正确实现方案 #

步骤1：确保TEMP1表结构与源表一致 #

如果还没创建TEMP1，先从任意一张年份表复制结构（不复制数据）：

CREATE TABLE TEMP1 AS SELECT * FROM dbo.B3_HIST_2015 LIMIT 0;

若各年份表结构有差异，建议手动指定列名创建TEMP1，避免插入时结构不匹配。

步骤2：批量插入数据的两种方式 #

方法1：创建可复用的存储过程

CREATE OR REPLACE PROCEDURE load_b3_hist_to_temp1()
LANGUAGE plpgsql
AS $$
DECLARE
    target_year INT;
    source_table TEXT;
BEGIN
    -- 遍历2015到2023年的所有目标表
    FOR target_year IN 2015..2023 LOOP
        -- 动态生成源表名
        source_table := format('dbo.B3_HIST_%s', target_year);
        -- 执行动态INSERT语句，%I确保表名被当作合法标识符处理
        EXECUTE format('INSERT INTO TEMP1 SELECT * FROM %I', source_table);
        -- 可选：打印调试信息
        RAISE NOTICE '已导入表 % 的数据', source_table;
    END LOOP;
END;
$$;

执行存储过程：

CALL load_b3_hist_to_temp1();

方法2：一次性执行匿名块（无需创建存储过程）

如果只是临时执行，直接用匿名块更便捷：

DO $$
DECLARE
    target_year INT;
    source_table TEXT;
BEGIN
    FOR target_year IN 2015..2023 LOOP
        source_table := format('dbo.B3_HIST_%s', target_year);
        EXECUTE format('INSERT INTO TEMP1 SELECT * FROM %I', source_table);
    END LOOP;
END $$;

关键注意事项 #

• 动态表名必须用%I处理：Postgres中动态拼接表名时，一定要用format函数的%I占位符，它会自动处理标识符的大小写、特殊字符，同时避免SQL注入风险。
• 避免用*全选列：如果各年份表的列顺序/数量不一致，要手动指定列名，比如：

  EXECUTE format('INSERT INTO TEMP1 (col1, col2, col3) SELECT col1, col2, col3 FROM %I', source_table);
  

• 美元引号要正确配对：存储过程/匿名块的代码体必须用$$完整包裹，中间不能出现未闭合的引号导致解析失败。

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