Implementing history tracking in SaveChanges overrides

Question

I am currently trying to track the history of all my tables in my application, overriding the method SaveChangesand using reflection. As a simple example, suppose I have 2 classes / dbsets for my domain objects and a history table for each type:

DbSet<Cat> Cats { get; set; }
DbSet<CatHistory> CatHistories { get; set; }
DbSet<Dog> Dogs { get; set; }
DbSet<DogHistory> DogHistories { get; set; }

The class is CatHistoryas follows ( DogHistoryfollows the same pattern):

public class CatHistory : HistoricalEntity
{
  public int CatId { get; set; }

  public virtual Cat Cat{ get; set; }
}

My goal is when the object is saved, I would like to insert a record in the corresponding history table. I am having the problem of overcoming the type difference when using reflection. My current attempt is below, and I seem to be stuck in a line //TODO::

        var properties = entry.CurrentValues.PropertyNames.Where(x => entry.Property(x).IsModified).ToList();

        //get the history entry type from our calculated typeName
        var historyType = Assembly.GetExecutingAssembly().GetTypes().FirstOrDefault(x => x.Name == historyTypeName);

        if(historyType != null)
        {

          //modified entries
          if (dbSet != null && historyDbSet != null && entry.State == EntityState.Modified)
          {
            var existingEntry = dbSet.Find(entry.Property("Id").CurrentValue);

            //create history record and add entry to table
            var newHistories = GetHistoricalEntities(existingEntry, type, entry);

            var listType = typeof(List<>).MakeGenericType(new[] { historyType });
            var typedHistories = (IList)Activator.CreateInstance(listType);

            //TODO: turn newHistories (type = List<HistoricalEntity>) into specific list type (List<MyObjectHistory>) so I can addrange on appropriate DbSet (MDbSet<MyObjectHistory>)

            historyDbSet.AddRange(newHistories);
          }
        }

Answer 1

AutoMapper . , , :

IList dogs = new List<Dog>() { new Dog { Id = 1, Name = "Alsatian" }, new Dog { Id = 2, Name = "Westie" } };
var dogHistoryType = typeof(DogHistory);
var listType = typeof(List<>).MakeGenericType(new[] { dogHistoryType });
var typedHistories = (IList)Activator.CreateInstance(listType);

mapper.Map(dogs, typedHistories);

foreach (var historyItem in typedHistories)
{
    this.Add(historyItem);
}

Answer 2

, .

, , .

BaseModel.cs

namespace ProductVersionModel.Model
{
    using System;
    using System.ComponentModel.DataAnnotations;
    using System.ComponentModel.DataAnnotations.Schema;

    /// <summary>
    /// all common properties of the tables are defined here
    /// </summary>
    public class BaseModel
    {
        /// <summary>
        /// id of the table
        /// </summary>
        [Key]
        public int Id { get; set; }

        /// <summary>
        /// user id of the user who modified last 
        /// </summary>
        public string LastModifiedBy { get; set; }

        /// <summary>
        /// last modified time
        /// </summary>
        public DateTime LastModifiedTime { get; set; }


        /// <summary>
        /// record created user id
        /// </summary>
        [Required]
        public string CreatedBy { get; set; }

        /// <summary>
        /// record creation time
        /// </summary>
        public DateTime CreationTime { get; set; }

        /// <summary>
        /// Not mapped to database, only for querying used
        /// </summary>
        [NotMapped]
        public int RowNumber { get; set; }
    }
}

Product.cs

namespace ProductVersionModel.Model
{
    using System;
    using System.Collections.Generic;
    using System.ComponentModel.DataAnnotations;

    /// <summary>
    /// store detals of the product
    /// </summary>
    public class ProductStatus : BaseModel
    {
        /// <summary>
        /// Name of the product
        /// </summary>
        [Required, MaxLength(100)]
        public string Name { get; set; }


        /// <summary>
        /// product version validity start date
        /// </summary>

        public DateTime ValidFrom { get; set; }

        /// <summary>
        /// product version valid till
        /// </summary>
        public DateTime? ValidTill { get; set; }

        /// <summary>
        /// This field used to keep track of history of a product
        /// </summary>
        public int ProductNumber { get; set; }

    }
}

HistoryBaseModel.cs

using System;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;

namespace ProductVersionModel.Model.History
{
    public class HistroyBaseModel
    {

        /// <summary>
        /// id of the table
        /// </summary>
        [Key,  DatabaseGenerated(DatabaseGeneratedOption.None)]
        public int Id { get; set; }

        public string DeletedBy { get; set; }

        public DateTime? DeletedTime { get; set; }
        /// <summary>
        /// record created user id
        /// </summary>
        [Required]
        public string CreatedBy { get; set; }

        /// <summary>
        /// record creation time
        /// </summary>
        public DateTime CreationTime { get; set; }
    }
}

ProductStatusHistory.cs

using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using ProductVersionModel.Model.History;

// ReSharper disable once CheckNamespace
namespace ProductVersionModel.Model.History
{
    public class ProductStatusHistory : HistroyBaseModel
    {

        /// <summary>
        /// Name of the product
        /// </summary>
        [MaxLength(100)]
        public string Name { get; set; }

        /// <summary>
        /// product version validity start date
        /// </summary>
        public DateTime ValidFrom { get; set; }

        /// <summary>
        /// product version valid till
        /// </summary>
        public DateTime? ValidTill { get; set; }

        /// <summary>
        /// This field used to keep track of history of a product
        /// </summary>
        public int ProductNumber { get; set; }

    }
}

CrudRepository

    public virtual int Delete(List<object> ids, string userName)
    {
        try
        {
            foreach (var id in ids)
            {
                var dbObject = _table.Find(id);
                HistroyBaseModel historyRecord = null;
                var modelAssembly = Assembly.Load(nameof(ProductVersionModel));
                var historyType =
                    modelAssembly.GetType(
                        // ReSharper disable once RedundantNameQualifier   - dont remove namespace it is required
                        $"{typeof(ProductVersionModel.Model.History.HistroyBaseModel).Namespace}.{typeof(TModel).Name}History");

                if (historyType != null)
                {
                    var historyObject = Activator.CreateInstance(historyType);

                    historyRecord = MapDeletingObjectToHistoyObject(dbObject, historyObject, userName);

                    DatabaseContext.Entry(historyRecord).State = EntityState.Added;
                }
                DatabaseContext.Entry(dbObject).State = EntityState.Deleted;
            }
            return DatabaseContext.SaveChanges();
        }
        catch (DbUpdateException ex)
        {
            throw HandleDbException(ex);
        }
    }

    protected virtual HistroyBaseModel MapDeletingObjectToHistoyObject(object inputObject, object outputObject, string userName)
    {
        var historyRecord = MapObjectToObject(inputObject, outputObject) as HistroyBaseModel;
        if (historyRecord != null)
        {
            historyRecord.DeletedBy = userName;
            historyRecord.DeletedTime = DateTime.UtcNow;
        }
        return historyRecord;
    }

    protected virtual object MapObjectToObject(object inputObject, object outputObject)
    {
        var inputProperties = inputObject.GetType().GetProperties();
        var outputProperties = outputObject.GetType().GetProperties();//.Where(x => !x.HasAttribute<IgnoreMappingAttribute>());
        outputProperties.ForEach(x =>
        {
            var prop =
                inputProperties.FirstOrDefault(y => y.Name.Equals(x.Name) && y.PropertyType == x.PropertyType);
            if (prop != null)
                x.SetValue(outputObject, prop.GetValue(inputObject));
        });

        return outputObject;
    }

TModel -

public class CrudRepository<TModel> : DataAccessBase, ICrudRepository<TModel> where TModel : class, new()
public class ProductStatusRepository : CrudRepository<ProductStatus>, IProductStatusRepository

MapDeletingObjectToHistoyObject MapObjectToObject , , .