对数组中的每个对象运行 PostgreSQL UPDATE 查询



假设我有一车杂货,每件商品都有一个唯一的ID。当有人单击"购买"时,会发送一个数组,其中包含该购物车中每件商品的对象。购物车各不相同,所以有时可能是 2 件,有时可能是 6 件,等等。

例:

[{id: 1, amt_purchased: 3}, {id: 2, amt_purchased: 4}]

我需要我的 SQL 表"可用的杂货",根据购买的内容进行更新。

对于一个杂货,我会使用以下方法:

UPDATE available 
SET amt_avail = amt_avail - 3
WHERE produce_id = 1

由于我现在有多个项目,如何让查询针对购买的每个项目运行?还是作为一个庞大的查询,将根据购买的物品数量进行调整?

我的项目是Ionic/AngularJs和NodeJs,Express,MassiveJs。

谢谢大家!仍然是一个菜鸟,所以我很难解释我需要什么。

PostgreSQL有一个很好的功能UPDATE ... FROM ...;它提供了一种方便的方式来更新另一个表上的一个表。第二个出色的功能 - 您可以在此查询中使用伪表VALUES

UPDATE available a
SET amt_available = a.amt_available + v.amt_available
FROM (
VALUES (1, 25), (3, 15), (7, -55)   -- just pass required values
) AS v (produce_id, amt_available)
WHERE a.produce_id=v.produce_id;

这是一个 SQLFiddle 来检查一个想法 - http://sqlfiddle.com/#!17/04f24/22

update available 
set amt_avail = case 
when produce_id = 1 then amt_avail - 3
when produce_id = 2 then amt_avail - 4 
end;

您可以使用简单的 for 循环来构建这样的查询

var items = [{id: 1, amt_purchased: 3}, {id: 2, amt_purchased: 4}];
function buildQuery(items) {
var query = "update available set amt_avail = case ";
for (var i = 0; i < items.length; i++) {
var item = items[i];
query += `when produce_id = ${item['id']} then amt_avail - ${item['amt_purchased']}`
}
return query += " end;";
}

如果您使用的是Massive.js 3.0,这意味着您可以访问其底层驱动程序pg-promise。

不幸的是,我个人没有使用Massive.js所以我对直接通过它进行更新还不够了解。作为 pg-promise 的作者,我只能建议您访问其驱动程序以执行所需的更新,如下所示。

const db; // your Massive.js database object;
const helpers = db.pgp.helpers; // pg-promise helpers namespace
// reusable ColumnSet:
const cs = new helpers.ColumnSet(['?id', 'amt_purchased'], {table: 'available '});
// your input data:
const data = [{id: 1, amt_purchased: 3}, {id: 2, amt_purchased: 4}];
// query to be executed:
const query = helpers.update(data, cs) + ' WHERE v.id = t.id';
db.instance.none(query)
.then(() => {
// success, updated all at once
})
.catch(error => {
// error
});

另请参阅:pg-promise 多行更新。

链接:

  • 帮助程序命名空间

最新更新