MongoDB + node.js - SQL Entsprechendes auswählen

Question

Ich bin ziemlich neu in node.js und mongodb. Ich brauche eine Funktion, die ein Array mit Ergebnissen aus der Datenbank zurückgibt. Wenn ich 'SELECT * FROM table' in PHP abfrage, gibt es Array oder Array von Objekten zurück. Aber mit Node und Mongo muss ich viel Code verwenden, was mir so unnötig erscheint. Also schrieb ich diese Funktion:

select: function (table, terms) { 
    var rows = []; 
    var find = function (error, db) { 
     var collection = db.collection(table); 
     var docs = collection.find(terms); 
     docs.each(function (error, doc) { 
      rows.push(doc); 
     }); 
    }; 
    client.connect(url, find); 
    return rows; 
} 

Es Tabellennamen [string] und Begriffe [js object] als Argument nimmt. Und ich möchte diese Funktion ein Array wie folgt zurückgeben: [{doc1}, {doc2}, {doc3}, ...]. Wenn ich Variable doc protokollieren, ist es in jeder Funktion in Ordnung - gültiges Javascript-Objekt. Aber wenn ich nach dem Verschieben aller Dokumente variable Zeilen protokolliere, ist es leer - []. Auch das Ergebnis von function select() ist leeres Array - [].

Bitte, gibt es jemanden, der eine Idee hat, was ein Problem sein könnte oder wer eine ähnliche Methode verwendet, um Daten von MongoDB zu holen? Danke

Answer 1

Die Verbindungsfunktion ist asynchron und endet nach Ihrer Rückkehranweisung. Setzen Sie Ihre Return-Anweisung innerhalb der Callback-Funktion, direkt nach der schließenden Klammer von docs.each (.....); Auf diese Weise können Sie sicher sein, dass Ihre Return-Anweisung ausgeführt wird, nachdem Ihr Array gefüllt wurde.

Edit für die Vollständigkeit: eine Rückgabeanweisung funktioniert natürlich nicht, weil es von der Funktion in finden zurückgibt. Arbeiten Sie mit einer Rückruffunktion.

So:

select: function (table, terms, cb) { 
    var rows = []; 
    var find = function (error, db) { 
     var collection = db.collection(table); 
     var docs = collection.find(terms); 
     docs.each(function (error, doc) { 
      rows.push(doc); 
     }); 
     cb(error, rows); 
    }; 
    client.connect(url, find); 
} 

Edit: Im obigen Beispiel (cb Funktion statt return)