如何批量更新实体框架中的记录？

Question

我正在尝试使用实体框架批量更新记录。我试过 Entity Framework.Extensions

Update

方法。

Update

方法能够批量更新一组具有相同更新值的记录。

例子：

           Id -  Quantity
Record 1 - A  -  10
Record 2 - B  -  20
Record 3 - C  -  30

我们可以通过简单的调用批量更新以上所有记录

Records.Update(new => Record { Quantity = 100 });

如何使用

Entityframework.Extensions

或任何其他方法批量更新不同数量的每条记录，从而更快地完成批量更新？

Answer 1

如果不想使用 SQL 语句，可以使用 Attach 方法来更新实体而无需先加载它：

using (myDbEntities db = new myDbEntities())
{
    try
    {
      //disable detection of changes to improve performance
      db.Configuration.AutoDetectChangesEnabled = false;

      //for all the entities to update...
      MyObjectEntity entityToUpdate = new MyObjectEntity() {Id=123, Quantity=100};
      db.MyObjectEntity.Attach(entityToUpdate);

      //then perform the update
      db.SaveChanges();
    }
    finally
    {
      //re-enable detection of changes
      db.Configuration.AutoDetectChangesEnabled = true;
    }
}

Answer 2

使用

ExecuteSqlCommand

：

using (yourDbEntities db = new yourDbEntities())
{
    db.Database.ExecuteSqlCommand("UPDATE YourTABLE SET Quantity = {0} WHERE Id = {1}", quantity, id);
}

或

ExecuteStoreCommand

：

yourDbContext.ExecuteStoreCommand("UPDATE YourTABLE SET Quantity = {0} WHERE Id = {1}", quantity, id);

Answer 3

EFCore内置了

ExecuteUpdate

和

ExecuteDelete

方法，EFCore 7.0已经交付了

context.Customers.Where(...).ExecuteDeleteAsync();
context.Customers.Where(...).ExecuteUpdateAsync(c => new Customer { Age = c.Age + 1 });
context.Customers.Where(...).ExecuteUpdateAsync(c => new { Age = c.Age + 1 });

Answer 4

如果您只想修改几个属性，请使用这种方式：

foreach (var vSelectedDok in doks)
{
    //disable detection of changes to improve performance
    vDal.Configuration.AutoDetectChangesEnabled = false;
    
    vDal.Dokumente.Attach(vSelectedDok);

    vDal.Entry(vSelectedDok).Property(x=>x.Status).IsModified=true;
    vDal.Entry(vSelectedDok).Property(x => x.LastDateChanged).IsModified = true;
}
vDal.SaveChanges();

Answer 5

a) EFCore.BulkExtensions - BatchUpdateAsync

_dbContext.Set<MyObjectEntity>().BatchUpdateAsync( x => new MyObjectEntity{ Id=123, Quantity=100 });

https://github.com/borisdj/EFCore.BulkExtensions

"EntityFrameworkCore 扩展：批量操作（插入、更新、删除、读取、更新插入、同步）和批处理（删除、更新）。 库是轻量级且非常高效的，具有所有主要使用的 CRUD 操作。 入选微软推荐的前 20 名 EF 核心扩展。”

b) 或 EF 扩展 - UpdateFromQuery

_dbContext.Set<MyObjectEntity>().UpdateFromQuery( x => new MyObjectEntity{ Id=123, Quantity=100 });

资源：

https://entityframework-extensions.net/update-from-query

https://stackoverflow.com/a/63460251/12425844

为什么 UpdateFromQuery 比 SaveChanges、BulkSaveChanges 和 BulkUpdate 更快？

UpdateFromQuery 直接在SQL中执行一条语句这样 作为 UPDATE [TableName] SET [SetColumnsAndValues] WHERE [Key].

其他操作通常需要一次或多次数据库往返 这使得性能变慢。

Answer 6

我找到了一个easy way to do that without any 3rd party packages：
通过添加一个通用的扩展方法

SetValue

你可以简单地写：

例子：

void Main()
{
    
    var dc = this; // context
    var p = dc.Purchases.Where(x=>x.Description.ToLower()=="bike")
                        .SetValue(w => w.Description = "Bicycle");
    p.Dump();
    dc.SubmitChanges();
}

如您所见，任何符合

Where

条件的值都可以显式设置为新值，因此这里的

Bike

将被

Bicycle

替换。之后您可以查询表格以查看更改是否真正保留。

当然，如果你想改变所有的记录，你也可以省略

Where

语句：

dc.Records.SetValue(x => x.Quantity = 100);
dc.SubmitChanges();

实体框架 (EF) / LINQ 跟踪这些更改，当您调用 .SubmitChanges() - 如果您使用的是 LinqPad，您可以在 SQL 选项卡中看到 - 它将创建如下 SQL 代码：

-- Region Parameters
DECLARE @p0 Int = 3
DECLARE @p1 VarChar(1000) = 'Bicycle'
-- EndRegion
UPDATE [Purchase]
SET [Description] = @p1
WHERE [ID] = @p0

对于小的更改，这没问题，但是对于大表，它变得效率低下，因为它使用 ID 列来标识和更改记录，而不是 .SetValue 定义的描述列。

理论上 EF 可以对此进行优化，但如您所见，它并没有这样做。 因此，如果你想要真正的批量操作，你需要运行一个 SQL 命令，或者创建一个你通过 EF 调用的存储过程（用于复杂查询）。

---

扩展方法

SetValue

这个扩展方法可以解决问题（不需要其他第 3 方包）：

// see: https://visualstudiomagazine.com/articles/2019/07/01/updating-linq.aspx
public static class Extensions
{
    public static IEnumerable<T> SetValue<T>(this IEnumerable<T> items, 
                                                  Action<T> updateMethod)
    {
        foreach (T item in items)
        {
            updateMethod(item);
        }
        return items;
    }
}

---

注： 上面的示例使用了Nutshell示例数据库，您可以通过此链接轻松创建该数据库，代码是为LinqPad 6编写的，但可以轻松调整（LinqPad 6使用.NET Core，但您可以尝试一下LinqPad 5 以及 .NET Framework）。

Answer 7

在 EF 6 中，我们在每个表中都有 AddRange 方法。文档表明此方法比使用许多添加方法快得多。因此，可以将所有可更新的记录插入临时表并使用单个 sql 语句批量更新主表。

编辑：这个Document建议AddRange只优化变化检测。它不会改变将更改应用到数据库的方式。

Answer 8

幸运的是，EF Core7引入了

ExecuteUpdate

和

ExecuteDelete

来提高更新和删除操作的性能，是目前批量更新和批量删除的最佳选择。

var affectedRows = await DbContext.Records
   .ExecuteUpdateAsync(updates => updates.SetProperty(p => p.Quantity, 100));

https://medium.com/@mahsan-ghasemi-dev/bulk-update-and-bulk-delete-using-executeupdate-and-executedelete-in-ef-core7-8751e94e6953

Answer 9

批量更新可以通过简单的 EF 分三步完成，而不是单独的扩展方法：-

• 首先加载所有实体。
• 对每个实体进行 Foreach 并更改其字段值。
• 在 Foreach 之后保存上下文更改一次。

这将在单个批次中发送多个更新查询。

Answer 10

可以通过使用

UpdateRange([NotNullAttribute] params TEntity[] entities)

       private void bulkTagUpdate()
        {
            RfidTag tag = new RfidTag
            {
                Id = 1,
                Status ="tight",
                TagId = "234353444",
                LocationId = "1",
                CreatedAt = DateTime.Now,
                UpdatedAt = DateTime.Now,
            };
            RfidTag tag2 = new RfidTag
            {
                Id = 2,
                Status = "tight",
                TagId = "3454544",
                LocationId = "1",
                CreatedAt = DateTime.Now,
                UpdatedAt = DateTime.Now,
            };

            List<RfidTag> tagList = new List<RfidTag>();
            tagList.Add(tag);
            tagList.Add(tag2);

            using (rfid_statusContext context = new rfid_statusContext())
            {
                context.RfidTags.UpdateRange(tagList);
                context.SaveChanges();
                MessageBox.Show("Update successfull !");
            }
        }