Как сделать Bulk update методами LINQ (Entity Framework Core) дополнительной таблицы при связи много-ко-многим?

Question

[Nik Faraday]

Есть две таблицы Pharmacies и Products, которые связаны связью много-ко-многим. Пытаюсь сделать метод для обновления дополнительной таблицы PharmacyProductsEntity методом ExecuteUpdate, но не могу понять, как правильно построить такой запрос. Проблема в том, что не все методы могут транслироваться в SQL запрос.

Вот код, который я смог собрать:

public async Task ApplyRange(Guid pharmacyId, IEnumerable<(Guid id, int count)> products)
{
    await _table
    .Where(entity => entity.PharmacyId == pharmacyId && products.Where(p => p.id == entity.ProductId).Any())
    .ExecuteUpdateAsync(entity => entity.SetProperty(x => x.Count, x => x.Count + products.First(p => p.id == x.ProductId).count));
}

К сведению, используется Entity Framework Core 8.

Comments

[Александр]

Есть так же библиотека для Bulk Insert.
Вроде бы так же и называется ef core bulk.
Там есть метод, который вы ищите.

P. S. Сталкивался так же с проблемой что EF не умеет работать с bulk

[Nik Faraday]

Александр, Да, я нашёл несколько таких и им подобных, но есть проблема. Заключается она в том, что мне нужно сделать Update не превращая запрос в данные. В этом вся суть проблемы. В вопросе приведён код с использованием ExecuteUpdateAsync, который работает с запросом, а не с данными.

В ином случае, я бы их просто циклом закинул на udpate и не заморачивался)

[Александр]

Nik Faraday, честно говоря, так и не понял чем тебе не подходит данная либа, учитывая требования задачи.
Ну если уж не подходит либа, пробуй на самом sql писать, не используя orm

[Nik Faraday]

Александр, на sql не подходит, т.к. модель `Code First`. В другом случае я бы использовал `stored procedure`, но не тут.

так и не понял чем тебе не подходит данная либа, учитывая требования задачи

Условно, сделать так, как вы и поняли, но методами linq не преобразую запрос в данные (Без ToList, ToDictionary и т.д.)

Answer 1

[Сергей Соловьев]

Для данного случая предлагаю update в цикле, обернутую в транзакцию.
Так как даже в SQL такое не выразить

Примерно так

public async Task ApplyRange(Guid pharmacyId, IEnumerable<(Guid id, int count)> products)
{
    await _table.BeginTransactionAsync();
    for (var (id, count) in products)
    {
          await _table.Where(e => e.PharmacyId == pharmacyId && e.ProductId == id)
                              .ExecuteUpdateAsync(entity => entity.SetProperty(x => x.Count, x => x.Count + count))
    }
    await _table.CommitTransactionAsync();
}

Единственная проблема здесь в множественных RTT при каждом запросе, но все нивилируется тем, что выполняется в транзакции, т.е. большая задержка будет при коммите. Но рекомендую найти какую-нибудь либу, которая будет батчить подобные операции

P.S.
1. Есть CreateExecutionStrategy, который и реализует семантику транзакции
2. Код писал здесь в редакторе, поэтому может даже не компилироваться - главная задача дать идею

Comments

[Nik Faraday]

Спасибо за ответ. Основная проблема в том, что нужна производительность. Методы ToList, Select и т д. Вытягивают данные из БД, чего можно избежать используя метод ExecuteUpdate. На счёт транзакцие так же не очень уверен, посколько это всё можно сделать в рамках одного Update. Именно такой способ ищу

[Сергей Соловьев]

Nik Faraday, точно в рамках единственного update? как по мне, здесь явная хэштаблица для соответствия по id, поэтому я тут вижу несколько вариантов:
1. Все делать в единственной транзакции множественными update - наиболее переносимо и понятно
2. Найти какое-нибудь расширение, которое создает хэштаблицу и с помощью нее в одном запросе это все реализовать (хз как)
3. Использовать CTE - она будет этой хэштаблицей
4. Хранимая процедура

Последний - самый производительный

[Nik Faraday]

Сергей Соловьев, да, я бы использовал последний вариант как и в других случаях, но проект уже на половину написан, и сейчас не будут переписывать под database first. Тут всё на linq + ef, по этому тут сложно что-то предпринять.

Как вариант, можно просто запрос выполнять через Execute или подобное, но пока не знаю, честно

[Сергей Соловьев]

Nik Faraday, ef позволяет использовать хранимки, а создавать их через миграции.
И вообще, не надо тут устраивать культ - не существует чистых code/database first. Всегда есть компромиссы.