Reo.Core.Database 10.0.209

Reo.Core.Database

Описание пакета

Reo.Core.Database — это абстрактный слой для работы с базами данных, предназначенный для упрощения и унификации доступа к данным в приложениях на C#. Пакет предоставляет общий интерфейс для выполнения операций CRUD, поддерживает инструменты для аудита изменений, а также включает реализации для работы с MongoDB и PostgreSQL. Он решает проблему дублирования кода при работе с разными СУБД и обеспечивает централизованное управление конфигурацией и состоянием баз данных.

Основные компоненты

1. IDataProvider<TId>

Интерфейс для выполнения операций с базой данных (CRUD, фильтрация, агрегация). Предоставляет методы для работы с сущностями, включая вставку, обновление, удаление и выборку данных.

2. IDataProviderFactory

Фабрика для создания экземпляров IDataProvider<TId>. Используется для интеграции с контейнером зависимостей (DI) в ASP.NET Core и других фреймворках.

3. MongoDataProvider

Реализация IDataProvider<string> для работы с MongoDB. Поддерживает асинхронные операции, фильтрацию и инклюзию связанных данных (через Include).

4. PostgresClusterHealthCheck

Реализация проверки состояния кластера PostgreSQL. Использует Npgsql для проверки доступности узлов кластера и обеспечивает высокую отказоустойчивость.

5. UpdateDateInterceptor

Инструмент для автоматического обновления даты последнего изменения сущности. Может быть интегрирован в ORM-провайдеры для отслеживания изменений.

Требования

• .NET версии: .NET Standard 2.0, .NET 6.0 и выше.
• Зависимости:
  • Npgsql (для PostgreSQL-проверок состояния).
  • Microsoft.Extensions.DependencyInjection (для интеграции с DI-контейнером).

Установка

Используйте следующие команды для установки пакета:

Install-Package Reo.Core.Database

или

dotnet add package Reo.Core.Database

Настройка

Регистрация в ASP.NET Core

Добавьте сервисы в Startup.cs или Program.cs:

services.AddSingleton<IDataProviderFactory, DataProviderFactory>();
services.AddSingleton<IDataProvider<string>, MongoDataProvider>();

Конфигурационные параметры

• Строка подключения MongoDB: Указывается в appsettings.json или через DI-контейнер.
• Проверка состояния PostgreSQL: Настройте параметры подключения в HealthChecks через PostgresClusterHealthCheck.

Использование

Пример 1: CRUD-операции с MongoDB

public class UserService
{
 private readonly IDataProvider<string> _dataProvider;

 public UserService(IDataProvider<string> dataProvider)
 {
 _dataProvider = dataProvider;
 }

 public async Task<User> GetUserByIdAsync(string id)
 {
 return await _dataProvider.Query<User>(x => x.Id == id).FirstOrDefaultAsync();
 }

 public async Task CreateUserAsync(User user)
 {
 await _dataProvider.InsertAsync(user);
 }
}

Пример 2: Проверка состояния PostgreSQL-кластера

public class HealthCheckService
{
 private readonly IHealthCheck _healthCheck;

 public HealthCheckService(IHealthCheck healthCheck)
 {
 _healthCheck = healthCheck;
 }

 public async Task CheckClusterHealthAsync()
 {
 var result = await _healthCheck.CheckHealthAsync(new HealthCheckContext());
 if (result.Status != HealthStatus.Healthy)
 {
 // Обработка ошибки
 }
 }
}

Пример 3: Автоматическое обновление даты изменения

public class Product
{
 public string Id { get; set; }
 public string Name { get; set; }
 public DateTime LastUpdated { get; set; }
}

// В конфигурации ORM:
services.AddSingleton<UpdateDateInterceptor>();

Лицензия

Данный пакет распространяется под лицензией MIT.