0

所以我有点卡在这里。

我有一个对象，例如：

var lineItems = [
    {
      id: 1,
      quantity: 10
    },
    {
      id: 2,
      quantity: 15
    },
    {
      id: 4,
      quantity: 22
    }
]

现在我需要做的是在 pg-promise SQL 事务中循环，以确保关联 id 的数据库数量中的行项目 >= 对象项目，所以：

SELECT * FROM inventory WHERE id = $1 AND quantity >= $2, [1,10],
SELECT * FROM inventory WHERE id = $1 AND quantity >= $2, [2,15],
SELECT * FROM inventory WHERE id = $1 AND quantity >= $2, [4,22]

如果我收到 3 个结果，则该对象为真，我可以插入请求

INSERT INTO orders SET a = 1, b = 2, c = 3, items = lineItems::json etc RETURNING id;

当然，如果我的结果比 lineItems 对象中的结果少，那么我就不会理会该INSERT语句，而只需返回一个'item id: 4, quantity:22 doesn't have enough inventory to perform your request...

我最初使用的是：

db.tx(function(t)){
  return this.batch([
    checkInventory
  ])
    .then(function(inv){
      console.log( inv );
    });
})
.then(function(results){
  console.log( results );
})
.catch(function(error){
  console.log( error );
});

checkInventory我调用的函数在哪里

var checkInventory = function(){
    console.log( '|-------------------------------------|' );
    console.log( 'LINE ITEMS >> ', lineItems );
    var query = [], sql = ''; 
    for( var i = 0; i < lineItems.length; i++ ){
        sql += 'SELECT quantity FROM pim_inventory WHERE';
        sql += ' product_id = $1 AND quantity >= $2;';

        var pquery = [
            lineItems[i].id,
            lineItems[i].quantity
        ];

        query.push(this.one(sql, pquery));
    }

    console.log( 'invQUERY >> ', query );
    return query;
};

这会产生以下错误：

(node:44810) UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 3): QueryResultError: Multiple rows were not expected.
(node:44810) UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 4): error: syntax error at or near "product_id"
|-------------------------------------|
EVENTS >>  [ [ Promise {
      <rejected> QueryResultError: Multiple rows were not expected.
        at QueryResultError.Error (native)
        at new QueryResultError (/Users/directtap-dev/www/GitHub/v1.02/node_modules/pg-promise/lib/errors.js:13:22)
        at Query.callback (/Users/directtap-dev/www/GitHub/v1.02/node_modules/pg-promise/lib/index.js:629:38)
        at Query.handleReadyForQuery (/Users/directtap-dev/www/GitHub/v1.02/node_modules/pg/lib/query.js:89:10)
        at Connection.<anonymous> (/Users/directtap-dev/www/GitHub/v1.02/node_modules/pg/lib/client.js:163:19)
        at emitOne (events.js:101:20)
        at Connection.emit (events.js:188:7)
        at Socket.<anonymous> (/Users/directtap-dev/www/GitHub/v1.02/node_modules/pg/lib/connection.js:109:12)
        at emitOne (events.js:96:13)
        at Socket.emit (events.js:188:7) },
    Promise { <rejected> [Object] } ] ]

有任何想法吗？

4

1 回答 1

2

当您一次问太多问题时，您可能会在中间遇到多个错误。尝试一次解决一个问题。

在您的代码中至少有 5 个问题，显然......

问题 1

当您使用它时：this.one(sql, pquery)您创建的每个请求都期望返回一行，但其中至少一个返回多行，因此错误Multiple rows were not expected.。查看方法的 API，它就在那里。

问题 2

你使用你的函数checkInventory来生成一个promise数组，这很好，但是batch你没有直接将它传递给方法，而是你这样做batch([checkInventory])了，这导致了batch([[promises]])，因为它没有得到解决。

问题 3

您使用checkInventory而不是函数，这是无效的。你应该打电话batch(checkInventory())。

问题 4

您显然没有显示完整的代码，因为您没有链接您创建的承诺，这导致松散的承诺，然后Unhadled promise rejection最终。

问题 5

您传递的某些值product_id无效，因此有关它的服务器级错误。

于 2017-02-01T23:10:35.547 回答