Wie ist ein IAsyncCursor verwendet für die iteration mit der mongodb c# driver?

Ich versuche, um eine Liste aller Datenbanken, in meinem server und schließlich drucken Sie Sie aus (d.h. Ihre Namen als strings). Mit der vorherigen version der c# - Treiber, den ich nennen könnte, die Server.GetDatabases(), aber das wurde ersetzt mit ListDatabasesAsync().

Der Rückgabewert ist eine IAsyncCursor<> und ich bin mir nicht sicher, was zu tun ist. Wie macht man eine Iteration durch die Liste der Datenbanken (oder nichts) mit so einen cursor?

InformationsquelleAutor Shamster | 2015-04-16
  1. 27

    Kurze Antwort: verwenden Sie die ForEachAsync extension Methode:

    var cursor = await client.ListDatabasesAsync();
await cursor.ForEachAsync(db => Console.WriteLine(db["name"]));

    Lange Antwort: Traditionellen iteration in C# erfolgt mit IEnumerable und foreach. foreach ist der compiler syntaktische Zucker. Es ist eigentlich ein Aufruf GetEnumerator eine using Bereich und ein while Schleife. Aber das unterstützt keine asynchronen Operationen:

    using (var enumerator = enumerable.GetEnumerator())
{
    while (enumerator.MoveNext())
    {
        var current = enumerator.Current;
        //use current.
    }
}

    IAsyncCursor entspricht IEnumerator (das Ergebnis IEnumerable.GetEnumerator), während IAsyncCursorSource istIEnumerable. Der Unterschied ist, dass diese Unterstützung async (und bekommen Sie einen Stapel in jeder iteration und nicht nur einem einzigen Element). Sie können nicht foreach wie es ist gebaut für IEnumerable aber Sie implementieren können, das ganze using, while Schleife Sache:

    IAsyncCursorSource<int> cursorSource = null;

using (var asyncCursor = await cursorSource.ToCursorAsync())
{
    while (await asyncCursor.MoveNextAsync())
    {
        foreach (var current in asyncCursor.Current)
        {
            //use current
        }
    }
}

    Aber das ist eine Menge von boilerplate, damit der Fahrer fügt die Erweiterung Methoden zur IAsyncCursor wie ForEachAsync, ToListAsync und so weiter.

    Dass deckt die meisten Anwendungsfälle aber für andere, die Sie noch brauchen, um zu implementieren, die iteration selbst.

    • Ist es speichern, um zu modiy das Dokument in ForEachAsync und speichern Sie es zurück zu db mit ReplaceOneAsync? Änderungen in diesem Fall sind zu Komplex, zu verwenden UpdateManyAsync
    • ja. Es ist sicher. Nur weniger effizient.
    InformationsquelleAutor i3arnon
Schreibe einen Kommentar