如何在Postgres-custom-function中参数化表和列,如果值存在,则选择PK,否则插入它并返回PK?

How do I parameterize table & column in a Postgres-custom-function, selecting PK if value exists, otherwise insert it and return PK anyways?

提问人:auf keinsten 提问时间:12/13/2021 最后编辑:Jim Jonesauf keinsten 更新时间:12/13/2021 访问量:54

问:

尝试做我在标题中指定的事情,我已经让 upsert-functionalities 工作了,但是当我尝试参数化它时,我只是超出了我的深度,无法调试它。

我的疑问:

CREATE OR REPLACE FUNCTION custom_upsert(target_value_input text, 
                                         target_table_input text,
                                         target_column_input text,
                                         OUT pk_output int)
  LANGUAGE plpgsql AS
$func$
BEGIN
   LOOP
      execute 'SELECT id '
      ' FROM '  || target_table_input || 
      ' WHERE ' || target_column_input || ' =  ' || target_value_input ||
      ' INTO pk_output';

      EXIT WHEN FOUND;
      
      execute 'INSERT  INTO ' || target_table_input || 'AS o ( ' || target_column_input || ' )'
      ' VALUES ( ' || target_value_input || ' ) '
      ' ON CONFLICT ( ' || target_column_input || ' ) DO NOTHING '
      ' RETURNING o.id'
      ' INTO pk_output';

      EXIT WHEN FOUND;
   END LOOP;
END
$func$;

现在,当我尝试使用该函数时,我得到:

ERROR:  syntax error at or near "INTO"
LINE 1: ...module WHERE artifact_id =  artifact_id_example_1 INTO pk_ou...
                                                             ^
QUERY:  SELECT id  FROM maven_module WHERE artifact_id =  artifact_id_example_1 INTO pk_output
CONTEXT:  PL/pgSQL function custom_upsert(text,text,text) line 4 at EXECUTE

让我感到困惑的是,这种语法在非参数化版本中工作正常:

https://dbfiddle.uk/?rdbms=postgres_14&fiddle=765389a746d3a392bc646fbedb7ed3b3

我的参数化尝试:

https://dbfiddle.uk/?rdbms=postgres_14&fiddle=1bffab45d8a9587342a7c3253ea35fc8

https://dbfiddle.uk/?rdbms=postgres_14&fiddle=de6ba235aa21dae33b922f8fddac3b63

提前非常感谢您,第一次发帖,所以如果我在提问时有什么不同的事情,我很高兴得到反馈

编辑:这是我的函数调用:

-- should return pk of existing artifact_id
SELECT custom_upsert('artifact_id_example_1', 'maven_module', 'artifact_id');  

-- should return pk of new artifact_id
SELECT custom_upsert('artifact_id_example_2', 'maven_module', 'artifact_id');
SQL 数据库 PostgreSQL 参数传递 plpgsql

评论

0赞 auf keinsten 12/13/2021
那么,在这个例子中,这不应该也是一个问题 dbfiddle.uk/ 吗?
0赞 Edouard 12/13/2021
你的第二个陈述听起来很奇怪:应该是表的名称,是吗?execute 'INSERT INTO ' || target_column_input || ...target_column_input
0赞 auf keinsten 12/13/2021
哦,现在我明白你想说什么了,你当然是对的,那是疏忽!不过我仍然收到同样的错误
0赞 Edouard 12/13/2021
在 SELECT 语句中,INTO 子句必须紧随 SELECT 子句之后,FROM 子句之前:SELECT id INTO pk_output FROM ...
0赞 Jim Jones 12/13/2021
@aufkeinsten这是你要找的吗?dbfiddle.uk/......

答:

0赞 Jim Jones 12/13/2021 #1

不要像那样连接字符串。函数 format() 使你的生活更轻松(更安全),例如

EXECUTE format('INSERT INTO %1$I AS o (%2$I) 
                VALUES (%3$L) ON CONFLICT (%2$I) DO NOTHING RETURNING o.id',
                target_table_input,
                target_column_input,
                target_value_input) INTO pk_output;
  • %I将用双引号括起来标识符,这在表或列区分大小写且包含特殊字符时非常方便。
  • %L将用单引号括起来
  • 1$和 是调用中提供的变量位置,如果一个变量被多次使用,这将非常方便。2$3$format()

演示:db<>fiddle

评论

1赞 auf keinsten 12/13/2021
再次尝试,不仅是为了解决方案,还因为很好的解释,帮助了我很多