net - Cómo hacer findAll en el nuevo controlador mongo C#y hacerlo sincrónico

mongodb driver php

Question

Estaba usando el controlador oficial de C # para hacer un FindAll y actualicé al nuevo controlador 2.0. FindAll está obsoleto y se reemplaza con Find. Estoy tratando de convertir un método simple que me devuelve una lista de Class1 . No puedo encontrar un ejemplo realista utilizando un POCO en su documentación

var collection = database.GetCollection<ClassA>(Collection.MsgContentColName); return collection.FindAll().ToList();

¿Puede alguien ayudarme a convertir con el controlador 2.0 y devolver una lista y no una tarea?

Answer 1

Con la versión 2.2.4 de MongoDb, la implementación cambió un poco. Siguiendo las mejores prácticas, construyamos la conexión de MongoDb de esta manera:

public static class PatientDb
{
public static IMongoCollection<Patient> Open()
{
var client = new MongoClient("mongodb://localhost");
var db = client.GetDatabase("PatientDb");
return db.GetCollection<Patient>("Patients");
}
}

Ahora se devuelve una interfaz de IMongoCollection lugar de una instancia de una clase concreta como MongoCollection . No es necesario crear una instancia de servidor para obtener más la base de datos, el cliente puede acceder a la base de datos directamente.

Luego en el controlador se hace así:

public class PatientController : ApiController
{
private readonly IMongoCollection<Patient> _patients;
public PatientController()
{
_patients = PatientDb.Open();
}
public IEnumerable<Patient> Get()
{
return _patients.Find(new BsonDocument()).ToEnumerable();
}
}

Donde _patients es un IMongoCollection y para recuperar a todos los pacientes en lugar de usar FindAll() ahora se usa Find() donde el filtro es una nueva instancia de BsonDocument .

Answer 2

EDITAR:

Decidieron volver a agregar soporte síncrono (aunque async aún es preferible para las operaciones de E / S), por lo que simplemente puede usar:

var list = collection.Find(_ => true).ToList();

Original:

No bloquee sincrónicamente en código asíncrono. Es malo para el rendimiento y podría llevar a puntos muertos.

Si desea mantener su aplicación sincrónica, se recomienda que siga utilizando el controlador síncrono anterior.

En el nuevo controlador v2.0, la opción async debería tener este aspecto:

async Task FooAsync()
{
var list = await collection.Find(_ => true).ToListAsync();
}

Answer 3

Esto es con MongoDb C # Driver 2.2

El nuevo controlador de C # es asíncrono. Guste o no debe ser tratado. Será útil en el futuro. Pero por ahora...

En el código siguiente, la llamada asíncrona se realiza de manera síncrona debido al código "result.GetAwaiter (). GetResult ();". Esto hace que el código asíncrono se ejecute hasta su finalidad en el flujo normal.

 static void MongoGoNow()
{
IMongoCollection<ClassA> collection = db.GetCollection<ClassA>(Collection.MsgContentColName);
var result = TestFind(collection);
result.GetAwaiter().GetResult();
//What''s next???
}
static async Task TestFind(IMongoCollection<ClassA> MyCollection)
{
var filter = new BsonDocument();
var count = 0;
using (var cursor = await MyCollection.FindAsync(filter))
{
while (await cursor.MoveNextAsync())
{
var batch = cursor.Current;
foreach (var document in batch)
{
// process document
count++;
}
}
} 

También puede combinar las dos últimas líneas de código en el método Principal de la siguiente manera:

 static void MongoGoNow()
{
IMongoCollection<ClassA> collection = db.GetCollection<ClassA>(Collection.MsgContentColName);
TestFind(collection).GetAwaiter().GetResult();
//What''s next???
}

Answer 4

Para recuperar todo, puede usar un filtro vacío según la documentation

FilterDefinition<T>.Empty

Por ejemplo

 public async Task<IEnumerable<ClassA>> GetAllAsync() =>
await database.GetCollection<ClassA>(Collection.MsgContentColName)
.Find(FilterDefinition<ClassA>.Empty).ToListAsync();

Answer 5

puedes hacer esto para lograr lo mismo usando el driver 2.0,

var collection = database.GetCollection<ClassA>(Collection.MsgContentColName);
var doc = collection.Find(filter).ToListAsync();
doc.Wait();
return doc.Result;