处理回调函数[重复]

Question

我正在开发一个需要与 mongoDb 数据库通信的 node.js 项目。我目前正在编写一个函数来使用 th node-mongodb-native 模块在我的数据库中查找一些数据。一切正常，但我的代码看起来像回调中的回调中的回调...

我创建了这个函数来防止我每次想要访问我的数据库时都使用回调。我现在只需要调用这个函数。

module.exports.find = function(query, projection, callback){
    db.open(function(err, db){
        if(err) throw err;
        db.collection('rooms', function(err, collection){
            if(err) throw err;
            collection.find(query, projection, function(err, cursor){
                if (err) throw err;
                cursor.toArray(function(err, find){
                    db.close();
                    callback(err, find);
                });
            });
        });
    });
};

有没有办法减少这种codeception？

Answer 1

如果你只是想知道如何合理地清理回调和作用域db：

module.exports.find = function(query, projection, callback){
    var local_db;

    function db_open(err, db) {
        if(err) throw err;
        local_db = db;
        local_db.collection('rooms', handle_homes_collection);

    }

    function handle_homes_collection(err, collection){
        if(err) throw err;
        collection.find(query, projection, handle_find_query);
    }

    function handle_find_query(err, cursor){
        if (err) throw err;
        cursor.toArray(function(err, find){
            local_db.close();
            callback(err, find);
        });
    }

    db.open(db_open);
};

Answer 2

像这样：

module.exports.find = function(query, projection, callback){
    var database;

    db.open(function(err, db_temp){
        if(err) throw err;

        database = db_temp;
    });

    database.collection('rooms', function(err, collection){
        if(err) throw err;
        collection.find(query, projection, function(err, cursor){
            if (err) throw err;
            cursor.toArray(function(err, find){
                db.close();
                callback(err, find);
            });
        });
    });
};