0

我正在尝试在 async.waterfall 中创建一个函数,该函数检查数组中的每个 id 是否在 mongodb 中有任何具有此 id 的条目(使用 Mongoose)。如果 id 已经存在,则将从数组中删除。我写了以下函数:

    function(eventIds, callback) {
        // check for duplicates
        for (var i = 0; i < eventIds.length; i++) {
            var query = Party.find({
                fbEventId: eventIds[i]
            });
            query.exec(function(err, doc) {
                if (err) return console.log(err);
                if (doc) {
                    // remove i from array
                    console.log(doc);
                }
            });
        }
        callback(null, eventIds);
    }

但是,这会发出警告,因为在 for 循环中构造了一个新函数。

如果我在 for 循环之外创建函数,如下所示,则会出现错误:ReferenceError: err is not defined。

    function(eventIds, callback) {
        // check for duplicates
        function checkDuplicate(err, doc) {
            if (err) return console.log(err);
            if (doc) {
                    // remove i from array
                console.log(doc);
            }
        }
        for (var i = 0; i < eventIds.length; i++) {
            var query = Party.find({
                fbEventId: eventIds[i]
            });
            query.exec(checkDuplicate(err, doc));
        }
        callback(null, eventIds);
    }

这样做的正确方法是什么?

4

1 回答 1

3

您正在调用该函数,而不是为其分配引用。

你的代码

query.exec(query.exec(checkDuplicate(err, doc));

应该

query.exec(query.exec(checkDuplicate));
于 2013-11-01T12:53:52.810 回答