我应该如何删除 DbSet 中的所有元素

本文关键字：元素 DbSet 何删除 删除 我应该 | 更新日期: 2023-09-27 18:33:06

使用实体框架 4.3 删除 System.Data.Entity.DbSet 中的所有元素的最佳方法是什么？

我应该如何删除 DbSet 中的所有元素

dbContext.Database.ExecuteSqlCommand("delete from MyTable");

（不开玩笑。

问题是 EF 不支持任何批处理命令，不使用直接 DML 删除集合中所有实体的唯一方法是：

foreach (var entity in dbContext.MyEntities)
    dbContext.MyEntities.Remove(entity);
dbContext.SaveChanges();

或者可能便宜一点以避免加载完整的实体：

foreach (var id in dbContext.MyEntities.Select(e => e.Id))
{
    var entity = new MyEntity { Id = id };
    dbContext.MyEntities.Attach(entity);
    dbContext.MyEntities.Remove(entity);
}
dbContext.SaveChanges();

但在这两种情况下，您都必须加载所有实体或所有键属性，并从集合中逐个删除实体。此外，当您调用SaveChanges EF会将n（=集合中的实体数）DELETE语句发送到数据库，这些语句也会在数据库中逐个执行（在单个事务中）。

因此，直接SQL显然更可取，因为您只需要一个DELETE语句。

旧帖子，但现在有一个 RemoveRange 方法：

    dbContext.MyEntities.RemoveRange(dbContext.MyEntities);
    dbContext.SaveChanges();
这是在

代码中执行此操作的另一种方法。

public static class Extensions
{
    public static void DeleteAll<T>(this DbContext context)
        where T : class
    {
        foreach (var p in context.Set<T>())
        {
            context.Entry(p).State = EntityState.Deleted;
        }
    }
}

实际调用该方法并清除集合：

myDbContext.DeleteAll<MyPocoClassName>();

如果要在不编写任何 SQL 的情况下删除所有元素，并且只执行单个 Db 调用

实体框架扩展库提供批量删除方法。

context.Users.Delete();

由于接受的答案仅提及以下方法：

context.Database.ExecuteSqlCommand("delete from MyTable");

而是提供了它的替代方案，我设法编写了一个方法，您可以使用该方法来避免加载所有实体，然后循环遍历它们并使用 ExecuteSqlCommand 代替。

假设使用工作单元，其中上下文是 DbContext：

using System.Data.Entity.Core.Objects;
using System.Text.RegularExpressions;
public void DeleteAll()
{
    ObjectContext objectContext = ( (IObjectContextAdapter)context ).ObjectContext;
    string sql = objectContext.CreateObjectSet<T>().ToTraceString();
    Regex regex = new Regex( "FROM (?<table>.*) AS" );
    Match match = regex.Match( sql );
    string tableName = match.Groups[ "table" ].Value;
    context.Database.ExecuteSqlCommand( string.Format( "delete from {0}", tableName ) );
}

第一个代码块检索 ExecuteSqlCommand 方法中所需的表名。

用法：

using ( var context = new UnitOfWork() )
{
    context.MyRepository.DeleteAll();
}

无需致电 

context.SaveChanges()

如果您正在使用工作单元和通用存储库，您可能会发现以下内容很有用

public virtual void DeleteWhere(Expression<Func<TEntity, bool>> filter = null,
            Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBy = null,
            string includeProperties = "")
        {
            IQueryable<TEntity> query = dbSet;
            if (filter != null)
            {
                query = query.Where(filter);
            }
            foreach (var includeProperty in includeProperties.Split
                (new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries))
            {
                query = query.Include(includeProperty);
            }
            foreach (var entity in query)
            {
                context.Entry(entity).State = EntityState.Deleted;
            }
        }

用法：

uow.myRepositoryName.DeleteWhere(u => u.RoomId == roomId);
uow.Save();

使用存储库模式，您可以在其中为存储库提供模型的类型，它可以处理任何模型类型。

    public async Task<int> RemoveAllAsync()
    {
        Context.Set<T>().RemoveRange(await Context.Set<T>().ToListAsync());
        return await Context.SaveChangesAsync();
    }
相关文章：