prehistoric-systems/FilterLists
1
0
Fork 0
mirror of https://github.com/collinbarrett/FilterLists.git synced 2026-03-11 09:04:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

reafactors

Browse source 
ref #308
This commit is contained in:
Collin M. Barrett 2018-09-10 17:04:07 -05:00
parent ed1ae929bd
commit db1890ccdf
1 changed files with 14 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
src/FilterLists.Data/Seed/Extensions/SeedFilterListsDbContext.cs
View file

@ -37,7 +37,7 @@ private static void SeedOrUpdate<TEntity>(this DbContext dbContext, string dataP
var entityType = dbContext.Model.FindEntityType(typeof(TEntity));
var properties = GetPropertiesLessValueGeneratedTimestamps(entityType);
var seedRows = GetSeedRows<TEntity>(dataPath);
Delete(dbContext, seedRows);
ApplyRemovals(dbContext, seedRows);
InsertOnDuplicateKeyUpdate(dbContext, properties, entityType, seedRows);
}
@ -61,30 +61,23 @@ private static List<TEntity> GetSeedRows<TEntity>(string dataPath) where TEntity
}
//https://stackoverflow.com/a/52264468/2343739
private static void Delete<TEntity>(DbContext dbContext, IEnumerable<TEntity> seedRows)
where TEntity : class, IBaseEntity
private static void ApplyRemovals<TEntity>(DbContext dbContext, IEnumerable<TEntity> seedRows)
where TEntity : class
{
var entityType = dbContext.Model.FindEntityType(typeof(TEntity));
var entityPrimaryKey = entityType.FindPrimaryKey();
var entityPk = entityType.FindPrimaryKey();
var dbEntity = Expression.Parameter(entityType.ClrType, "e");
var matchAny = seedRows.Select(entity => entityPrimaryKey.Properties
.Select(p => Expression.Equal(
Expression.Property(dbEntity, p.PropertyInfo),
Expression.Property(Expression.Constant(entity), p.PropertyInfo)))
.Aggregate(Expression.AndAlso))
var matchAny = seedRows.Select(e => entityPk.Properties
.Select(p => Expression.Equal(
Expression.Property(dbEntity, p.PropertyInfo),
Expression.Property(Expression.Constant(e), p.PropertyInfo)))
.Aggregate(Expression.AndAlso))
.Aggregate<BinaryExpression, Expression>(null,
(current, match) => current != null ? Expression.OrElse(current, match) : match);
var dbQuery = dbContext.Set<TEntity>().AsQueryable();
if (matchAny != null)
{
var predicate = Expression.Lambda<Func<TEntity, bool>>(Expression.Not(matchAny), dbEntity);
dbQuery = dbQuery.Where(predicate);
}
var dbEntities = dbQuery.ToList();
if (dbEntities.Count == 0)
return;
dbContext.RemoveRange(dbEntities);
(current, match) =>
current != null ? Expression.OrElse(current, match) : match);
var notInSeedRows = Expression.Lambda<Func<TEntity, bool>>(Expression.Not(matchAny), dbEntity);
var removedEntities = dbContext.Set<TEntity>().Where(notInSeedRows);
dbContext.RemoveRange(removedEntities);
dbContext.SaveChanges();
}