👁 Image
Indiko.Blocks.DataAccess.Abstractions 2.8.0

Indiko.Blocks.DataAccess.Abstractions

Core abstractions for data access layer implementation in the Indiko framework, providing interfaces and base classes for repositories, unit of work, and database context management.

Overview

This package defines the fundamental contracts for implementing data access layers across different ORM providers (Entity Framework, MongoDB, Marten, etc.). It provides a consistent API for CRUD operations, querying, and transaction management.

Features

• Generic Repository Pattern: Comprehensive IRepository<TEntity, TIdType> interface
• Unit of Work: Transaction management abstraction
• Database Context: Base classes for DbContext implementations
• Model Builder: Configuration system for entity mappings
• Entity Configuration Registry: Centralized entity configuration management
• Manager Pattern: Service locator for repositories
• Soft Delete Support: Built-in soft delete functionality
• Paging & Filtering: Query, paging, and filtering operations
• Aggregation Functions: Sum, Count, Min, Max, Average, GroupBy, Distinct
• Async/Await: Full async support throughout
• Change Tracking: Entity state management and dirty tracking
• Multiple ID Types: Support for Guid, int, long, string, etc.

Installation

dotnet add package Indiko.Blocks.DataAccess.Abstractions

Key Interfaces

IRepository<TEntity, TIdType>

Comprehensive repository interface with over 50 methods for data operations.

public interface IRepository<TEntity, TIdType> where TEntity : class, IEntity<TIdType>
{
 // CRUD Operations
 ValueTask<bool> AddAsync(TEntity entity, CancellationToken cancellationToken = default);
 ValueTask<bool> UpdateAsync(TEntity entity, CancellationToken cancellationToken = default);
 ValueTask<bool> DeleteAsync(TEntity entity, bool useSoftDelete = true, CancellationToken cancellationToken = default);
 
 // Read Operations
 ValueTask<TEntity> ReadByIdAsync(TIdType id, CancellationToken cancellationToken = default);
 ValueTask<IEnumerable<TEntity>> ReadAllAsync(bool asNotracking = true, CancellationToken cancellationToken = default);
 ValueTask<IEnumerable<TEntity>> ReadManyByQueryAsync(Expression<Func<TEntity, bool>> where, ...);
 ValueTask<PagedList<TEntity>> ReadManyByQueryPagedAsync(Expression<Func<TEntity, bool>> where, int page = 1, int pageSize = 25, ...);
 
 // Aggregations
 ValueTask<int> CountAsync(Expression<Func<TEntity, bool>> where, ...);
 ValueTask<decimal> SumAsync(Expression<Func<TEntity, decimal>> where, ...);
 ValueTask<TResult> MaxAsync<TResult>(Expression<Func<TEntity, TResult>> where, ...);
 ValueTask<TResult> MinAsync<TResult>(Expression<Func<TEntity, TResult>> where, ...);
 ValueTask<double> AverageAsync(Expression<Func<TEntity, bool>> where, Expression<Func<TEntity, double>> averageBy, ...);
 
 // Advanced Queries
 ValueTask<IEnumerable<TResult>> GroupByAsync<TKey, TResult>(...);
 ValueTask<IEnumerable<TProperty>> DistinctAsync<TProperty>(...);
 ValueTask<bool> ExistsAsync(Expression<Func<TEntity, bool>> where, ...);
 
 // Batch Operations
 ValueTask<bool> AddRangeAsync(IEnumerable<TEntity> entities, ...);
 ValueTask<bool> UpdateRangeAsync(IEnumerable<TEntity> entities, ...);
 ValueTask<bool> DeleteRangeAsync(IEnumerable<TEntity> entities, ...);
}

IUnitOfWork

Transaction management interface.

public interface IUnitOfWork : IDisposable
{
 Task<int> SaveChangesAsync(CancellationToken cancellationToken = default);
 Task BeginTransactionAsync(CancellationToken cancellationToken = default);
 Task CommitTransactionAsync(CancellationToken cancellationToken = default);
 Task RollbackTransactionAsync(CancellationToken cancellationToken = default);
}

IManager

Service locator for accessing repositories.

public interface IManager
{
 IRepository<TEntity, TIdType> GetRepository<TEntity, TIdType>() 
 where TEntity : class, IEntity<TIdType>;
}

IDataAccessBlock

Marker interface for data access blocks.

public interface IDataAccessBlock : IBlock
{
}

Usage Examples

Basic CRUD Operations

public class UserService
{
 private readonly IRepository<User, Guid> _userRepository;
 private readonly IUnitOfWork _unitOfWork;

 public UserService(IRepository<User, Guid> userRepository, IUnitOfWork unitOfWork)
 {
 _userRepository = userRepository;
 _unitOfWork = unitOfWork;
 }

 // Create
 public async Task<User> CreateUserAsync(User user)
 {
 await _userRepository.AddAsync(user);
 await _unitOfWork.SaveChangesAsync();
 return user;
 }

 // Read
 public async Task<User> GetUserAsync(Guid id)
 {
 return await _userRepository.ReadByIdAsync(id);
 }

 // Update
 public async Task UpdateUserAsync(User user)
 {
 await _userRepository.UpdateAsync(user);
 await _unitOfWork.SaveChangesAsync();
 }

 // Delete (soft delete)
 public async Task DeleteUserAsync(Guid id)
 {
 await _userRepository.DeleteAsync(id, useSoftDelete: true);
 await _unitOfWork.SaveChangesAsync();
 }
}

Querying and Filtering

// Simple query
var activeUsers = await _userRepository.ReadManyByQueryAsync(u => u.IsActive);

// Query with ordering
var recentUsers = await _userRepository.ReadManyByQueryAsync(
 where: u => u.IsActive,
 orderBy: u => u.CreatedAt,
 orderByAscending: false
);

// Paged query
var pagedUsers = await _userRepository.ReadManyByQueryPagedAsync(
 where: u => u.IsActive && u.Email.Contains("@example.com"),
 page: 1,
 pageSize: 20
);

// Query with includes (navigation properties)
var usersWithOrders = await _userRepository.ReadManyByQueryWithIncludesAsync(
 where: u => u.IsActive,
 asNotracking: true,
 includes: "Orders", "Orders.Items"
);

// Query with projection
var userNames = await _userRepository.ReadByQueryWithSelectorAsync(
 where: u => u.IsActive,
 selector: u => new { u.Id, u.Name, u.Email }
);

Aggregations

// Count
int activeCount = await _userRepository.CountAsync(u => u.IsActive);

// Sum
decimal totalRevenue = await _userRepository.SumAsync(
 where: u => u.IsActive,
 sumBy: u => u.TotalPurchases
);

// Average
double averageAge = await _userRepository.AverageAsync(
 where: u => u.IsActive,
 averageBy: u => u.Age
);

// Min/Max
var oldestUser = await _userRepository.MaxAsync(u => u.Age);
var youngestUser = await _userRepository.MinAsync(u => u.Age);

// Group By
var usersByCountry = await _userRepository.GroupByAsync(
 filter: u => u.IsActive,
 groupBy: u => u.Country,
 selector: g => new 
 { 
 Country = g.Key, 
 Count = g.Count(),
 TotalRevenue = g.Sum(u => u.TotalPurchases)
 }
);

// Distinct
var countries = await _userRepository.DistinctAsync(
 selector: u => u.Country,
 filter: u => u.IsActive
);

Batch Operations

// Add multiple entities
var newUsers = new List<User> { user1, user2, user3 };
await _userRepository.AddRangeAsync(newUsers);
await _unitOfWork.SaveChangesAsync();

// Update multiple entities
await _userRepository.UpdateRangeAsync(usersToUpdate);
await _unitOfWork.SaveChangesAsync();

// Delete multiple entities
await _userRepository.DeleteRangeAsync(usersToDelete);
await _unitOfWork.SaveChangesAsync();

Transactions

public async Task TransferFundsAsync(Guid fromUserId, Guid toUserId, decimal amount)
{
 await _unitOfWork.BeginTransactionAsync();
 
 try
 {
 var fromUser = await _userRepository.ReadByIdAsync(fromUserId);
 var toUser = await _userRepository.ReadByIdAsync(toUserId);
 
 fromUser.Balance -= amount;
 toUser.Balance += amount;
 
 await _userRepository.UpdateAsync(fromUser);
 await _userRepository.UpdateAsync(toUser);
 
 await _unitOfWork.SaveChangesAsync();
 await _unitOfWork.CommitTransactionAsync();
 }
 catch
 {
 await _unitOfWork.RollbackTransactionAsync();
 throw;
 }
}

Using Manager Pattern

public class OrderService
{
 private readonly IManager _manager;
 private readonly IUnitOfWork _unitOfWork;

 public OrderService(IManager manager, IUnitOfWork unitOfWork)
 {
 _manager = manager;
 _unitOfWork = unitOfWork;
 }

 public async Task CreateOrderAsync(Order order)
 {
 var orderRepo = _manager.GetRepository<Order, Guid>();
 var userRepo = _manager.GetRepository<User, Guid>();
 
 var user = await userRepo.ReadByIdAsync(order.UserId);
 if (user == null) throw new Exception("User not found");
 
 await orderRepo.AddAsync(order);
 await _unitOfWork.SaveChangesAsync();
 }
}

Base Classes

BaseRepository<TEntity, TIdType>

Abstract base class for repository implementations.

public abstract class BaseRepository<TEntity, TIdType> : IRepository<TEntity, TIdType>
 where TEntity : class, IEntity<TIdType>
{
 protected abstract IQueryable<TEntity> GetQueryable();
 // ... common implementation
}

BaseDbContext

Abstract base class for database context implementations.

public abstract class BaseDbContext
{
 public abstract Task<int> SaveChangesAsync(CancellationToken cancellationToken = default);
 // ... common implementation
}

Entity Configuration

IEntityConfiguration<TEntity>

Interface for entity configuration.

public interface IEntityConfiguration<TEntity> where TEntity : class
{
 void Configure(IEntityBuilder<TEntity> builder);
}

EntityConfigurationRegistry

Registry for managing entity configurations.

public class EntityConfigurationRegistry : IEntityConfigurationRegistry
{
 public void Register<TEntity>(IEntityConfiguration<TEntity> configuration) 
 where TEntity : class;
 
 public IEnumerable<IEntityConfiguration<TEntity>> GetConfigurations<TEntity>() 
 where TEntity : class;
}

Enumerations

DatabaseType

public enum DatabaseType
{
 SqlServer,
 PostgreSQL,
 MySQL,
 MongoDB,
 SQLite,
 Oracle,
 MariaDB
}

OrmApproach

public enum OrmApproach
{
 EntityFramework,
 Dapper,
 MongoDB,
 Marten,
 NHibernate
}

Options

DataAccessOptions

public class DataAccessOptions
{
 public string ConnectionString { get; set; }
 public DatabaseType DatabaseType { get; set; }
 public OrmApproach OrmApproach { get; set; }
 public bool EnableSensitiveDataLogging { get; set; }
 public int CommandTimeout { get; set; }
}

Target Framework

• .NET 10

Dependencies

• Indiko.Common.Abstractions
• Indiko.Blocks.Common.Abstractions

License

See LICENSE file in the repository root.

Related Packages

• Indiko.Blocks.DataAccess.EntityFramework - Entity Framework Core implementation
• Indiko.Blocks.DataAccess.MongoDb - MongoDB implementation
• Indiko.Blocks.DataAccess.Marten - Marten (PostgreSQL) implementation
• Indiko.Blocks.Common.Management - Block management system