nodejs - mongodb native finden Sie alle Dokumente

Folgenden ein Beispiel aus der mongodb-Handbuch für nodejs, ich finde alle Dokumente aus einer db wie folgt

mongo.Db.connect(mongoUri, function (err, db) {
    if (err) {
        console.log(err);
    } 
    else {
        db.collection('test').find().toArray(function(e, d) {
            console.log(d.length);
            db.close();
        });
    }
});

Nun, was ich merke, ist, dass die gesamte Gruppe wird konvertiert in ein array. Als dataset wird wachsen, das wird nicht der ideale Ansatz. Es ist trotzdem stream der Daten, so dass Sie nicht in den Speicher geladen, jedes mal?

Dank

InformationsquelleAutor dopplesoldner | 2014-02-07

  1. 14

    Der einfachste Weg ist die Verwendung eines Cursor (Referenz):

    var cursor = db.collection('test').find();

//Execute the each command, triggers for each document
cursor.each(function(err, item) {
    //If the item is null then the cursor is exhausted/empty and closed
    if(item == null) {
        db.close(); //you may not want to close the DB if you have more code....
        return;
    }
    //otherwise, do something with the item
});

    Wenn es gibt eine Menge von Berechnungen, die Sie tun müssen, sollten Sie überlegen, ob ein Map-reduce (Referenz) passen würde Ihre Bedürfnisse als würde der code zum ausführen auf dem DB-server statt lokal.

    Danke für den Vorschlag für map-reduce. Ich war versucht zu denken, aber ich bin nicht sicher, ich verstehe die Prinzipien der "map-reduce" auf mongodb gut genug, um zu brechen mein problem.. Aber ich werde auf jeden Fall überdenken in der Zukunft.

    InformationsquelleAutor WiredPrairie

  2. 10

    Können Sie stream die Ergebnisse einer node.js native-Treiber die Abfrage durch den Aufruf von stream() auf der zurückgegebenen cursor:

    var stream = collection.find().stream();
stream.on('data', function(doc) {
    console.log(doc);
});
stream.on('error', function(err) {
    console.log(err);
});
stream.on('end', function() {
    console.log('All done!');
});
    Was ist der Unterschied zwischen stream() und next()

    InformationsquelleAutor JohnnyHK

  3. 0

    Wäre die Begrenzung der Abfrage eine option sein? Buchstäblich mit der db.Sammlung.finden().limit()? Die Grenze analysiert wird, vor dem senden des Befehls an den server, so dass es nur überprüft die Menge der Daten, die in Ihrem limit.

    Meine Anwendung eigentlich benötigt, um einige mathematische Berechnungen an den Daten-und return-die meisten "ähnlichen" Dokumenten. Also ich fahre auf alle Dokumente und tun die Berechnung lokal. Jetzt wäre es schön, wenn ich Sie durchführen können diese Berechnungen auf die Datenbank selbst, aber ich weiß nicht, ob das möglich ist?

    InformationsquelleAutor d1ll1nger

Schreibe einen Kommentar