- 增加 FreeSql.DbContext DbSet Remove 可根据 lambda 条件删除数据的方法;

This commit is contained in:
28810 2019-10-26 11:11:05 +08:00
parent 06fba16b4a
commit f7633e9f67
2 changed files with 20 additions and 0 deletions

View File

@ -377,6 +377,16 @@ namespace FreeSql
_db._entityChangeReport.AddRange(dels.Select(a => new DbContext.EntityChangeReport.ChangeInfo { Object = a.Value, Type = DbContext.EntityChangeType.Delete })); _db._entityChangeReport.AddRange(dels.Select(a => new DbContext.EntityChangeReport.ChangeInfo { Object = a.Value, Type = DbContext.EntityChangeType.Delete }));
return Math.Max(dels.Length, affrows); return Math.Max(dels.Length, affrows);
} }
/// <summary>
/// 根据 lambda 条件删除数据
/// </summary>
/// <param name="predicate"></param>
/// <returns></returns>
async public Task<int> RemoveAsync(Expression<Func<TEntity, bool>> predicate)
{
await DbContextExecCommandAsync();
return await this.OrmDelete(null).Where(predicate).ExecuteAffrowsAsync();
}
#endregion #endregion
#region AddOrUpdateAsync #region AddOrUpdateAsync

View File

@ -410,6 +410,16 @@ namespace FreeSql
EnqueueToDbContext(DbContext.EntityChangeType.Delete, state); EnqueueToDbContext(DbContext.EntityChangeType.Delete, state);
} }
} }
/// <summary>
/// 根据 lambda 条件删除数据
/// </summary>
/// <param name="predicate"></param>
/// <returns></returns>
public int Remove(Expression<Func<TEntity, bool>> predicate)
{
DbContextExecCommand();
return this.OrmDelete(null).Where(predicate).ExecuteAffrows();
}
#endregion #endregion
#region AddOrUpdate #region AddOrUpdate