使用 pg-promise 执行接受参数数组的 Postgresql 函数

Question

我们有这个 postgresql 类型：

create type order_input as (
    item text,
    quantity integer);

还有这个 postgresql 函数：

create or replace function insert_into_orders(order_input[])
returns void language plpgsql as $$
declare 
    inserted_id integer;
begin
    insert into public.orders(orderdate) 
    values (now()) 
    returning orderid into inserted_id;

    insert into public.orderdetails(orderid, item, quantity)
    select inserted_id, item, quantity
    from unnest($1);
end $$;

要在 pgadmin-4 中执行，我们运行：

select insert_into_orders(
    array[
        ('Red Widget', 10), 
        ('Blue Widget', 5)
    ]::order_input[]
);

我试图弄清楚如何使用 pg-promise javascript 库执行 insert_into_orders 函数。我尝试过以下操作：

const pgp = require("pg-promise")();
const db = pgp(connectionObj);

await db.func("insert_into_orders", [{item:"Red Widget", quantity:10}, {item:"Blue Widget", quantity:5}]

但收到以下消息：

{
  "error": {
    "message": "malformed array literal: \"{\"item\":\"Red Widget\", \"quantity\":10}\""
  }
}

如果有人知道我必须如何为 pg-promise 构建我的输入，我将不胜感激，原帖来自这里：Postgres Function to insert multiple records in two tables

Answer 1

方法func 需要一个值数组作为第二个参数。在您的情况下，它必须是一个参数 - 对象数组。但是您改为给它 2 个参数，每个参数都是一个对象，因此会出现错误。

正确的做法是：

const orderInput = [{item:"Red Widget", quantity:10}, {item:"Blue Widget", quantity:5}];

await db.func('insert_into_orders', [orderInput]);

无论如何，您应该使用事件query 或pg-monitor 来查看生成了什么SQL。

另外，您的insert_into_orders 至少应该是stored procedure，然后通过proc 执行。但是，它的实现看起来应该只是代码中的一个事务。

执行此操作后，错误返回为"error": {"message": "function insert_into_orders(text[]) does not exist"}

那是因为类型不匹配，需要类型转换...

您可以通过常规查询方法调用该函数，也可以使用Custom Type Formatting修改数据格式：

const data = {
    toPostgres: () => `${pgp.as.array(orderInput)}::json[]::order_input[]`,
    rawType: true
};

然后将其传入：

await db.func('insert_into_orders', [data]);