使用for循环插入表格

Question

我正在尝试编写一个循环来读取临时表，然后将该记录插入到另一个表中。我需要进行单条记录处理的原因是我需要在每次插入目标表后找到序列的值。我还没有将该功能添加到 SQL 中（稍后会出现）。我在将记录插入目标表时遇到了困难。

我遇到语法错误，但我认为还有更多需要修复的地方。

CREATE OR REPLACE FUNCTION test_insert()
  RETURNS SETOF varchar AS
$func$
DECLARE
    rec record;
BEGIN   
   FOR rec IN
        SELECT * FROM   TBL_stg01
   LOOP INSERT  INTO target_tbl
        SELECT * FROM TBL_stg01
;
      END IF;
   END LOOP;
END
$func$  LANGUAGE plpgsql STABLE;

Answer 1

您需要在插入中特别提及您的列名，并且您不需要“重新选择”您的数据。

CREATE OR REPLACE FUNCTION test_insert()
  RETURNS SETOF varchar AS
$func$
DECLARE
    rec record;
BEGIN   
   FOR rec IN
        SELECT * FROM   TBL_stg01
   LOOP INSERT  INTO target_tbl (colaname1, colname2, colname3...)
        values (rec.col1, rec.col2, rec.col3...);
      END IF;
   END LOOP;
END
$func$  LANGUAGE plpgsql STABLE;

Answer 2

PL/pgSQL 函数已审计

有几个问题：

CREATE OR REPLACE FUNCTION test_insert()
   RETURNS SETOF varchar AS   -- what do you want to return?
$func$
DECLARE
    rec record;
BEGIN   
   FOR rec IN
      SELECT col1, col2, col3 FROM tbl_stg01  -- only needed columns
   LOOP
      INSERT INTO target_tbl (col1, col2, col3)
      VALUES (rec.col1, rec.col2, rec.col3)
      -- SELECT (rec).*  -- possible shorthand
   END LOOP;
END
$func$  LANGUAGE plpgsql;

• 如果tbl_stg01 和target_tbl 共享相同的行类型，并且您希望源表中的INSERT所有 列可以在没有显式的情况下工作目标清单。但是由于您显然有一个自动递增的 id，所以您很可能不能。在任何情况下你都不应该。喜欢Joe already provided。
  请注意我一开始只选择需要的列。

• 你有一个END IF 却没有启动一个IF 块。

• 不能将写入表的函数声明为STABLE。我删除了关键字，所以默认的function volatility VOLATILE 开始了。

• 你的函数被声明为RETURNS SETOF varchar，但你没有返回任何东西......

适当的解决方案

你提到你need to find the value of the Sequence after every insert，但你没有提供你的表定义，说明你需要它的顺序或用途。

无论哪种方式，这都是您在 INSERT 之后返回自动生成的默认值的方式

INSERT INTO target_tbl (col1, col2, col3)
SELECT col1, col2, col3
FROM   tbl_stg01
RETURNING *

相关答案：

• How to select inside a FOR-Loop for further computations?

您可以使用data-modifying CTEs like 在单个语句中将更多命令链接起来

WITH ins AS (
   INSERT INTO target_tbl (col1, col2, col3)
   SELECT col1, col2, col3
   FROM   tbl_stg01
   RETURNING target_tbl_id
   )
INSERT INTO tbl3 (some_id)
SELECT target_tbl_id
FROM   ins;

更多示例说明：

• Passing a record as function argument PL/pgSQL
• Return value cross join