SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Fix BulkUpsert for EF Core 8

Browse source
This commit is contained in:
Sipke Schoorstra 2023-11-27 19:25:44 +01:00
parent b84bcdff93
commit 40fce04a14
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/modules/Elsa.EntityFrameworkCore.Common/Extensions/QueryableExtensions.cs
View file

@ -19,8 +19,13 @@ public static class QueryableExtensions
{
var set = dbContext.Set<TEntity>();
var compiledKeySelector = keySelector.Compile();
var containsLambda = keySelector.BuildContainsExpression(entities);
var existingEntities = await set.AsNoTracking().Where(containsLambda).ToListAsync(cancellationToken);
var containsLambda = entities.Any() ? keySelector.BuildContainsExpression(entities) : default;
var existingEntitiesQuery = set.AsNoTracking();
if (containsLambda != null)
existingEntitiesQuery = existingEntitiesQuery.Where(containsLambda);
var existingEntities = await existingEntitiesQuery.ToListAsync(cancellationToken);
var entitiesToUpdate = entities.IntersectBy(existingEntities.Select(compiledKeySelector), compiledKeySelector).ToList();
var entitiesToInsert = entities.Except(entitiesToUpdate).ToList();