處理回調函數

Question

我正在研究一個node.js項目，我需要與mongoDb數據庫進行通信。我目前正在編寫一個函數，使用node-mongodb-native模塊在我的db中查找一些數據。一切正常，但我的代碼看起來像回調中的回調在回調中的回調...

我創建此函數，以防止我每次訪問我的數據庫時使用回調。我現在只需要調用這個函數。

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

像這樣：

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); 
      }); 
     }); 
    }); 
}; 

Answer 2

如果你只是想知道如何清理回調的合理和範圍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); 
};