如何在通用仓储中使用EF Core 8的ExecuteUpdate/Delete并保持接口无依赖

1. 定义应用层独立的抽象参数模型 #

在应用层创建不依赖EF Core的类，用来描述批量更新的属性操作逻辑，完全与数据访问技术解耦：

// 应用层 - 抽象更新操作模型
public class PropertyUpdate<TEntity>
    where TEntity : class
{
    public Expression<Func<TEntity, object>> PropertySelector { get; }
    public Expression<Func<TEntity, object>> ValueProvider { get; }

    public PropertyUpdate(Expression<Func<TEntity, object>> propertySelector, Expression<Func<TEntity, object>> valueProvider)
    {
        PropertySelector = propertySelector;
        ValueProvider = valueProvider;
    }
}

2. 设计应用层的通用仓储接口 #

接口仅使用应用层的抽象模型和标准LINQ表达式，无任何EF Core相关引用：

// 应用层 - 通用仓储接口
public interface IGenericRepository<TEntity>
    where TEntity : class
{
    Task<int> BulkDeleteAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default);
    Task<int> BulkUpdateAsync(IEnumerable<PropertyUpdate<TEntity>> propertyUpdates, Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default);
}

3. 基础设施层实现仓储，转换抽象到EF Core调用 #

在基础设施层的EF Core实现中，负责将应用层的抽象模型转换为EF Core的具体调用，仅在此层引入EF Core命名空间：

// 基础设施层 - EF Core仓储实现
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Query;

public class EfGenericRepository<TEntity> : IGenericRepository<TEntity>
    where TEntity : class
{
    private readonly DbContext _dbContext;
    private readonly DbSet<TEntity> _dbSet;

    public EfGenericRepository(DbContext dbContext)
    {
        _dbContext = dbContext;
        _dbSet = dbContext.Set<TEntity>();
    }

    public async Task<int> BulkDeleteAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default)
    {
        return await _dbSet.Where(predicate).ExecuteDeleteAsync(cancellationToken);
    }

    public async Task<int> BulkUpdateAsync(IEnumerable<PropertyUpdate<TEntity>> propertyUpdates, Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default)
    {
        return await _dbSet.Where(predicate).ExecuteUpdateAsync(setters =>
        {
            foreach (var update in propertyUpdates)
            {
                setters.SetProperty(update.PropertySelector, update.ValueProvider);
            }
            return setters;
        }, cancellationToken);
    }
}

4. 应用层调用示例（可选优化） #

可以在应用层添加扩展方法，简化PropertyUpdate的创建，让应用服务代码更简洁：

// 应用层 - 扩展方法
public static class PropertyUpdateExtensions
{
    public static PropertyUpdate<TEntity> SetProperty<TEntity, TProperty>(this Expression<Func<TEntity, TProperty>> propertySelector, Expression<Func<TEntity, TProperty>> valueProvider)
        where TEntity : class
    {
        return new PropertyUpdate<TEntity>(propertySelector, valueProvider);
    }
}

// 应用服务中调用示例
public async Task UpdateUserStatusesAsync(IEnumerable<Guid> userIds, bool newStatus, CancellationToken ct)
{
    var updates = new List<PropertyUpdate<User>>
    {
        PropertyUpdateExtensions.SetProperty<User, bool>(u => u.IsActive, _ => newStatus)
    };

    await _userRepository.BulkUpdateAsync(updates, u => userIds.Contains(u.Id), ct);
}

核心思路总结 #

• 依赖反转原则：应用层定义抽象的操作契约，基础设施层负责适配具体的数据访问技术，完全符合Clean Architecture的依赖规则。
• 技术隔离：EF Core的特定类型（如SetPropertyCalls）仅出现在基础设施层，应用层完全独立于数据访问实现，后续更换ORM时只需修改基础设施层代码，应用层无需变动。

内容的提问来源于stack exchange，提问作者Dario