Nello scorso script (https://www.aspitalia.com/script/1265/Utilizzare-MongoDB-ASP.NET-Core.aspx) abbiamo introdotto l'utilizzo del database NoSql MongoDb all'interno di un'applicazione ASP.NET Core e abbiamo visto come effettuare l'inserimento di una entity in una collection. In questo script, invece, ci occuperemo delle operazioni di retrieve, update e delete, così da chiudere il cerchio delle CRUD su una entità.

Recuperare un'entità

private readonly IMongoCollection<Person> _people;

public async Task<IActionResult> Details(string id)
{
    if (id == null)
    {
        return NotFound();
    }

    var person = await _people.AsQueryable()
        .SingleOrDefaultAsync(x => x.Id == new ObjectId(id));

    if (person == null)
    {
        return NotFound();
    }

    return View(person);
}

Il nocciolo della logica è costituito dal metodo AsQueryable che, applicato a una collection, espone tutti gli extension method di LINQ. Nell'esempio specifico, abbiamo sfruttato SingleOrDefaultAsync per effettuare una ricerca per Id. Vale la pena far notare che il driver traduce la query nella sintassi di MongoDb, così che sia il database server - e non il client - a eseguire effettivamente la query.

Riguardo alle performance, c'è da notare come questa specifica query sia estremamente veloce perchè il filtro è basato sulla chiave primaria. Più in generale, LINQ ci consente di filtrare per qualsiasi campo ma, in assenza di opportuni indici, le prestazioni degraderebbero velocemente all'aumentare delle dimensioni della base dati. Analizzaremo bene queste problematiche in un prossimo script.

Modificare un'entità

[HttpPost]
[ValidateAntiForgeryToken]
public async Task<IActionResult> Edit(string id, [Bind("Name,Email")] Person person)
{
    var original = await _people.AsQueryable()
        .SingleOrDefaultAsync(x => x.Id == new ObjectId(id));

    if (original == null)
    {
        return this.NotFound();
    }

    if (ModelState.IsValid && await this.TryUpdateModelAsync(original))
    {
        await _people.ReplaceOneAsync(x => x.Id == new ObjectId(id), original);

        return RedirectToAction(nameof(Index));
    }
    return View(person);
}

Come possiamo vedere, innanzitutto recuperiamo, con la stessa tecnica vista prima, la versione originale della entità Person, sollevando un 404 nel caso non sia stata trovata. Poi ne modifichiamo il contenuto tramite il metodo TryUpdateModelAsync, che recupera i valori postati nella request. L'ultimo passo è quello di salvare i dati con ReplaceOneSync, che accetta come argomento la query per recuperare l'elemento da sovrascrivere e il nuovo valore.

Eliminare un'entità

[HttpPost, ActionName("Delete")]
[ValidateAntiForgeryToken]
public async Task<IActionResult> DeleteConfirmed(string id)
{
    var person = await _people.DeleteOneAsync(x => x.Id == new ObjectId(id));

    return RedirectToAction(nameof(Index));
}