Mds.Libraries.CSharp.Updates - пакет для работы с изменениями и их отслеживанием

Задачи пакета

• Средства для обновления в апи, PartialUpdater
• Применение и отмлеживание изменений, Updater
• Синхронизация и импорт, UpdatesIndex, CollectionsSynchronizer и GroupsSynchronizer

Синхронизация

Объявляем тип реализующий интерфейс IUpdatable.

using Mds.Libraries.CSharp.Updates.Synchronizers.Abstractions;
using Mds.Libraries.CSharp.Updates;

public class ClientSummary : BaseDataType, IUpdatable<ClientSummary>
{
    private static readonly MdsUpdater<ClientSummary> updater = new MdsUpdater<ClientSummary>();

    public ClientSummary() : base()
    {
        ExternalId = 0;
        Name = string.Empty;
    }

    public ClientSummary(Client import)
    {
        ExternalId = import.Id;
        Name = import.Name;
    }


    public long ExternalId { get; set; }
    public string Name { get; set; }


    // Реализация интерфейса IUpdatable
    public bool Update(ClientSummary update)
    {
        var updates = new Dictionary<string, object>
        {
            { nameof(ExternalId), update.ExternalId },
            { nameof(Name), update.Name }
        };

        return updater.Apply(this, updates);
    }
}

Коллекции

В месте, где нам нужна синххронизация коллекции создаем адаптер с указанием уникального свойства.

var adapter = CollectionsSynchronizerBuilder.Build<ClientSummary, long>(s => s.ExternalId);

// При желании можно указать настроки синхронизации
adapter.Settings = new CollectionsSynchronizerSettings
{
    ImportMode = ImportMode.Partial
};

Используем адаптер для синхронизации

// Когда синхронизируем все элементы в базе
var index = await adapter.SyncAsync(import, context);

// Когда синхронизируем только определенные элементы
var stored = new List<ClientSummary> { ... };
var index = adapter.Sync(converted, stored);

Переменная index содержит данные для синхронизации: какие элементы надо добавить, какие обновить, какие удалить.

Осталось только сохранить. Система умеет ускоренно (Bulk) сохранять в MSSQL и PostgreSQL

await index.SaveAsync(context);