node.js - 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() 提供回调或a cursor 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();
        }
    }
);