EF Core重写SavingChangesAsync返回值类型错误求助

我自定义了SaveLogChangeInterceptors继承自SaveChangesInterceptor，想要实现SavingChangesAsync方法，但在方法里不知道怎么正确返回eventData.Context?.SaveChangesAsync(true, cancellationToken)的结果，代码如下：

public class SaveLogChangeInterceptors : SaveChangesInterceptor
{
    public override ValueTask<InterceptionResult<int>> SavingChangesAsync(DbContextEventData eventData,
        InterceptionResult<int> result,
        CancellationToken cancellationToken = default)
    {
        // some code
        var interceptionResult = eventData.Context?.SaveChangesAsync(true, cancellationToken);

       return interceptionResult; // get error
    }
}

报错信息：

无法将表达式类型“System.Threading.Tasks.Task?”转换为返回类型“System.Threading.Tasks.ValueTask<Microsoft.EntityFrameworkCore.Diagnostics.InterceptionResult>”

问题原因 #

1. 类型不匹配：SaveChangesAsync(true, cancellationToken)返回的是Task<int>，但拦截器的SavingChangesAsync要求返回ValueTask<InterceptionResult<int>>，两者类型完全不同。
2. 逻辑错误：拦截器的SavingChangesAsync是EF Core的拦截扩展点，不应该直接调用Context.SaveChangesAsync，而是要通过基类方法延续整个拦截链，否则会跳过其他拦截器的逻辑。

正确实现方式 #

方式一：正常执行拦截流程（推荐） #

如果只是要在保存前执行自定义逻辑，然后让EF Core正常完成保存操作，直接调用基类方法即可：

public class SaveLogChangeInterceptors : SaveChangesInterceptor
{
    public override async ValueTask<InterceptionResult<int>> SavingChangesAsync(DbContextEventData eventData,
        InterceptionResult<int> result,
        CancellationToken cancellationToken = default)
    {
        // 这里写你的前置逻辑，比如记录变更日志、修改实体状态等

        // 调用基类方法，继续执行后续拦截器和EF Core的保存流程
        var finalResult = await base.SavingChangesAsync(eventData, result, cancellationToken);

        // 可选：保存完成后处理结果
        if (!finalResult.IsSuppressed)
        {
            // 保存操作已执行，finalResult.Result就是影响的行数
        }

        return finalResult;
    }
}

方式二：手动控制保存流程 #

如果需要手动决定是否执行保存，或者自定义返回结果，可以构造InterceptionResult：

public class SaveLogChangeInterceptors : SaveChangesInterceptor
{
    public override ValueTask<InterceptionResult<int>> SavingChangesAsync(DbContextEventData eventData,
        InterceptionResult<int> result,
        CancellationToken cancellationToken = default)
    {
        // 你的前置逻辑

        // 示例：满足条件时跳过保存操作
        if (需要跳过保存的条件)
        {
            return ValueTask.FromResult(InterceptionResult<int>.Suppress());
        }

        // 示例：手动执行保存并返回结果（不推荐，会跳过其他拦截器）
        if (eventData.Context != null)
        {
            var saveTask = eventData.Context.SaveChangesAsync(cancellationToken);
            return new ValueTask<InterceptionResult<int>>(
                saveTask.ContinueWith(t => 
                    InterceptionResult<int>.SuppressWithResult(t.Result), 
                    cancellationToken)
            );
        }

        // 默认调用基类方法
        return base.SavingChangesAsync(eventData, result, cancellationToken);
    }
}

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