Create a RESTful API With .NET Core and MongoDB

1
dotnet new webapi -o MongoExample
2
cd MongoExample
3
dotnet add package MongoDB.Driver

1
namespace MongoExample.Models;
2
3
public class MongoDBSettings {
4
5
    public string ConnectionURI { get; set; } = null!;
6
    public string DatabaseName { get; set; } = null!;
7
    public string CollectionName { get; set; } = null!;
8
9
}

1
{
2
    "Logging": {
3
        "LogLevel": {
4
            "Default": "Information",
5
            "Microsoft.AspNetCore": "Warning"
6
        }
7
    },
8
    "AllowedHosts": "*",
9
    "MongoDB": {
10
        "ConnectionURI": "ATLAS_URI_HERE",
11
        "DatabaseName": "sample_mflix",
12
        "CollectionName": "playlist"
13
    }
14
}

1
using MongoExample.Models;
2
using Microsoft.Extensions.Options;
3
using MongoDB.Driver;
4
using MongoDB.Bson;
5
6
namespace MongoExample.Services;
7
8
public class MongoDBService {
9
10
    private readonly IMongoCollection<Playlist> _playlistCollection;
11
12
    public MongoDBService(IOptions<MongoDBSettings> mongoDBSettings) {
13
        MongoClient client = new MongoClient(mongoDBSettings.Value.ConnectionURI);
14
        IMongoDatabase database = client.GetDatabase(mongoDBSettings.Value.DatabaseName);
15
        _playlistCollection = database.GetCollection<Playlist>(mongoDBSettings.Value.CollectionName);
16
    }
17
18
    public async Task<List<Playlist>> GetAsync() { }
19
    public async Task CreateAsync(Playlist playlist) { }
20
    public async Task AddToPlaylistAsync(string id, string movieId) {}
21
    public async Task DeleteAsync(string id) { }
22
23
}

1
using MongoExample.Models;
2
using MongoExample.Services;
3
4
var builder = WebApplication.CreateBuilder(args);
5
6
builder.Services.Configure<MongoDBSettings>(builder.Configuration.GetSection("MongoDB"));
7
builder.Services.AddSingleton<MongoDBService>();

1
using MongoDB.Bson;
2
using MongoDB.Bson.Serialization.Attributes;
3
using System.Text.Json.Serialization;
4
5
namespace MongoExample.Models;
6
7
public class Playlist {
8
9
    [BsonId]
10
    [BsonRepresentation(BsonType.ObjectId)]
11
    public string? Id { get; set; }
12
13
    public string username { get; set; } = null!;
14
15
    [BsonElement("items")]
16
    [JsonPropertyName("items")]
17
    public List<string> movieIds { get; set; } = null!;
18
19
}

1
[BsonId]
2
[BsonRepresentation(BsonType.ObjectId)]
3
public string? Id { get; set; }

1
[BsonElement("items")]
2
[JsonPropertyName("items")]
3
public List<string> movieIds { get; set; } = null!;

1
using System;
2
using Microsoft.AspNetCore.Mvc;
3
using MongoExample.Services;
4
using MongoExample.Models;
5
6
namespace MongoExample.Controllers; 
7
8
[Controller]
9
[Route("api/[controller]")]
10
public class PlaylistController: Controller {
11
    
12
    private readonly MongoDBService _mongoDBService;
13
14
    public PlaylistController(MongoDBService mongoDBService) {
15
        _mongoDBService = mongoDBService;
16
    }
17
18
    [HttpGet]
19
    public async Task<List<Playlist>> Get() {}
20
21
    [HttpPost]
22
    public async Task<IActionResult> Post([FromBody] Playlist playlist) {}
23
24
    [HttpPut("{id}")]
25
    public async Task<IActionResult> AddToPlaylist(string id, [FromBody] string movieId) {}
26
27
    [HttpDelete("{id}")]
28
    public async Task<IActionResult> Delete(string id) {}
29
30
}

1
public async Task CreateAsync(Playlist playlist) {
2
    await _playlistCollection.InsertOneAsync(playlist);
3
    return;
4
}

1
[HttpPost]
2
public async Task<IActionResult> Post([FromBody] Playlist playlist) {
3
    await _mongoDBService.CreateAsync(playlist);
4
    return CreatedAtAction(nameof(Get), new { id = playlist.Id }, playlist);
5
}

1
public async Task<List<Playlist>> GetAsync() {
2
    return await _playlistCollection.Find(new BsonDocument()).ToListAsync();
3
}

1
[HttpGet]
2
public async Task<List<Playlist>> Get() {
3
    return await _mongoDBService.GetAsync();
4
}

1
public async Task AddToPlaylistAsync(string id, string movieId) {
2
    FilterDefinition<Playlist> filter = Builders<Playlist>.Filter.Eq("Id", id);
3
    UpdateDefinition<Playlist> update = Builders<Playlist>.Update.AddToSet<string>("movieIds", movieId);
4
    await _playlistCollection.UpdateOneAsync(filter, update);
5
    return;
6
}

1
[HttpPut("{id}")]
2
public async Task<IActionResult> AddToPlaylist(string id, [FromBody] string movieId) {
3
    await _mongoDBService.AddToPlaylistAsync(id, movieId);
4
    return NoContent();
5
}

1
public async Task DeleteAsync(string id) {
2
    FilterDefinition<Playlist> filter = Builders<Playlist>.Filter.Eq("Id", id);
3
    await _playlistCollection.DeleteOneAsync(filter);
4
    return;
5
}

1
[HttpDelete("{id}")]
2
public async Task<IActionResult> Delete(string id) {
3
    await _mongoDBService.DeleteAsync(id);
4
    return NoContent();
5
}

1
{
2
  "username": "nraboy",
3
  "items": [
4
    "1234",
5
    "5678"
6
  ]
7
}