AmelioMongoRepository 1.0.0

AmelioMongoRepository

A lightweight and extensible MongoDB repository pattern for .NET applications. Supports full CRUD operations, custom queries, and aggregate joins with simple integration.

📦 Installation

Add the NuGet package:

dotnet add package MongoRepositoryPackage

⚙️ Configuration

In your appsettings.json, add your MongoDB settings:

{
  "MongoDbSettings": {
    "ConnectionString": "mongodb://localhost:27017",
    "DatabaseName": "YourDatabaseName"
  }
}

🚀 Getting Started

1. Setup your Models

using MongoDB.Bson;
using MongoDB.Bson.Serialization.Attributes;
using MongoRepositoryPackage.Attributes;

public class Category : IEntity
{
    [BsonId(IdGenerator = typeof(UniqueIdGenerator))]
    public string Id { get; set; }
    public string Title { get; set; }
}

public class Product : IEntity
{
    [BsonId(IdGenerator = typeof(UniqueIdGenerator))]
    public string Id { get; set; }
    public string Name { get; set; }
    public double Price { get; set; }
    public string CategoryId { get; set; }
}

2. Register Repositories

var builder = Host.CreateDefaultBuilder(args)
    .ConfigureAppConfiguration((context, config) =>
    {
        config.AddJsonFile("appsettings.json", optional: false);
    })
    .ConfigureServices((context, services) =>
    {
        services.AddMongoRepository<Product>(context.Configuration);
        services.AddMongoRepository<Category>(context.Configuration);
    });

var host = builder.Build();

3. Use the Repositories

var productRepo = host.Services.GetRequiredService<IMongoRepository<Product>>();
var categoryRepo = host.Services.GetRequiredService<IMongoRepository<Category>>();

// Insert category
var newCategory = new Category { Title = "Electronics" };
await categoryRepo.InsertOneAsync(newCategory);

// Insert product linked to category
var newProduct = new Product { Name = "Laptop", Price = 1500.00, CategoryId = newCategory.Id };
await productRepo.InsertOneAsync(newProduct);

// Fetch all
var products = await productRepo.GetAllAsync();
Console.WriteLine($"Found {products.Count} products.");

4. Aggregate Lookup Example

Join Product with Category (one-to-one relationship):

public class ProductWithCategory
{
    public string Id { get; set; }
    public string Name { get; set; }
    public double Price { get; set; }
    public string CategoryId { get; set; }
    public Category Category { get; set; }
}

public class ProductAggregateService
{
    private readonly IMongoCollection<Product> _products;
    private readonly IMongoCollection<Category> _categories;

    public ProductAggregateService(IMongoRepository<Product> productRepo, IMongoRepository<Category> categoryRepo)
    {
        _products = productRepo.AsCollection();
        _categories = categoryRepo.AsCollection();
    }

    public async Task<List<ProductWithCategory>> GetProductsWithCategoryAsync()
    {
        var unwindOptions = new AggregateUnwindOptions<ProductWithCategory> { PreserveNullAndEmptyArrays = true };

        return await _products.Aggregate()
            .Lookup<Product, Category, ProductWithCategory>(
                _categories,
                p => p.CategoryId,
                c => c.Id,
                result => result.Category)
            .Unwind(result => result.Category, unwindOptions)
            .ToListAsync();
    }
}

🧪 Output

Found 2 product(s).
Found 2 product(s) with category.
Test Product 1 -> Category 1
Test Product 2 -> Category 2

✅ Features

• Generic repository pattern with DI support
• Attribute-based ID generation ([BsonId(IdGenerator = typeof(UniqueIdGenerator))])
• Aggregation with $lookup support
• Clean MongoDB collection naming
• Easily extendable