PostgreSQL函数中动态遍历多Schema同名表的游标实现疑问

问题1：能否在函数DECLARE部分声明游标，在BEGIN部分指定查询语句？ #

不行。PostgreSQL中，DECLARE段声明的是静态游标，必须在声明时就绑定完整的查询语句，无法在后续的BEGIN段中修改或指定查询逻辑。

如果需要动态指定查询语句，得用动态游标实现，有两种常用方式：

• 使用REF CURSOR类型变量，在BEGIN段通过OPEN ... FOR EXECUTE绑定动态SQL
• 在BEGIN段直接用DECLARE ... CURSOR FOR EXECUTE语法声明并打开动态游标

示例（REF CURSOR方式）：

CREATE OR REPLACE FUNCTION dynamic_cursor_demo() RETURNS SETOF record AS $$
DECLARE
  cur refcursor;
  rec record;
  query_text text := 'SELECT id, name FROM users WHERE age > 30';
BEGIN
  OPEN cur FOR EXECUTE query_text;
  LOOP
    FETCH cur INTO rec;
    EXIT WHEN NOT FOUND;
    RETURN NEXT rec;
  END LOOP;
  CLOSE cur;
END;
$$ LANGUAGE plpgsql;

问题2：多Schema下同名表的遍历查询 #

针对多schema下的同名表（如schema1.vault_log、schema2.vault_log），要实现遍历查询，核心是通过动态SQL拼接不同schema的表名，结合循环遍历所有目标schema。

具体实现步骤： #

1. 从系统视图information_schema.tables中筛选出所有包含vault_log表的schema名称
2. 遍历每个schema，动态拼接查询SQL，执行后处理结果

完整函数示例： #

CREATE OR REPLACE FUNCTION query_all_vault_logs() RETURNS SETOF record AS $$
DECLARE
  schema_rec record;
  cur refcursor;
  log_rec record;
BEGIN
  -- 遍历所有存在vault_log表的schema
  FOR schema_rec IN 
    SELECT table_schema 
    FROM information_schema.tables 
    WHERE table_name = 'vault_log' AND table_type = 'BASE TABLE'
  LOOP
    -- 动态拼接查询语句，替换schema名称（%I自动处理转义，避免SQL注入）
    OPEN cur FOR EXECUTE format(
      'SELECT ac, scheme_code, resp, err, opr FROM %I.vault_log WHERE extract(minute from now()-req_ts) <= 5',
      schema_rec.table_schema
    );
    -- 读取游标结果并返回
    LOOP
      FETCH cur INTO log_rec;
      EXIT WHEN NOT FOUND;
      RETURN NEXT log_rec;
    END LOOP;
    CLOSE cur;
  END LOOP;
END;
$$ LANGUAGE plpgsql;

关键说明： #

• 用format()函数拼接SQL，%I会自动处理特殊字符转义，彻底避免SQL注入风险
• 通过系统视图自动获取所有目标schema，无需手动维护schema列表，扩展性更强
• 借助REF CURSOR+OPEN ... FOR EXECUTE实现动态游标，完美解决DECLARE段无法使用变量的问题

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