node.js - Express 和 Node (CouchDB) 无法返回填充数据的列表

Question

我试图返回“checkins_each”，但每次尝试显示它时它都会返回一个空白列表[]。我认为 checkins.list() 正在新线程中运行，或者与 checkins.get() 在新线程中运行相同的东西 - 是否有正确的方法返回 checkins_each - 它应该有一些记录？

console.log(jsondoc)表明jsondoc确实是一个大型的json数据结构

// return data
var checkins = nano.use(settings.COUCHDB_PREFIX+'checkins');
var checkins_each = [];
checkins.list(function(err, body) {
    if (!err) {
        console.log('hi proximity loop')
        body.rows.forEach(function(doc) {
            console.log(doc.id);
            checkins.get(doc.id, function(err,jsondoc) {
                console.log(JSON.stringify(jsondoc));
                if (jsondoc.profile_id != profile_id) {
                    console.log('appending checkin');
                    checkins_each.push(jsondoc);
                }

            });
        });
        res.send({status: 'proximity', checkins: checkins_each});
    } else {
        console.log("error", err);
        res.send({status: 'fail', error: err});

    }

Answer 1

您必须阅读有关异步调用的内容并使用 Promises , async-lib或者像下面这样

var checkins = nano.use(settings.COUCHDB_PREFIX+'checkins');
checkins.list(function(err, body) {
    if (err) 
        return res.send({status: 'fail', error: err});

    var checkins_each = [];
    function getRow(i) {
        if (i == body.rows)
            return res.send({status: 'proximity', checkins: checkins_each});

        var doc = body.rows[i];
        checkins.get(doc.id, function(err, jsondoc) {
            if (err)
                return res.send({status: 'fail', error: err});

            if (jsondoc.profile_id != profile_id)
                checkins_each.push(jsondoc);

            getRow(i + 1);
        });
    };

    getRow(0);
} 

如果checkins.get返回Promise，那么代码可以像下面这样

var checkins = nano.use(settings.COUCHDB_PREFIX+'checkins');
checkins.list(function(err, body) {
    if (err) 
        return res.send({status: 'fail', error: err});

    var promises = body.rows.map((row) => checkins.get(row.id));
    Promise.All(promises)
        .then(function (results) {
            var checkins_each = [];
            results
                .filter((res) => res.profile_id != profile_id)
                .forEach((res) => checkins_each.push(res))

            res.send({status: 'proximity', checkins: checkins_each});
        })
        .catch(err) {
            return res.send({status: 'fail', error: err});
        }
})