MongoJS同步调用

Question

我在修复一个项目中的一些错误。我需要同步游标，以便在循环中加载数据。我有密码：

var mongo     = require('mongojs'),
    dataMaps  = [];

mongo.penguin_friends.find({ user_id_1: id_user }, function(err, friends) {     
    friends.forEach(function(data) {
        var cursor = mongo.penguin_user_maps3.find({ user_id: data.id_user }, { fields: { maps: 1 } });
    //I need to do dataMaps.push(cursor.data);

    });

    console.log("processingThisSomething()");

    processSomething();     
}); 

在调用processSomething()之前，我需要完成这个请求；因此，我需要在循环中同步处理mongodb查询。

Answer 1

由于API不支持查询，所以不可能使查询同步。

要接收结果，您必须向.find()或 method提供一个回调：

cursor.toArray(function (err, maps) {
    if (!err) {
        dataMaps.push(maps);
    }
});

但是，可以将迭代器替换为异步感知的迭代器(如async.each() )，以便在它们完成后继续进行：

async.each(
    friends,

    function (data, callback) {
        var cursor = mongo....;

        cursor.toArray(function (err, maps) {
            if (!err) {
                dataMaps.push(maps);
            }

            callback(err);
        });
    },

    function (err) {
        if (!err) {
            processSomething();
        }
    }
);