A cohesive set of infrastructure libraries for dotnet that utilizes abstractions for event handling, persistence, unit of work, mediator, distributed messaging, event bus, CQRS, email, and more
Get Started
$ dotnet add package RCommon.PersistenceReadme
RCommon.Persistence
Persistence abstraction layer for RCommon providing the repository pattern, unit of work, specification pattern, and named data store management. This package defines the core interfaces and base classes that ORM-specific implementations (EF Core, Dapper, Linq2Db) build upon.
Features
- Repository pattern with separate read-only and write-only interfaces for CQRS-friendly designs
- LINQ-enabled repositories exposing
IQueryable<T>for composable queries - Graph repositories with change tracking support for ORMs like Entity Framework Core
- SQL mapper repositories for micro-ORMs like Dapper
- Specification pattern support for encapsulating query logic
- Paginated query results via
IPaginatedList<T>with built-in ordering - Eager loading abstraction with
Include/ThenIncludechaining - Unit of work pattern with configurable transaction modes and isolation levels
- Named data store factory for managing multiple database connections
- Domain event tracking integrated into repository operations
- Soft delete -- automatic
!IsDeletedfiltering on reads and logical deletion on writes for entities implementingISoftDelete - Multitenancy -- automatic tenant filtering on reads and
TenantIdstamping on writes for entities implementingIMultiTenant - Fluent builder API for DI registration via
AddRCommon()
Installation
dotnet add package RCommon.Persistence
Usage
This package is typically used indirectly through a provider-specific package. However, you program against these abstractions in your application and domain layers:
// Inject repository abstractions into your services
public class OrderService
{
private readonly IGraphRepository<Order> _orderRepo;
private readonly IUnitOfWorkFactory _unitOfWorkFactory;
public OrderService(IGraphRepository<Order> orderRepo, IUnitOfWorkFactory unitOfWorkFactory)
{
_orderRepo = orderRepo;
_unitOfWorkFactory = unitOfWorkFactory;
}
public async Task<Order> GetOrderAsync(int id)
{
return await _orderRepo.FindAsync(id);
}
public async Task<ICollection<Order>> GetPendingOrdersAsync()
{
return await _orderRepo.FindAsync(o => o.Status == OrderStatus.Pending);
}
public async Task<IPaginatedList<Order>> GetOrdersPagedAsync(int page, int pageSize)
{
return await _orderRepo.FindAsync(
o => o.IsActive,
o => o.CreatedDate,
orderByAscending: false,
pageNumber: page,
pageSize: pageSize);
}
public async Task PlaceOrderAsync(Order order)
{
using var unitOfWork = _unitOfWorkFactory.Create(TransactionMode.Default);
await _orderRepo.AddAsync(order);
unitOfWork.Commit();
}
}