使用 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 构建我的输入，我将不胜感激

Answer 1

方法func需要一个值数组作为第二个参数。在您的情况下，它必须是一个参数 - 对象数组。但是您改为给它 2 个参数，每个参数都是一个对象，因此会出现错误。正确的方法是：const orderInput = [{item:"Red Widget", quantity:10}, {item:"Blue Widget", quantity:5}];await db.func('insert_into_orders', [orderInput]);无论如何，您应该使用事件查询或pg-monitor来查看生成了什么 SQL。另外，您insert_into_orders应该是一个存储过程，然后至少通过proc执行。但是，它的实现看起来应该只是代码中的一个事务。执行此操作后，错误返回为"error": {"message": "function insert_into_orders(text[]) does not exist"}那是因为类型不匹配，这需要类型转换......您可以通过常规查询方法调用该函数，也可以使用自定义类型格式来修改数据格式：const data = {    toPostgres: () => `${pgp.as.array(orderInput)}::json[]::order_input[]`,    rawType: true};然后将其传入：await db.func('insert_into_orders', [data]);