Razory.MongoDB 2.1.1

Razory.MongoDB

MongoDB provider for Razory. Implements IRepository and IQueryObject<T> using the official MongoDB .NET Driver.

Installation

dotnet add package Razory.MongoDB

Setup

1. Implement IMongoEntityConfiguration<T> for each entity

public class ProductConfiguration : IMongoEntityConfiguration<Product>
{
    public string Name => "products"; // collection name

    public void ConfigureCollection(IMongoCollection<Product> collection)
    {
        // optional: create indexes, TTLs, etc.
        collection.Indexes.CreateOne(
            new CreateIndexModel<Product>(
                Builders<Product>.IndexKeys.Ascending(p => p.Category)));
    }
}

2. Implement IDatabaseConfiguration

public class MyMongoDatabaseConfiguration : IDatabaseConfiguration
{
    private readonly List<IEntityConfiguration> configurations =
    [
        new ProductConfiguration(),
        new OrderConfiguration(),
    ];

    public string ConnectionString => "mongodb://localhost:27017";

    public string GetDatabaseName<T>() where T : EntityBase => "my_database";

    public IEntityConfiguration<T> GetEntityConfiguration<T>() where T : EntityBase =>
        configurations.OfType<IEntityConfiguration<T>>().Single();

    public IEnumerable<IEntityConfiguration> GetAllEntityConfigurations() => configurations;
}

3. Register

builder.Services.ConfigureRazoryMongoDB(new MyMongoDatabaseConfiguration());

This registers:

• IRepository → MongoRepository
• IQueryObject<T> → MongoQueryObject<T>
• All internal commands (ICreateDocumentCommand, IUpdateDocumentCommand, etc.)
• ICollectionResolver, IDatabaseResolver

Usage

Inject IRepository for CRUD and IQueryObject<T> for queries:

public class ProductService(IRepository repository, IQueryObject<Product> query)
{
    public Task<Product> GetByIdAsync(Guid id) =>
        repository.GetAsync<Product>(id);

    public Task InsertAsync(Product product) =>
        repository.InsertAsync(product);

    public Task UpsertAsync(Product product) =>
        repository.UpsertAsync(p => p.Id == product.Id, product);

    public Task<IEnumerable<Product>> GetActiveByCategoryAsync(string category) =>
        query
            .FilterBy<ProductFilter>(f => f.ActiveOnly().WithCategory(category))
            .SortAscending(p => p.Name)
            .Query()
            .GetAllAsync();

    public Task<IEnumerable<Product>> GetPageAsync(int page, int size) =>
        query
            .FilterBy(p => p.IsActive)
            .Query()
            .Skip((page - 1) * size)
            .Limit(size)
            .GetAllAsync();
}

MongoDB-specific result features

Query() returns IMongoQueryObjectResult<T> and Aggregate() returns IMongoQueryObjectAggregateResult<T>. These extend the base interfaces with MongoDB-native operations:

Native projection via IMongoQueryObjectProjectionDefinition<TSource, TDestination>

public class ProductSummaryProjection : IMongoQueryObjectProjectionDefinition<Product, ProductSummary>
{
    public ProjectionDefinition<Product, ProductSummary> Definition(
        ProjectionDefinitionBuilder<Product> builder) =>
        builder.Expression(p => new ProductSummary
        {
            Id = p.Id,
            Name = p.Name,
        });
}

var result = (IMongoQueryObjectResult<Product>)query.Query();
var summaries = await result.Project(new ProductSummaryProjection()).GetAllAsync();

Aggregate Unwind

var result = (IMongoQueryObjectAggregateResult<Order>)query.Aggregate();
var items = await result.Unwind<OrderItem>("Items").GetAllAsync();

Repository

github.com/johnyricalde/Razory