PL/pgSQL函数报错‘syntax error at or near “QUERY”’，如何修复？

核心错误原因 #

你遇到的语法错误是因为PL/pgSQL中动态执行SQL的正确命令是EXECUTE，不需要添加QUERY前缀，QUERY EXECUTE是无效的语法结构。

其他需要修复的问题 #

除了核心语法错误，还有几处细节问题需要修正：

• 变量引用错误：RAISE NOTICE中使用的query变量未声明，应改为你定义的query_pw。
• 字符串引号错误：PostgreSQL中字符串常量需用单引号包裹，双引号用于标识符（如表名），所以所有SET语句的双引号要替换为单引号。
• 函数属性错误：该函数执行修改表配置和数据库参数的操作，会改变数据库状态，不能标记为IMMUTABLE，应改为VOLATILE（默认属性，也可显式声明）。

修复后的完整函数代码 #

CREATE OR REPLACE FUNCTION public.end_to_end_query(part_id integer)
 LANGUAGE plpgsql VOLATILE
AS $function$
DECLARE
  query_pw varchar := format(
    $dynsql$
    ALTER TABLE metric_events_%s SET (parallel_workers = 16)
    $dynsql$, part_id
  );

BEGIN
    RAISE NOTICE 'Value: %', query_pw;
    EXECUTE 'set enable_parallel_append = off';
    EXECUTE 'SET work_mem TO ''1GB''';
    EXECUTE query_pw;
    EXECUTE 'SET max_parallel_workers_per_gather = 16';
    EXECUTE 'set max_worker_processes=8';
END $function$;

关键修复点总结 #

• 把所有QUERY EXECUTE改为EXECUTE。
• 修正RAISE NOTICE中的变量名。
• 将双引号包裹的SQL语句改为单引号，注意字符串内部的单引号需要用两个单引号转义（如''1GB''）。
• 调整函数属性为VOLATILE。

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