Reo.Core.MongoDB 10.0.210

Reo.Core.MongoDB

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

Reo.Core.MongoDB — это библиотека, предназначенная для работы с MongoDB в .NET-приложениях. Пакет предоставляет инструменты для миграций данных, инициализации базы (сеединг), асинхронной обработки данных и управления версиями миграций. Он решает проблемы, связанные с настройкой и поддержкой MongoDB в приложениях, обеспечивая структурированный подход к управлению данными и автоматизируя рутинные задачи.

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

• Migration: Класс для определения миграций данных. Содержит методы ApplyAsync и RollbackAsync для применения и отката изменений.
• IMigrationBuilder: Интерфейс для создания и управления миграциями.
• IMongoDatabaseProvider: Сервис для получения экземпляра IMongoDatabase, используемого для взаимодействия с MongoDB.
• SeedService: Класс для инициализации базы данных (сеединг). Реализует интерфейс INoSqlSeedService.
• INoSqlSeedService: Интерфейс для сеединга. Включает методы SeedAsync (заполнение данных) и EntityName ( название сущности).
• AsyncEnumerable: Расширения для асинхронной итерации по документам MongoDB через IAsyncCursor.
• MigrationVersion: Класс для управления версиями миграций.

Требования

• .NET: Совместимо с .NET 8.0 и .NET 9.0.
• Зависимости:
  • MongoDB.Driver
  • Microsoft.Extensions.DependencyInjection

Установка

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

Install-Package Reo.Core.MongoDB

или

dotnet add package Reo.Core.MongoDB

Настройка

Регистрация в DI-контейнере (ASP.NET Core)

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

services.AddMongoDatabase("MongoDBSettings:ConnectionString", "MongoDBSettings:DatabaseName");
services.AddMigrations();
services.AddSeeders<SampleSeeder>();

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

• ConnectionString: Строка подключения к MongoDB.
• DatabaseName: Имя базы данных.
• MigrationVersion: Версия миграции (опционально).

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

Пример 1: Создание и применение миграции

public class SampleMigration : Migration
{
 public override async Task ApplyAsync(IMongoDatabase database, CancellationToken cancellationToken)
 {
 await database.GetCollection<User>("users").InsertManyAsync(
 new List<User> { new User { Name = "Alice" }, new User { Name = "Bob" } },
 cancellationToken
 );
 }
}

Пример 2: Реализация сеединга

public class SampleSeeder : INoSqlSeedService
{
 public string EntityName() => "Users";

 public async Task<int> SeedAsync(CancellationToken cancellationToken)
 {
 // Логика заполнения данных
 return 2; // Количество добавленных элементов
 }
}

Пример 3: Асинхронная обработка данных

var collection = database.GetCollection<MyDocument>("mycollection");
await foreach (var document in collection.ToAsyncEnumerable(cancellationToken))
{
 Console.WriteLine(document.Id);
}

Лицензия

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

Примечание: Для использования в проектах требуется явное указание версии MongoDB и настройка параметров подключения.