mongodb NodeJS Speicherwert außerhalb verbinden

Question

ich einen Weg brauchen Wert zu speichern außerhalb mongoDB Anruf verbinden:

read(object) { 
    let result 
    MongoClient.connect(this.url, function (err, db) { 
     if (err!=null){ 
      result = err; 
     } else { 
      db.collection(object.collection).find(object.field).toArray(function(err, docs) { 
       assert.equal(err, null); 
       db.close();  
       result = docs; 
      }); 
     } 
    }); 
    return result 
} 

Wenn ich diese Methode aufrufen, die Teil einer Klasse ist, Rückkehr wird vor Ergebniszuweisung genannt, als normal . Beispiel: console.log(read(obj)) gibt undefined zurück

Die Idee ist, Wert in einer Variablen zu speichern, und Rückkehr möglicherweise warten, bis Verbindung beendet wird.

Gibt es eine Möglichkeit, dieses Problem zu lösen?

Answer 1

Ohne Versprechen:

Anruf Rückkehr innen finden und irre Funktion:

read(object) { 
    let result 
    MongoClient.connect(this.url, function (err, db) { 
     if (err!=null){ 
      result = err; 
      return result; //here 
     } else { 
      db.collection(object.collection).find(object.field).toArray(function(err, docs) { 
       assert.equal(err, null); 
       db.close();  
       result = docs; 
       return result; // here 
      }); 
     } 
    }); 
} 

oder ein Timeout für die Rückkehr mit genügend Zeit eingestellt für anderen Prozess warten, bis zum Ende:

read(object) { 
    let result 
    MongoClient.connect(this.url, function (err, db) { 
     if (err!=null){ 
      result = err; 
     } else { 
      db.collection(object.collection).find(object.field).toArray(function(err, docs) { 
       assert.equal(err, null); 
       db.close();  
       result = docs; 
      }); 
     } 
    }); 
    setTimeout(function(){ return result}, 3000); // 3secs 
} 

Answer 2

Mit Promise können Sie Folgendes versuchen:

function read(object) { 
    let result 
    return new Promise((resolve, reject) => { 
     MongoClient.connect(this.url, function (err, db) { 
      if (err!=null){ 
       reject(err); 
      } else { 
       db.collection(object.collection).find(object.field).toArray(function(err, docs) { 
        db.close(); 
        if (err) { 
         reject(err); 
        } else { 
         resolve(docs);           
        } 
       }); 
      } 
     }); 
    }); 
} 

// then you can call the function and use the result like this 
read(obj).then(docs => { 
    console.log(docs); 
}) 
.catch(err => { 
    // handle error 
    console.log(err); 
})