能否为所有仓储重写SaveChangesAsync方法？Blazor项目疑问

我有一个规模较大的Blazor项目，其中针对简单实体的小型仓储继承自GenericRepository，示例代码如下：

public class MySmallRepositoryOne : GenericRepository<MySmallEntityOne>, IMySmallRepositoryOne

但还有针对复杂实体的仓储并未继承自GenericRepository。请问是否可编写如下重写方法作用于所有仓储：

public override int SaveChangesAsync()
{
    // my code

    return base.SaveChangesAsync();
}

还是必须让所有仓储继承GenericRepository，并在该泛型仓储中实现此重写？

直接写单独的override方法无法作用于所有仓储 #

你写的override int SaveChangesAsync()只能在继承了GenericRepository的类中生效——因为override关键字要求当前类必须继承自包含该方法的基类。那些未继承GenericRepository的复杂仓储，根本没有这个方法可以重写，所以这种方式覆盖不了所有仓储。

可选解决方案 #

根据你的项目情况，有几种可行的实现方式：

1. 统一让所有仓储继承GenericRepository

这是最直接的方案：

• 在GenericRepository中实现统一的SaveChangesAsync重写逻辑，所有仓储（包括复杂实体的仓储）都继承这个泛型基类。
• 注意调整复杂仓储的现有逻辑：如果复杂仓储原本有自己的实现，需要确保继承后不会和基类逻辑冲突，必要时可以在子类中进一步重写（但尽量保持统一逻辑在基类）。
• 优势：后续新增的仓储自动复用统一逻辑，维护成本低。

2. 使用装饰器模式包装所有仓储

如果不想修改现有仓储的继承结构，可以用装饰器给所有仓储接口添加统一逻辑：

• 定义一个装饰器类，实现仓储接口，内部包装原始仓储实例，在SaveChangesAsync中插入统一逻辑：

public class RepositorySaveDecorator<TRepo, TEntity> : TRepo
    where TRepo : class, IRepository<TEntity>
{
    private readonly TRepo _originalRepo;

    public RepositorySaveDecorator(TRepo originalRepo)
    {
        _originalRepo = originalRepo;
    }

    public new async Task<int> SaveChangesAsync()
    {
        // 你的统一处理逻辑
        return await _originalRepo.SaveChangesAsync();
    }

    // 转发其他接口方法到原始仓储
    public override Task<TEntity> GetByIdAsync(int id)
    {
        return _originalRepo.GetByIdAsync(id);
    }
}

• 在DI容器注册时，用装饰器包装所有仓储实例：

// 注册原始仓储
services.AddScoped<IMySmallRepositoryOne, MySmallRepositoryOne>();
services.AddScoped<IComplexRepository, ComplexRepository>();

// 用装饰器包装
services.Decorate<IMySmallRepositoryOne, RepositorySaveDecorator<IMySmallRepositoryOne, MySmallEntityOne>>();
services.Decorate<IComplexRepository, RepositorySaveDecorator<IComplexRepository, ComplexEntity>>();

• 优势：不修改现有仓储代码，灵活适配不同仓储类型。

3. 使用EF Core拦截器（如果用EF作为数据访问）

如果你的仓储底层基于EF Core，直接用EF的拦截器可以实现全局SaveChanges逻辑，完全不需要修改仓储：

• 实现一个拦截器类：

public class GlobalSaveChangesInterceptor : SaveChangesInterceptor
{
    public override InterceptionResult<int> SavingChanges(DbContextEventData eventData, InterceptionResult<int> result)
    {
        // 同步版统一逻辑，比如审计字段赋值
        var entries = eventData.Context?.ChangeTracker.Entries()
            .Where(e => e.State is EntityState.Added or EntityState.Modified);
        foreach (var entry in entries)
        {
            if (entry.State == EntityState.Added)
            {
                entry.Property("CreatedAt").CurrentValue = DateTime.UtcNow;
            }
            entry.Property("UpdatedAt").CurrentValue = DateTime.UtcNow;
        }
        return base.SavingChanges(eventData, result);
    }

    public override ValueTask<InterceptionResult<int>> SavingChangesAsync(DbContextEventData eventData, InterceptionResult<int> result, CancellationToken cancellationToken = default)
    {
        // 异步版逻辑
        return base.SavingChangesAsync(eventData, result, cancellationToken);
    }
}

• 注册拦截器到DbContext：

services.AddDbContext<AppDbContext>(options =>
    options.UseSqlServer(Configuration.GetConnectionString("Default"))
           .AddInterceptors(new GlobalSaveChangesInterceptor()));

• 优势：最底层的全局控制，所有通过DbContext的SaveChanges都会触发，不管仓储如何实现。

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