EF6中通过DbCommandInterceptor修改嵌套集合数据不生效的问题

问题原因 #

你用DbCommandInterceptor的ReaderExecuted方法修改数据时，只处理了主实体的初始读取逻辑，但嵌套集合（比如T01_Object.T102_Child）的加载分为两种情况：

1. 立即加载（Include）：主查询返回包含子实体的合并结果集，但你可能没处理子实体对应的行数据；
2. 延迟加载：子集合会在首次访问时发起独立查询，这个查询未被当前拦截逻辑覆盖。
   另外，DataReader本身是只读的，直接修改实体对象可能因EF的跟踪机制或映射时机问题，导致嵌套集合的修改未被正确同步。

推荐解决方案：用ValueConverter统一处理属性转换 #

因为你的需求是单向、通用的加密解密逻辑，且T102_Child多处被使用，ValueConverter是EF Core原生支持的属性级转换方案，能自动应用到所有场景（立即/延迟加载、嵌套/单独查询），无需手动拦截查询。

步骤1：定义ValueConverter #

创建针对ChildName的转换类，实现从数据库值到应用层值的解密逻辑（单向操作，写入数据库时不做处理）：

public class ChildNameDecryptConverter : ValueConverter<string, string>
{
    public ChildNameDecryptConverter(ConverterMappingHints? hints = null)
        : base(
            dbValue => Decrypt(dbValue), // 读取时解密
            appValue => appValue,        // 写入时直接返回原值
            hints)
    {
    }

    // 替换为你的实际解密逻辑
    private static string Decrypt(string encryptedValue)
    {
        if (string.IsNullOrEmpty(encryptedValue))
            return encryptedValue;
        // 示例：模拟解密
        return Encoding.UTF8.GetString(Convert.FromBase64String(encryptedValue));
    }
}

步骤2：全局注册转换器 #

在DbContext的OnModelCreating方法中，将转换器绑定到T102_Child.ChildName属性：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    // 注册转换器到指定属性
    modelBuilder.Entity<T102_Child>()
        .Property(c => c.ChildName)
        .HasConversion(new ChildNameDecryptConverter());
    
    // 其他实体配置...
}

这样无论T102_Child是作为嵌套集合还是单独查询，ChildName都会自动解密，完全不需要手动干预查询过程。

若坚持使用DbCommandInterceptor的处理方式 #

如果必须基于拦截器实现，需要解决两个核心问题：覆盖所有查询（包括延迟加载的子查询）、正确修改DataReader中的子实体数据。

步骤1：确保拦截器全局生效 #

注册拦截器时要确保它被添加到所有DbContext实例：

services.AddDbContext<YourDbContext>(options =>
{
    options.UseSqlServer(Configuration.GetConnectionString("YourConn"))
           .AddInterceptors(new YourDataModifyInterceptor());
});

步骤2：包装DataReader处理所有行 #

因为DataReader是只读的，需要创建自定义的DbDataReader包装类，拦截属性读取逻辑：

public class ModifiedChildDataReader : DbDataReader
{
    private readonly DbDataReader _innerReader;

    public ModifiedChildDataReader(DbDataReader innerReader)
    {
        _innerReader = innerReader;
    }

    // 重写GetValue方法，处理ChildName列
    public override object GetValue(int ordinal)
    {
        var columnName = _innerReader.GetName(ordinal);
        if (columnName.Equals(nameof(T102_Child.ChildName), StringComparison.OrdinalIgnoreCase))
        {
            var encrypted = _innerReader.GetString(ordinal);
            return Decrypt(encrypted); // 你的解密逻辑
        }
        return _innerReader.GetValue(ordinal);
    }

    // 必须重写其他核心方法，直接委托给内部Reader
    public override bool Read() => _innerReader.Read();
    public override bool NextResult() => _innerReader.NextResult();
    public override int FieldCount => _innerReader.FieldCount;
    public override string GetName(int ordinal) => _innerReader.GetName(ordinal);
    public override Type GetFieldType(int ordinal) => _innerReader.GetFieldType(ordinal);
    public override int GetOrdinal(string name) => _innerReader.GetOrdinal(name);
    // 按需重写其他GetXXX方法（如GetString、GetInt32等）
}

步骤3：在ReaderExecuted中替换DataReader #

在拦截器的ReaderExecuted方法中，将原始DataReader替换为自定义包装类：

public class YourDataModifyInterceptor : DbCommandInterceptor
{
    public override void ReaderExecuted(DbCommand command, CommandExecutedEventData eventData, DbDataReader result)
    {
        base.ReaderExecuted(command, eventData, result);
        if (result != null && !result.IsClosed)
        {
            // 替换为自定义Reader，让EF读取修改后的数据
            var modifiedReader = new ModifiedChildDataReader(result);
            // 通过反射替换eventData中的Result（EF Core部分版本支持直接修改，需根据版本调整）
            var resultProperty = eventData.GetType().GetProperty("Result");
            resultProperty?.SetValue(eventData, modifiedReader);
        }
    }
}

这种方法需要处理DataReader的多结果集、不同数据类型读取等细节，复杂度远高于ValueConverter，仅推荐在特殊场景下使用。

关于EF数据变更通知的问题 #

不需要调用任何变更通知方法。你的修改是在数据从数据库映射到实体的阶段完成的，属于映射逻辑的一部分，而非修改已被EF跟踪的实体。只要转换逻辑正确，EF最终生成的实体对象会直接包含修改后的值。

内容的提问来源于stack exchange，提问作者Honza K.