EF变更追踪器修改状态下Current与Original值相同问题及批量优化咨询

常见触发场景 #

• 未追踪实体手动修改状态：如果实体是通过AsNoTracking()查询获取，之后手动将状态设为Modified，EF Core不会自动保留原始值，会导致OriginalValue与CurrentValue一致。
• 值类型转换干扰：使用Convert.ToString()转换属性值时，部分类型（如DateTime、自定义复杂对象）的原始值与当前值可能在字符串表现上一致，但实际值存在差异；若为引用类型，OriginalValue和CurrentValue可能指向同一实例，Equals判断会误判为相同。
• 变更追踪被提前重置：如果在调用SaveChanges前调用过ChangeTracker.AcceptAllChanges()或entry.AcceptChanges()，会重置变更追踪的原始值，导致两者同步。
• 属性未被正确追踪：若实体属性被标记为[NotMapped]或在ModelBuilder中配置为忽略，EF Core不会追踪其变更，IsModified状态可能异常。

调试建议 #

• 在SetChanges方法开头添加日志，输出entry.State和实体的完整信息，确认实体进入Modified状态的途径。
• 针对property.IsModified为true的属性，直接输出原始类型的OriginalValue和CurrentValue，而非转成字符串，验证值是否真的相同。
• 检查代码中是否存在调用AcceptAllChanges()或AcceptChanges()的逻辑，避免提前重置原始值。

当前代码在处理千条以上数据时，会因逐行处理、频繁操作上下文、冗余转换产生性能瓶颈，可从以下方向优化：

1. 批量操作替代逐行写入 #

• 先将所有日志对象收集到内存集合中，最后一次性批量添加到上下文，减少数据库往返次数。
• 可使用EF Core批量操作扩展（如EFCore.BulkExtensions）直接批量插入SystemLog和SystemChangeLog，大幅提升写入效率。

2. 减少冗余计算与反射 #

• 静态缓存忽略的属性集合：

  private static readonly HashSet<string> IgnoredProperties = new HashSet<string> 
  { 
      "ModifiedDate", "CreatedDate", "ModifiedBy", "CreatedBy", "RowVersion" 
  };
  

  用HashSet的Contains方法替代多次字符串相等判断，提升效率。
• 缓存实体Id属性的访问逻辑，避免每次循环都通过OriginalValues["Id"]和int.Parse获取值。

3. 变更追踪与异步优化 #

• 处理前暂时关闭自动变更检测：

  bool autoDetect = ChangeTracker.AutoDetectChangesEnabled;
  ChangeTracker.AutoDetectChangesEnabled = false;
  try
  {
      // 原有处理逻辑
  }
  finally
  {
      ChangeTracker.AutoDetectChangesEnabled = autoDetect;
  }
  

  减少EF Core内部的检测开销。
• 重写SaveChangesAsync方法，使用异步批量插入，适配高并发场景。

优化后核心代码片段 #

private static readonly HashSet<string> IgnoredProperties = new HashSet<string> 
{ 
    "ModifiedDate", "CreatedDate", "ModifiedBy", "CreatedBy", "RowVersion" 
};

private void SetChanges()
{
    var currentDate = DateTime.Now;
    var entitiesTracker = ChangeTracker.Entries()
        .Where(p => p.State == EntityState.Modified || p.State == EntityState.Added)
        .ToList();

    var allSystemLogs = new List<SystemLog>();
    var allChangeLogs = new List<SystemChangeLog>();

    foreach (var entry in entitiesTracker)
    {
        var pagename = entry.Entity.GetType().Name;
        if (pagename == "ExceptionLog")
            continue;

        int rowid = 0;
        if (entry.State == EntityState.Modified)
        {
            var idProperty = entry.Properties.FirstOrDefault(p => p.Metadata.Name == "Id");
            if (idProperty != null)
                rowid = Convert.ToInt32(idProperty.OriginalValue);
        }

        Guid systemLogId = Guid.NewGuid();
        var sysLog = new SystemLog
        {
            UserId = UserId,
            Date = currentDate,
            Page = pagename,
            Location = ExceptionHandler(entry, "Location"),
            IPAddress = ExceptionHandler(entry, "IPAddress"),
            MACAddress = ExceptionHandler(entry, "MACAddress"),
            SystemLogId = systemLogId.ToString()
        };

        var changeLog = new List<SystemChangeLog>();
        foreach (var property in entry.Properties)
        {
            string propertyName = property.Metadata.Name;
            switch (entry.State)
            {
                case EntityState.Added:
                    sysLog.Event = "Created";
                    break;
                case EntityState.Modified:
                    sysLog.Event = "Updated";
                    if (IgnoredProperties.Contains(propertyName))
                        continue;

                    if (property.IsModified && !Equals(property.OriginalValue, property.CurrentValue))
                    {
                        changeLog.Add(new SystemChangeLog
                        {
                            Property = propertyName,
                            OldValue = Convert.ToString(property.OriginalValue),
                            NewValue = Convert.ToString(property.CurrentValue),
                            DateOfChange = currentDate,
                            rowid = rowid,
                            SystemLogId = systemLogId.ToString()
                        });
                    }
                    break;
            }
        }

        allChangeLogs.AddRange(changeLog);
        if (changeLog.Count > 0 || entry.State == EntityState.Added)
            allSystemLogs.Add(sysLog);
    }

    if (allChangeLogs.Any())
        base.Set<SystemChangeLog>().AddRange(allChangeLogs);
    if (allSystemLogs.Any())
        base.Set<SystemLog>().AddRange(allSystemLogs);
}

4. 数据库层面优化 #

• 给SystemLog和SystemChangeLog表的SystemLogId字段创建索引，提升关联查询性能。
• 将日志写入操作分离到独立的数据库上下文，避免与业务数据操作互相阻塞。

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