PostgreSQL分区实现：插入触发器动态语句中NEW.*的使用问题

这是PostgreSQL实现动态分区时很典型的问题，我来帮你梳理下错误原因和正确的写法：

你的错误原因 #

你之前尝试用quote_literal(NEW.*)拼接SQL语句，问题出在：NEW是行类型，quote_literal会把它转换成带单引号的字符串（比如'(49563,,1,11,...)'），直接拼到INSERT VALUES后面就会导致语法错误——PostgreSQL期望的是行值（不带引号的括号内容），而不是字符串形式的行。

正确的两种实现方式 #

方式1：使用USING NEW传递行参数（推荐，安全简洁）

这种方法利用PostgreSQL的参数传递机制，避免手动拼接行内容，同时用%I确保表名作为合法标识符处理（防止tenant/store ID包含特殊字符引发错误）：

CREATE OR REPLACE FUNCTION item_lines_insert_trigger() RETURNS TRIGGER AS $$
BEGIN
  EXECUTE format(
    'INSERT INTO item_lines_partitions.%I VALUES ($1)',
    'p' || NEW.tenant_id || '_' || NEW.store_id
  ) USING NEW;
  RETURN NULL;
END;
$$ LANGUAGE plpgsql;

• %I会自动给表名添加必要的引号，确保标识符合法
• USING NEW直接把整行数据作为参数传递给动态SQL，PostgreSQL会自动匹配主表和分区表的列结构

方式2：动态展开行的所有列

如果你需要显式展开列（比如分区表和主表列顺序一致但列名不完全相同的场景），可以用row_to_json和json_each_text来生成列值列表，但这种写法不如第一种简洁：

CREATE OR REPLACE FUNCTION item_lines_insert_trigger() RETURNS TRIGGER AS $$
DECLARE
  cols text;
  vals text;
BEGIN
  SELECT string_agg(quote_ident(k), ', '), string_agg(quote_nullable(v), ', ')
  INTO cols, vals
  FROM json_each_text(row_to_json(NEW));

  EXECUTE format(
    'INSERT INTO item_lines_partitions.%I (%s) VALUES (%s)',
    'p' || NEW.tenant_id || '_' || NEW.store_id,
    cols,
    vals
  );
  RETURN NULL;
END;
$$ LANGUAGE plpgsql;

额外注意事项 #

• 确保所有分区表的列结构（顺序、类型、名称）和主表完全一致，否则会出现列不匹配的错误
• 动态生成的表名必须是已存在的分区表，否则会触发“表不存在”的错误，可以考虑在触发器里添加存在性检查（比如用pg_class系统表校验）

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