错误：使用带有异步系列的 pg-promise 时已经调用了回调

Question

我无法理解打印的输出为什么要执行此代码：

1 2 未处理的拒绝错误：已调用回调。

查询成功时似乎 then 和 catch 都执行了。

有什么想法吗？

干杯

    async.series([
            function(callback) {
                db.none(query)
                    .then(function () {
                        return callback(null, true);
                    })
                    .catch(function (err) {
                        return callback(err, null);
                    });
            },
            function(callback) {
                db.any(query)
                    .then(function (data) {
                        console.log('1')
                        return callback(null, data);
                    })
                    .catch(function (err) {
                        console.log('2')
                        console.log(err);
                        return callback(err, null);
                    });
            }
        ],
        function(err, results) {
           if (results && !results[1].isEmpty()) {
              // do something
           }
        });

编辑：

TypeError: results[1].isEmpty is not a function

问题似乎来自其余代码，只是一个简单的未定义函数错误，谢谢。

但我还是不明白：为什么这个错误是在第二个查询中而不是在异步查询之外捕获的？

Answer 1

你有没有尝试在外部定义你的函数：

function onYourFunction() {
   console.log('Hi function');
}

然后：

.then(onYourFunction)    //-->(onYourFunction without parentheses )

不幸的是我不使用 pg-promise 但我可以建议promise

此时我创建了所有必要的承诺：

function createPromise(currObj) {
return new Promise(function (resolve, reject) {
    currObj.save(function (errSaving, savedObj) {
        if(errSaving){
            console.log("reject!");
            return reject(errSaving, response);
        }

        console.log('currObj:' + currObj);
        return resolve(savedObj);
    });
});

}

然后在级联中：

var allPromiseOs = Promise.all(promise1, promise2, promise3);

Answer 2

会发生这样的事情：

• callback(null, data) 在.then() 的上下文中被调用；
• async 注意到这是该系列的最后一项，因此它调用最终处理程序（仍在 .then() 的上下文中）；
• 最终处理程序抛出错误；
• 因为代码在.then()的上下文中运行，所以promise实现会捕获错误并调用.catch()；
• 这再次调用回调；

概念验证：

const async = require('async');

async.series([
  callback => {
    Promise.resolve().then(() => {
      callback(null);
    }).catch(e => {
      callback(e);
    });
  }
], err => {
  throw Error();
})

Answer 3

我是pg-promise的作者。

您永远不应该将async 库与pg-promise 一起使用，这违背了共享/可重用连接的概念。

通过任务正确使用相同的连接来实现：

db.task(t => {
    return t.batch([
        t.none(query1),
        t.any(query2)
    ]);
})
    .then(data => {
        // data[0] = null - result of the first query
        // data[1] = [rows...] - result of the second query

        callback(null, data); // this will work, but ill-advised
    })
    .catch(error => {
        callback(error, null); // this will work, but ill-advised
    });

另请参阅：Chaining Queries。

但是，在您的情况下，看起来当您调用成功的callback(null, data) 时，它会引发错误，进而导致它被捕获在以下.catch 部分中。要对此进行测试，您可以像这样更改您的 Promise 处理程序：

    .then(data => {
        callback(null, data);
    }, error => {
        callback(error, null);
    });

它通常应该抛出一个关于 Promise 缺少 .catch 的错误，因为您在 .then 中抛出了一个错误，并且下面没有对应的 .catch 链接，您也可以通过此代码检查：

    .then(data => {
        callback(null, data);
    }, error => {
        callback(error, null);
    })
    .catch(error => {
        // if we are here, it means our callback(null, data) threw an error
    });

P.S. 你真的应该学会正确使用 Promise，并完全避免任何回调。我只提供了一个与你自己一致的示例，但总的来说，将 Promise 转换为回调是一种非常糟糕的编码技术。