MongoDB Basics And CRUD Operation Using .NET Core 7 Web API

using MongoDbDemo.Entities;
namespace MongoDbDemo.Repositories {
    public interface IProductService {
        public Task < List < ProductDetails >> ProductListAsync();
        public Task < ProductDetails > GetProductDetailByIdAsync(string productId);
        public Task AddProductAsync(ProductDetails productDetails);
        public Task UpdateProductAsync(string productId, ProductDetails productDetails);
        public Task DeleteProductAsync(String productId);
    }
}

ProductService

using Microsoft.Extensions.Options;
using MongoDB.Driver;
using MongoDbDemo.Configurations;
using MongoDbDemo.Entities;
namespace MongoDbDemo.Repositories {
    public class ProductService: IProductService {
        private readonly IMongoCollection < ProductDetails > productCollection;
        public ProductService(IOptions < ProductDBSettings > productDatabaseSetting) {
            var mongoClient = new MongoClient(productDatabaseSetting.Value.ConnectionString);
            var mongoDatabase = mongoClient.GetDatabase(productDatabaseSetting.Value.DatabaseName);
            productCollection = mongoDatabase.GetCollection < ProductDetails > (productDatabaseSetting.Value.ProductCollectionName);
        }
        public async Task < List < ProductDetails >> ProductListAsync() {
            return await productCollection.Find(_ => true).ToListAsync();
        }
        public async Task < ProductDetails > GetProductDetailByIdAsync(string productId) {
            return await productCollection.Find(x => x.Id == productId).FirstOrDefaultAsync();
        }
        public async Task AddProductAsync(ProductDetails productDetails) {
            await productCollection.InsertOneAsync(productDetails);
        }
        public async Task UpdateProductAsync(string productId, ProductDetails productDetails) {
            await productCollection.ReplaceOneAsync(x => x.Id == productId, productDetails);
        }
        public async Task DeleteProductAsync(string productId) {
            await productCollection.DeleteOneAsync(x => x.Id == productId);
        }
    }
}

Step 6

Next, add a new product controller.

using Microsoft.AspNetCore.Mvc;
using MongoDbDemo.Entities;
using MongoDbDemo.Repositories;
namespace MongoDbDemo.Controllers {
    [Route("api/[controller]")]
    [ApiController]
    public class ProductsController: ControllerBase {
        private readonly IProductService productService;
        public ProductsController(IProductService productService) => this.productService = productService;
        [HttpGet]
        public async Task < List < ProductDetails >> Get() {
                return await productService.ProductListAsync();
            }
            [HttpGet("{productId:length(24)}")]
        public async Task < ActionResult < ProductDetails >> Get(string productId) {
                var productDetails = await productService.GetProductDetailByIdAsync(productId);
                if (productDetails is null) {
                    return NotFound();
                }
                return productDetails;
            }
            [HttpPost]
        public async Task < IActionResult > Post(ProductDetails productDetails) {
                await productService.AddProductAsync(productDetails);
                return CreatedAtAction(nameof(Get), new {
                    id = productDetails.Id
                }, productDetails);
            }
            [HttpPut("{productId:length(24)}")]
        public async Task < IActionResult > Update(string productId, ProductDetails productDetails) {
                var productDetail = await productService.GetProductDetailByIdAsync(productId);
                if (productDetail is null) {
                    return NotFound();
                }
                productDetails.Id = productDetail.Id;
                await productService.UpdateProductAsync(productId, productDetails);
                return Ok();
            }
            [HttpDelete("{productId:length(24)}")]
        public async Task < IActionResult > Delete(string productId) {
            var productDetails = await productService.GetProductDetailByIdAsync(productId);
            if (productDetails is null) {
                return NotFound();
            }
            await productService.DeleteProductAsync(productId);
            return Ok();
        }
    }
}

Step 7

Open the appsettings.json file and add MongoDB server URL, database, and collection name inside the same after creating that inside the MongoDB Compass.

{
  "Logging": {
    "LogLevel": {
      "Default": "Information",
      "Microsoft.AspNetCore": "Warning"
    }
  },
  "AllowedHosts": "*",
  "ProductDatabase": {
    "ConnectionString": "mongodb://localhost:27017",
    "DatabaseName": "ProductDB",
    "ProductCollectionName": "Product"
  }
}

Step 8

Register a few services inside the Program class.

using MongoDbDemo.Configurations;
using MongoDbDemo.Repositories;
var builder = WebApplication.CreateBuilder(args);
// Add services to the container.
builder.Services.Configure < ProductDBSettings > (builder.Configuration.GetSection("ProductDatabase"));
builder.Services.AddSingleton < IProductService, ProductService > ();
builder.Services.AddControllers();
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();
var app = builder.Build();
// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment()) {
    app.UseSwagger();
    app.UseSwaggerUI();
}
app.UseHttpsRedirection();
app.UseAuthorization();
app.MapControllers();
app.Run();

Step 9

Run the application and add some product details using Swagger UI.

Step 10

After adding some product data, you can see details inside MongoDB Compass, as I showed below.

GitHub URL

https://github.com/Jaydeep-007/MongoDbDemo

Conclusion

Here we discussed the introduction and basic concept of MongoDB and step-by-step implementation of product application API using .NET Core 7 Web API.

Happy Coding!!!