[Из песочницы] Готовим ORM не отходя от плиты19.12.2016 01:33

public abstract class Repository : IRepository 
where T : EntityBase,new()
    {
    //Позже реализуем методы
    }

//суперкласс бизнес объекта 
public abstract class EntityBase : IEntity
    {
//в потомках необходимо явно переопределить идентификатор
        public abstract int Id { get; set; }
        public object Clone()
        {
            return MemberwiseClone();
        }
    }

    public interface IUnitOfWork : IDisposable
    {
        void Commit();
    }

    public static class Session
    {
        //локальное хранилище потока
        private static readonly ThreadLocal CurrentThreadData = 
        new ThreadLocal(true);
        public static IUnitOfWork Current
        {
            get { return CurrentThreadData.Value; }
            private set { CurrentThreadData.Value = value; }
        }
        public static IUnitOfWork Create(IUnitOfWork uow)
        {
            return Current ?? (Current = uow);
        }
    }

            var uow = new UnitOfWork();
            using (Session.Create(uow))
            {
                var profileRepo = new ProfileRepository();
                //Вызов методов репозитория
                uow.Commit();
           }

    internal struct EntityStruct
    {
       //тип объекта
        internal Type Key { get; private set; }
        internal EntityBase Value { get; private set; }
        internal EntityStruct(Type key, EntityBase value)
            : this()
        {
            Key = key;
            Value = value;
        }
        public override bool Equals(object obj)
        {
            return obj.GetHashCode() == GetHashCode();
        }
        public bool Equals(EntityBase obj)
        {
            return Equals(obj);
        }
        public override int GetHashCode()
        {
//в пределах одной бд, тип объекта и идентификатор однозначно определяют его уникальность
            var code = Key.GetHashCode() + Value.Id.GetHashCode();
            //хэш код должен быть положительным числом
            return code > 0 ? code : (-1) * code;
        }
    }

           var uow = new UnitOfWork();
            using (Session.Create(uow))
            {
                var profileRepo = new ProfileRepository();
            //регистрируем "чистые" объекты путем копирования полученных из бд, 
           //исходные считаем "грязными"
                var profiles = profileRepo.Get(x=>x.Info = "Хороший юзер");
                //изменяем "грязные" объекты
                foreach (var profile in profiles)
                {
                    profile.Info = "Плохой юзер";
                }
               //фиксация изменений
                uow.Commit();
           }

    internal interface IObjectTracker
    {
//для простоты приведен код регистрации только для измененных и новых объектов объектов
        ICollection NewObjects { get; }
        ICollection ChangeObjects { get; }
        //методы регистрации 
        void RegInsertedNewObjects(object sender, AddObjInfoEventArgs e);
        void RegCleanObjects(object sender, DirtyObjsInfoEventArgs e);
    }
    internal class DefaultObjectTracker : IObjectTracker
    {
        //ключ словаря - "грязный" объект, значение - "чистый" объект
        private readonly Dictionary _dirtyCreanPairs;
        public ICollection NewObjects { get; private set; }
        public ICollection ChangeObjects
        {
            get
            {
               // получаем измененные объекты
                return _dirtyCreanPairs.GetChangesObjects();
            }
        }
        internal DefaultObjectTracker()
        {
            NewObjects = new Collection();
  //Чтобы избежать лишних boxing/unboxing операций реализуем свой EqualityComparer
            _dirtyCreanPairs = 
          new Dictionary(new IdentityMapEqualityComparer());
        }
        public void RegInsertedNewObjects(object sender, AddObjInfoEventArgs e)
        {
            NewObjects.Add(e.InsertedObj);
        }
        public void RegCleanObjects(object sender, DirtyObjsInfoEventArgs e)
        {
            var objs = e.DirtyObjs;
            foreach (var obj in objs)
            {
                if (!_dirtyCreanPairs.ContainsKey(obj))
                {
  //получаем "чистый" объект путем клонирования исходного при помощи MemberwiseClone()
                    var cloneObj = new EntityStruct(obj.Key, (EntityBase)obj.Value.Clone());
                    _dirtyCreanPairs.Add(obj, cloneObj);
                }
            }
        }
      }

        public static ICollection GetChangesObjects
        (
         this Dictionary dirtyCleanPairs
        )
        {
            var result = new List();
            foreach (var cleanObj in dirtyCleanPairs.Keys)
            {
                if (!(cleanObj.Key == dirtyCleanPairs[cleanObj].Key))
                {
                    throw new Exception("incorrect types");
                }
                if (ChangeDirtyObjs(cleanObj.Value, dirtyCleanPairs[cleanObj].Value, cleanObj.Key))
                {
                    result.Add(cleanObj);
                }
            }
            return result;
        }
        public static bool ChangeDirtyObjs(EntityBase cleanObj, EntityBase dirtyObj, Type type)
        {
            var props = type.GetProperties();
           //цикл по каждому свойству объекта
            foreach (var prop in props)
            {
                var cleanValue = prop.GetValue(cleanObj, null);
                var dirtyValue = prop.GetValue(dirtyObj, null);
              //если хоть одно свойство изменено, считаем объект пригодным для регистрации
                if (!cleanValue.Equals(dirtyValue))
                {
                    return true;
                }
            }
            return false;
        }

    internal interface IDetector
    {
      //ключ слова - строка подключения к базу, значение - объект трекинга
        Dictionary ObjectDetector { get; }
    }

    public sealed class UnitOfWork : IUnitOfWork, IDetector
    {
        private readonly Dictionary _objectDetector;
        Dictionary IDetector.ObjectDetector
        {
            get { return _objectDetector; }
        }
        public UnitOfWork()
        {
            _objectDetector = new Dictionary();
            foreach (ConnectionStringSettings conName in ConfigurationManager.ConnectionStrings)
            {
             //каждому подключению к базе соответствует свой экземпляр трекинга
                _objectDetector.Add(conName.Name, new DefaultObjectTracker());
            }
        }
}

    public static class Session
    {
        private static readonly ThreadLocal CurrentThreadData = new ThreadLocal(true);
        public static IUnitOfWork Current
        {
            get { return CurrentThreadData.Value; }
            private set { CurrentThreadData.Value = value; }
        }
        public static IUnitOfWork Create(IUnitOfWork uow)
        {
            return Current ?? (Current = uow);
        }
        //Метод возвращает нужный экземляр трекинга для текущей транзакции
        // по имени строки подключения
        internal static IObjectTracker GetObjectTracker(string connectionName)
        {
            var uow = Current;
            if (uow == null)
            {
                throw new ApplicationException(" Create unit of work context and using Session.");
            }
            var detector = uow as IDetector;
            if (detector == null)
            {
                throw new ApplicationException("Create unit of work context and using Session.");
            }
            return detector.ObjectDetector[connectionName];
        }
    }
}

    internal interface IDataSourceProvider : IDisposable
    {
        State State { get; } 
        //для простоты фиксировать изменения в бд, будем только для измененных объектов
         void Commit(ICollection updObjs);
        ICollection GetByFields(BinaryExpression exp) where T : EntityBase, new();  
    }
    internal class DbProvider : IDataSourceProvider
    {
        private IDbConnection _connection;
        internal DbProvider(IDbConnection connection)
        {
            _connection = connection;
            State = State.Open;
        }
        public State State { get; private set; }
        public ICollection GetByFields(BinaryExpression exp) where T : EntityBase, new()
        {
            // делегат возвращающий текст select-запроса по выражению exp
            Func cmdBuilder =                                 SelectCommandBulder.Create;
            ICollection result;
            using (var conn = _connection)
            {
                using (var command = conn.CreateCommand())
                {
                    command.CommandText = cmdBuilder.Invoke(command, exp);
                    command.CommandType = CommandType.Text;
                    conn.Open();
                    result = command.ExecuteListReader();
                }
            }
            State = State.Close;
            return result;
        }
       public void Commit(ICollection updObjs)
        {
            if (updObjs.Count == 0)
            {
                return;
            }
              // ключ - делегат возвращающий текст update-запроса по выражению exp
              //значение - измененные объекты
            var cmdBuilder = new Dictionary, string>, ICollection>();
            cmdBuilder.Add(UpdateCommandBuilder.Create, updObjs);
            ExecuteNonQuery(cmdBuilder, packUpdDict, packDeleteDict);
        }  
       private void ExecuteNonQuery(Dictionary, string>, ICollection> cmdBuilder)
        {
            using (var conn = _connection)
            {
                using (var command = conn.CreateCommand())
                {
                    var cmdTxtBuilder = new StringBuilder();
                    foreach (var builder in cmdBuilder)
                    {
                        cmdTxtBuilder.Append(builder.Key.Invoke(command, builder.Value));
                    }
                    command.CommandText = cmdTxtBuilder.ToString();
                    command.CommandType = CommandType.Text;
                    conn.Open();
                    if (command.ExecuteNonQuery() < 1)
                        throw new ExecuteQueryException(command);
                }
            }
            State = State.Close;
        }
        private ICollection ExecuteListReader(EntityStruct objs)
        where T : EntityBase, IEntity, new()
        {
            Func cmdBuilder = SelectCommandBulder.Create;
            ICollection result;
            using (var conn = _connection)
            {
                using (var command = conn.CreateCommand())
                {
                    command.CommandText = cmdBuilder.Invoke(command, objs);
                    command.CommandType = CommandType.Text;
                    conn.Open();
                    result = command.ExecuteListReader();
                }
            }
            State = State.Close;
            return result;
        }
        private void Dispose()
        {
            if (State == State.Open)
            {
                _connection.Close();
                State = State.Close;
            }
            _connection = null;
            GC.SuppressFinalize(this);
        }
        void IDisposable.Dispose()
        {
            Dispose();
        }
        ~DbProvider()
        {
            Dispose();
        }
    }

    class DataSourceProviderFactory
    {
        static DbConnection CreateDbConnection(string connectionString, string providerName)
        {
            if (string.IsNullOrWhiteSpace(connectionString))
            {
                throw new ArgumentException("connectionString is null or whitespace");
            }
            DbConnection connection;
            DbProviderFactory factory;
            try
            {
                factory = DbProviderFactories.GetFactory(providerName);
                connection = factory.CreateConnection();
                if (connection != null) connection.ConnectionString = connectionString;
            }
            catch (ArgumentException)
            {
                try
                {
                    factory = DbProviderFactories.GetFactory("System.Data.SqlClient");
                    connection = factory.CreateConnection();
                    if (connection != null)
                    {
                        connection.ConnectionString = connectionString;
                    }
                }
                catch (Exception)
                {
                    throw new Exception("DB connection has been failed.");
                }
            }
            return connection;
        }
        public static IDataSourceProvider Create(string connectionString)
        {
            var settings = ConfigurationManager.ConnectionStrings[connectionString];

            var dbConn = CreateDbConnection(settings.ConnectionString, settings.ProviderName);
            return new DbProvider(dbConn);
        }
        public static IDataSourceProvider CreateByDefaultDataProvider(string connectionString)
        {
            var dbConn = CreateDbConnection(connectionString, string.Empty);
            return new DbProvider(dbConn);
        }
    }

    internal class TrackerProvider : IDataSourceProvider
    {
        private event EventHandler DirtyObjEvent;
        private event EventHandler UpdateObjEvent;
        private readonly IDataSourceProvider _dataSourceProvider;
        private readonly string _connectionName;
        private readonly object _syncObj = new object();
        private IObjectTracker ObjectTracker
        {
            get
            {
                lock (_syncObj)
                {
                   // получаем необходимый экземпляр трекинга
                    return Session.GetObjectTracker(_connectionName);
                }
            }
        }
        public TrackerProvider(string connectionName)
        {
            _connectionName = connectionName;
            _dataSourceProvider = DataSourceProviderFactory.Create(_connectionName);
           // регистрация событий трекинга
            RegisterEvents();
        }
        public State State
        {
            get
            {
                return _dataSourceProvider.State;
            }
        }
        private void RegisterEvents()
        {
           //Использование класса корректно только при использовании трекинга
            if (Session.Current == null)
            {
                throw new ApplicationException("Session has should be used. Create a session.");
            };
          //подписка на события трекинга
            DirtyObjEvent += ObjectTracker.RegCleanObjects;
            UpdateObjEvent += ObjectTracker.RegUpdatedObjects;
        }
        public ICollection GetByFields(BinaryExpression exp) 
        where T : EntityBase, IEntity, new()
        {
            //получаем исходные объекты из бд посредством экземпляра класса DbProvider
            var result = _dataSourceProvider.GetByFields(exp);
            var registratedObjs = result.Select(r => new EntityStruct(typeof(T), r)).ToList();
           //Возбуждаем событие регистрации "грязных" объектов
            var handler = DirtyObjEvent;
            if (handler == null)
                return result;
            handler(this, new DirtyObjsInfoEventArgs(registratedObjs));
            return result;
        }
        public void Commit(ICollection updObjs)
        {
              //полностью делегируем выполнение экземпляру класса DbProvider
            _dataSourceProvider.Commit(updObjs, delObjs, addObjs, packUpdObjs, deleteUpdObjs);
        }
        public void Dispose()
        {
            _dataSourceProvider.Dispose();
        }
    }

public abstract class Repository : IRepository 
where T : EntityBase, IEntity, new()
    {
        private readonly object _syncObj = new object();
        private IDataSourceProvider _dataSourceProvider;
     //c помощью свойства "мониторим" соединение с бд
        private IDataSourceProvider DataSourceProvider
        {
            get
            {
                lock (_syncObj)
                {
                    if (_dataSourceProvider.State == State.Close)
                    {
                        _dataSourceProvider = GetDataSourceProvider();
                    }
                    return _dataSourceProvider;
                }
            }
        }
        private readonly string _connectionName;
        protected Repository(string connectionName)
        {
            if (string.IsNullOrWhiteSpace(connectionName))
            {
                throw new ArgumentNullException("connectionName");
            }
            _connectionName = connectionName;
            var dataSourceProvider = GetDataSourceProvider();
            if (dataSourceProvider == null)
            {
                throw new ArgumentNullException("dataSourceProvider");
            }
            _dataSourceProvider = dataSourceProvider;
        }
        private IDataSourceProvider GetDataSourceProvider()
        {
              //если трекинг включен создаем экземпляр класса DbProvider'а
             // иначе создаем его ////декорированную версию - TrackerProvider
            return Session.Current == null ? DataSourceProviderFactory.Create(_connectionName)
                       : new TrackerProvider(_connectionName);
        }
        public ICollection Get(Expression> exp)
        {
            return DataSourceProvider.GetByFields(exp.Body as BinaryExpression);
        }
    }

    public sealed class UnitOfWork : IUnitOfWork, IDetector
    {
        private readonly Dictionary _objectDetector;
        Dictionary IDetector.ObjectDetector
        {
            get { return _objectDetector; }
        }
        public UnitOfWork()
        {
            _objectDetector = new Dictionary();
            foreach (ConnectionStringSettings conName in ConfigurationManager.ConnectionStrings)
            {
                _objectDetector.Add(conName.Name, new DefaultObjectTracker());
            }
        }
        public void Commit()
        {
            SaveChanges();
        }
        private async void SaveChanges()
        {
            await Task.Run(() =>
                    {
                    //фиксируем изменения в экземплярах трекинга по каждой из бд
                        foreach (var objectDetector in _objectDetector)
                        {
                            var provider = new TrackerProvider(objectDetector.Key);
                            provider.Commit(
                                objectDetector.Value.ChangeObjects);
                        }
                    }
                );
        }
    }