Mongo.GenericClient 8.1.6

Mongo.GenericClient

Generic library to manage a MongoDB database.

Required environment variables

• "MONGODB_CONNECTION_STRING" (e.g., "mongodb://root:root@localhost:27017")

• "MONGODB_DATABASE_NAME" (e.g., "my_mongodb")

Interfaces

Reposirory

namespace Mongo.GenericClient.Core.Repositories
{
    using Mongo.GenericClient.Core.Entities;
    using MongoDB.Driver;

    public interface IGenericRepository<TEntity>
        where TEntity : IEntity
    {
        IMongoCollection<TEntity> Collection { get; }
    }
}

Services

namespace Mongo.GenericClient.Core.Services
{
    using System.Collections.Generic;
    using System.Threading.Tasks;
    using Mongo.GenericClient.Core.Entities;
    using Mongo.GenericClient.Models;
    using MongoDB.Bson;

    public interface IReadService<TEntity>
        where TEntity : IEntity
    {
        IEnumerable<TEntity> GetAll(Expression<Func<TEntity, bool>>? filter = null);

        IMongoQueryable<TEntity> AsQueryable();

        Task<PaginationResult<TEntity>> GetPaginatedAsync(
            int pageNum,
            int pageSize);
        
        Task<PaginationResult<TEntity>> GetPaginatedAsync(
            Expression<Func<TEntity, bool>> filter,
            int pageNum,
            int pageSize);

        Task<TEntity> GetByIdAsync(ObjectId id);

        Task<TEntity> GetByIdAsync(string id);
    }
}

namespace Mongo.GenericClient.Core.Services
{
    using System.Threading.Tasks;
    using Mongo.GenericClient.Core.Entities;
    using MongoDB.Bson;

    public interface IWriteService<TEntity>
        where TEntity : IEntity
    {
        Task<TEntity> CreateAsync(TEntity entity);

        Task<bool> UpdateAsync(TEntity entity);

        Task DeleteAsync(ObjectId id);
        
        Task DeleteAsync(string id);
    }
}

IEntity

namespace Mongo.GenericClient.Core.Entities
{
    using MongoDB.Bson;

    public interface IEntity
    {
        ObjectId Id { get; set; }
    }
}

MongoHelper

namespace Mongo.GenericClient
{
    using MongoDB.Driver;

    public static class MongoHelper
    {
        private static readonly MongoClient client = new MongoClient(AppConfig.ConnectionString);
        private static readonly IMongoDatabase database = client.GetDatabase(AppConfig.DatabaseName);

        public static MongoClient Client => client;
        
        public static IMongoDatabase Database => database;
    }
}

Usage

Defining an entity and its collection name

The class must implement IEntity and have the attribute CollectionName

namespace Mongo.GenericClient.Tests.SetUp
{
    using Mongo.GenericClient.Core.Attributes;
    using Mongo.GenericClient.Core.Entities;
    using MongoDB.Bson;

    [CollectionName("persons")]
    public class PersonEntity : IEntity
    {
        public ObjectId Id { get ; set;  }

        public string Name { get; set; } = string.Empty;

        public int Age { get; set; }
    }
}

Creating a collection (or just inserting data)

Using the repository

await this.repository.Collection.InsertOneAsync(entity);

Using the service

await this.writeService.CreateAsync(entity);

Getting a list of documents as entities

var allEntities = this.readService.GetAll()
var filteredEntities = this.readService.GetAll(x => x.Age == 30)

Namespace Mongo.GenericClient.DependencyInjection

Some extension methods have been added to facilitate the registration of repositories and services.

Services and Repository separately:

services.RegisterGenericRepository<PersonEntity>(RegisterMode.Transient);
services.RegisterGenericServices<PersonEntity>(RegisterMode.Transient);

Services and repository at the same time:

services.RegisterGenericRepositoryAndServices<PersonEntity>(RegisterMode.Transient);

Note

• In order to run the tests, you must first run docker compose up -d.

• You can then manage the database at http://localhost:8081, with:

  • User: user
  • Password: pwd