实体框架5变更日志如何实现？

Question

我正在使用 MVC4 和实体框架 5 创建一个应用程序。我该如何实现它？ 我环顾四周，发现我需要覆盖 SaveChanges 。

有人有这方面的示例代码吗？我使用的是代码优先方法。

例如，我保存数据的方式如下，

 public class AuditZoneRepository : IAuditZoneRepository
    {
        private AISDbContext context = new AISDbContext();



        public int Save(AuditZone model, ModelStateDictionary modelState)
        {
            if (model.Id == 0)
            {
                context.AuditZones.Add(model);
            }
            else
            {
                var recordToUpdate = context.AuditZones.FirstOrDefault(x => x.Id == model.Id);
                if (recordToUpdate != null)
                {
                    recordToUpdate.Description = model.Description;
                    recordToUpdate.Valid = model.Valid;
                    recordToUpdate.ModifiedDate = DateTime.Now;
                }
            }

            try
            {
                context.SaveChanges();
                return 1;
            }
            catch (Exception ex)
            {
                modelState.AddModelError("", "Database error has occured.  Please try again later");
                return -1;
            }
        }
    }

Answer 1

无需覆盖 SaveChanges。

你可以

触发器Context.ChangeTracker.DetectChanges(); // 可能是必要的，具体取决于您的代理方法

然后在保存之前分析上下文。 然后，您可以...将更改日志添加到当前工作单元。 所以日志被保存在一个 COMMIT 事务中。 或按您认为合适的方式处理它。 但同时保存您的更改日志。确保它是 ONE Transaction。

分析上下文样本： 我有一个简单的工具，可以转储上下文内容以调试输出，因此在调试器中我可以使用即时窗口来检查内容。例如 您可以将其用作准备更改日志的起点。 在调试器即时窗口中尝试。我的 Context 类上有 FULL 转储。

示例立即窗口调用。 UoW.Context.FullDump();

public void FullDump() {

        Debug.WriteLine("=====Begin of Context Dump=======");
        var dbsetList = this.ChangeTracker.Entries();
        foreach (var dbEntityEntry in dbsetList)
        {

            Debug.WriteLine(dbEntityEntry.Entity.GetType().Name + " => " + dbEntityEntry.State);
            switch (dbEntityEntry.State)
            {
                case EntityState.Detached:
                case EntityState.Unchanged:
                case EntityState.Added:
                case EntityState.Modified:
                    WriteCurrentValues(dbEntityEntry);
                    break;
                case EntityState.Deleted:
                    WriteOriginalValues(dbEntityEntry);
                    break;
                default:
                    throw new ArgumentOutOfRangeException();
            }
            Debug.WriteLine("==========End of Entity======");
        }
        Debug.WriteLine("==========End of Context======");
    }

    private static void WriteCurrentValues(DbEntityEntry dbEntityEntry)
    {
        foreach (var cv in dbEntityEntry.CurrentValues.PropertyNames)
        {
            Debug.WriteLine(cv + "=" + dbEntityEntry.CurrentValues[cv]);
        }
    }
    private static void WriteOriginalValues(DbEntityEntry dbEntityEntry)
    {
        foreach (var cv in dbEntityEntry.OriginalValues.PropertyNames)
        {
            Debug.WriteLine(cv + "=" + dbEntityEntry.OriginalValues[cv]);
        }
    }
}

编辑：获取更改

我使用此例程来获取更改...

public class ObjectPair {
    public string Key { get; set; }
    public object Original { get; set; }
    public object Current { get; set; }
 }

public virtual IList<ObjectPair> GetChanges(object poco) {
        var changes = new List<ObjectPair>();
        var thePoco = (TPoco) poco;


        foreach (var propName in Entry(thePoco).CurrentValues.PropertyNames) {
            var curr = Entry(thePoco).CurrentValues[propName];
            var orig = Entry(thePoco).OriginalValues[propName];
            if (curr != null && orig != null) {
                if (curr.Equals(orig)) {
                    continue;
                }
            }
            if (curr == null && orig == null) {
                continue;
            }
            var aChangePair = new ObjectPair {Key = propName, Current = curr, Original = orig};
            changes.Add(aChangePair);
        }
        return changes;
    }

edit 2 如果必须使用内部对象跟踪。

    var context =  ???// YOUR DBCONTEXT class
     // get objectcontext from dbcontext... 
     var   objectContext = ((IObjectContextAdapter) context).ObjectContext;
        // for each tracked entry
        foreach (var dbEntityEntry in context.ChangeTracker.Entries()) {
          //get the state entry from the statemanager per changed object
          var stateEntry =  objectContext.ObjectStateManager.GetObjectStateEntry(dbEntityEntry.Entity);
            var modProps = stateEntry.GetModifiedProperties();
            Debug.WriteLine(modProps.ToString());
        }

我反编译了 EF6 。得到修改确实是使用私有位数组来跟踪具有 已更改。

 // EF decompiled source..... _modifiedFields is a bitarray
 public override IEnumerable<string> GetModifiedProperties()
{
  this.ValidateState();
  if (EntityState.Modified == this.State && this._modifiedFields != null)
  {
    for (int i = 0; i < this._modifiedFields.Length; ++i)
    {
      if (this._modifiedFields[i])
        yield return this.GetCLayerName(i, this._cacheTypeMetadata);
    }
  }
}