Xpandables.Data 10.0.2

System.Data

ADO.NET repository, unit-of-work, and SQL builder abstractions for raw database access.

📖 Overview

System.Data (NuGet: Xpandables.Data) provides IDataRepository<TData> for CRUD operations, IDataUnitOfWork for transaction management, and IDataSqlBuilder for generating provider-specific SQL. Supports SQL Server, PostgreSQL, and MySQL dialects. Namespace: System.Data.

Built for .NET 10 and C# 14.

✨ Features

📊 Repository

🔄 Unit of Work

🔗 Connection Management

🏗️ SQL Building

🔍 Specification & Interceptors

📦 Installation

dotnet add package Xpandables.Data

Dependencies: Microsoft.Extensions.Logging.Abstractions, Microsoft.Extensions.Options
Project References: Xpandables.AsyncPaged

🚀 Quick Start

Basic CRUD with Unit of Work

using System.Data;

// Create a unit of work (scoped connection)
await using IDataUnitOfWork unitOfWork = await unitOfWorkFactory.CreateAsync(ct);

// Start a transaction
await using IDataTransaction transaction = await unitOfWork.BeginTransactionAsync(ct);

// Get typed repositories
IDataRepository<Order> orderRepo = unitOfWork.GetRepository<Order>();
IDataRepository<OrderItem> itemRepo = unitOfWork.GetRepository<OrderItem>();

// Insert
var order = new Order { CustomerId = customerId, Total = 149.99m };
await orderRepo.InsertAsync(order, ct);

// Insert related items
var items = new[]
{
    new OrderItem { OrderId = order.Id, ProductName = "Widget", Qty = 2 },
    new OrderItem { OrderId = order.Id, ProductName = "Gadget", Qty = 1 }
};
await itemRepo.InsertAsync(items, ct);

// Commit transaction — rolls back automatically on failure
await transaction.CommitAsync(ct);

Query with Specification

// Define a specification for filtering and projection
var spec = new DataSpecification<Order, OrderSummary>
{
    Criteria = o => o.Status == "Active" && o.Total > 100,
    OrderBy = o => o.CreatedOn,
    PageSize = 20,
    CurrentPage = 1,
    Projection = o => new OrderSummary(o.Id, o.CustomerName, o.Total)
};

// Query — returns IAsyncEnumerable
await foreach (OrderSummary summary in orderRepo.QueryAsync(spec, ct))
{
    Console.WriteLine($"{summary.Id}: {summary.CustomerName} — {summary.Total:C}");
}

// Paged query — returns IAsyncPagedEnumerable with pagination metadata
IAsyncPagedEnumerable<OrderSummary> pagedResults = orderRepo.QueryPagedAsync(spec, ct);

await foreach (OrderSummary summary in pagedResults)
{
    Console.WriteLine(summary.CustomerName);
}

Pagination pagination = await pagedResults.GetPaginationAsync(ct);
Console.WriteLine($"Page {pagination.CurrentPage} of {pagination.TotalPages}");

Single-Item Queries

// Throws InvalidOperationException if not exactly one
OrderSummary single = await orderRepo.QuerySingleAsync(spec, ct);

// Returns default if none found
OrderSummary? maybeOrder = await orderRepo.QuerySingleOrDefaultAsync(spec, ct);

Update with DataUpdater

// Build a typed update
var updater = new DataUpdater<Order>()
    .Set(o => o.Status, "Completed")
    .Set(o => o.UpdatedOn, DateTime.UtcNow)
    .Where(o => o.Id == orderId);

await orderRepo.UpdateAsync(updater, ct);

Delete

await orderRepo.DeleteAsync(o => o.Id == orderId, ct);

SQL Dialects

The IDataSqlBuilder generates provider-specific SQL. Built-in dialects:

// SQL Server (T-SQL)   — MsDataSqlBuilder
// PostgreSQL            — PostgreDataSqlBuilder
// MySQL                 — MyDataSqlBuilder

SqlDialect dialect = SqlDialect.PostgreSql;

Command Interceptor (Logging)

// Register the logging interceptor to log all SQL commands
services.Configure<DataCommandInterceptorOptions>(options =>
{
    options.IsEnabled = true;
});

📄 License

Apache License 2.0 — Copyright © Kamersoft 2025