DbHub 1.0.0

DbHub

DbHub is a .NET 10 generic database execution engine built with Clean Architecture and Clean Code principles. It provides a unified API to connect to multiple database providers and execute queries, stored procedures, non-query commands, and scalar operations — with built-in Redis caching and MongoDB-based connection configuration.

Features

• ✅ Multi-provider: SQL Server, MySQL, Oracle, MongoDB
• ✅ Strategy pattern: Easily add new database providers
• ✅ Redis caching: Connection strings are cached automatically
• ✅ MongoDB config store: Connection and procedure configurations stored in MongoDB
• ✅ Fully async: All operations are async/await with CancellationToken support
• ✅ Strongly typed generics: Results mapped to your models
• ✅ SOLID & Clean Architecture: Domain → Application → Infrastructure

Installation

dotnet add package DbHub

Quick Start

1. Register services

// Program.cs
builder.Services.AddDbHub(options =>
{
    options.MongoDbConnectionString = "mongodb://localhost:27017";
    options.MongoDbDatabase         = "DbHubConfig";
    options.RedisConnectionString   = "localhost:6379";
    options.CacheExpiry             = TimeSpan.FromHours(1);
});

2. Store a connection configuration in MongoDB

Insert a document into the ConnectionConfigs collection:

{
  "AppKey": "MyApp",
  "ConnectionType": 1,
  "DatabaseKey": "MainDb",
  "Server": "localhost",
  "Database": "MyDatabase",
  "User": "sa",
  "Password": "YourPassword",
  "Provider": "MSSQL",
  "Port": 0,
  "AdditionalSettings": {}
}

ConnectionType values: 1 = MSSQL, 2 = MYSQL, 3 = ORACLE, 4 = MONGODB

3. Execute operations

public class UserService(IDbHubService dbHub)
{
    public Task<IEnumerable<UserDto>> GetAllAsync(CancellationToken ct) =>
        dbHub.ExecuteQueryAsync<UserDto>(new DbHubRequest
        {
            AppKey         = "MyApp",
            ConnectionType = ConnectionType.MSSQL,
            DatabaseKey    = "MainDb",
            CommandText    = "SELECT Id, Name, Email FROM Users WHERE IsActive = @IsActive",
            Params         =
            [
                new DbHubParameter { Name = "IsActive", Value = true, Type = DbType.Boolean }
            ]
        }, ct);

    public Task<IEnumerable<UserDto>> GetByStoredProcedureAsync(CancellationToken ct) =>
        dbHub.ExecuteStoredProcedureAsync<UserDto>(new DbHubRequest
        {
            AppKey         = "MyApp",
            ConnectionType = ConnectionType.MSSQL,
            DatabaseKey    = "MainDb",
            ProcedureKey   = "GET_ACTIVE_USERS"
        }, ct);

    public Task<int> InsertAsync(string name, CancellationToken ct) =>
        dbHub.ExecuteNonQueryAsync(new DbHubRequest
        {
            AppKey         = "MyApp",
            ConnectionType = ConnectionType.MSSQL,
            DatabaseKey    = "MainDb",
            CommandText    = "INSERT INTO Users (Name) VALUES (@Name)",
            Params         = [new DbHubParameter { Name = "Name", Value = name }]
        }, ct);

    public Task<int?> CountAsync(CancellationToken ct) =>
        dbHub.ExecuteScalarAsync<int?>(new DbHubRequest
        {
            AppKey         = "MyApp",
            ConnectionType = ConnectionType.MSSQL,
            DatabaseKey    = "MainDb",
            CommandText    = "SELECT COUNT(*) FROM Users"
        }, ct);
}

MongoDB Provider

Architecture

DbHub                ← Public NuGet entry point
DbHub.Infrastructure ← Providers, repositories, cache, DI
DbHub.Application    ← Interfaces, services, request models
DbHub.Domain         ← Entities, interfaces
DbHub.Shared         ← Enums, models, utilities