如何仅通过实体框架更新实体的已更改属性



假设我们有一个MyDbContext里面有DbSet<MyEntity>。我正在尝试实现以下方案(因为我发现它被称为断开连接的场景或断开连接模式(:

  1. 我从数据库中获取List<MyEntity>(它可以只是通过DbContext.MyEntities.ToList()的所有记录或通过某些过滤条件的记录 - 没关系(。
  2. 然后将这些实体传递到用户可以在其中更改属性的某些 UI。他的行为是不可预测的:他可以改变每个实体的每个属性,或者他只能改变单个实体的一个属性(他甚至不能执行任何更改(。
  3. 之后,我需要将更新传递到数据库。

为了实现该方案,我找到了两种可能的解决方案:

1(在整个场景中保持连接畅通。所以它将像这样工作:

MyDbContext.Database.Connection.Open();
List<MyEntity> EntitiesList = MyDbContext.MyEntities.ToList();
//passing EntitiesList to the UI, where user can change them
EntitiesList[0].SomeStringProperty = "123";
//change some other properties here
//saving changes to database some time later
MyDbContext.SaveGhanges();
MyDbContext.Database.Connection.Close();

但在此解决方案中,数据库连接持续打开的时间过长。当 UI 工作时,它不应该打开(例如,用户可以在几个小时内更改实体(。

2(获得List<MyEntity>后关闭连接并打开 将更新传递到数据库时再次连接。所以它会起作用 喜欢这个:

MyDbContext.Database.Connection.Open();
List<MyEntity> EntitiesList = MyDbContext.MyEntities.ToList();
MyDbContext.Database.Connection.Close();
//passing EntitiesList to the UI, where user can change them
EntitiesList[0].SomeStringProperty = "123";
//change some other properties here
//saving changes to database some time later
MyDbContext.Database.Connection.Open();
foreach(var entity in EntitiesList)
{
//Attach updated entity and make context know that it is modified
MyDbContext.MyEntities.Attach(entity);
MyDbContext.MyEntities(entity).State = EntityState.Modified;
}
MyDbContext.SaveGhanges();
MyDbContext.Database.Connection.Close();

但是在这个解决方案中,我认为绝对修改了所有实体的所有属性。这会导致巨大的数据库更新开销。

另一种选择是编写MyEntityWrapper类,该类将跟踪用户执行的所有更改,并知道需要更新哪些属性。所以我可以将上面的代码更改为这个:

foreach(var entity in EntitiesList)
{
//Attach updated entity and make context know which properties are modified
MyDbContext.MyEntities.Attach(entity);
MyDbContext.Entry(entity).Property(e => e.SomeStringProperty).IsModified = true;
//mark other changed properties
}

那么 - 是否有一些更优雅的解决方案,我可以只更新更改的属性而不编写MyEntityWrapper类吗?我可以简单地告诉 DbContext:"这里有一些List<MyEntity>- 接受它,确定哪些属性与数据库中的值不同并更新这些值"?

顺便说一句。如果它很重要 - 我正在通过Devart dotConnect forSQLite +EntityFramework 6.0.1使用 SQLite 数据库

请查看下面的代码,我认为它可能会对您有所帮助(在谷歌上找到(

public virtual void Update(T entity, params Expression<Func<T, object>>[] updatedProperties)
{
//Ensure only modified fields are updated.
var dbEntityEntry = DbContext.Entry(entity);
if (updatedProperties.Any())
{
//update explicitly mentioned properties
foreach (var property in updatedProperties)
{
dbEntityEntry.Property(property).IsModified = true;
}
}
else{
//no items mentioned, so find out the updated entries
foreach (var property in dbEntityEntry.OriginalValues.PropertyNames)
{
var original = dbEntityEntry.OriginalValues.GetValue<object>(property);
var current = dbEntityEntry.CurrentValues.GetValue<object>(property);
if (original != null && !original.Equals(current))
dbEntityEntry.Property(property).IsModified = true;
}
}
}

最新更新