0

Добрый день! Можете рассказать о реализации паттерна Unit Of Work в среде ASP.NET Core

5
  • 1
    @vitidev: Из всей этой статьи мне кажется наиболее полезным комментарий: «Если посмотреть на EF со стороны, то DbContext — это и есть UnitOfWork, а DataSet — репозитории.»
    – VladD
    15 окт 2016 в 13:17
  • (вот длинное обсуждение по теме с разными мнениями)
    – VladD
    15 окт 2016 в 13:27
  • 2
    @VladD Нужно по другому задавать вопрос "что такого особенного в core, чтобы именно в нем этот паттерн реализовывался как то особенно". Лично я не в курсе
    – vitidev
    15 окт 2016 в 13:41
  • @vitidev: Держу пари, особенности именно ASP.NET, да ещё и Core 1.0 автору вопроса в реальности не так уж и важны.
    – VladD
    15 окт 2016 в 22:15

1 ответ 1

1

каждая repository дает работать с единицу информации:это единица может быть например один таблица или связанные таблицы или может быть другой контейнер информации
.обязанности паттерна Unit Of Work : связывать эти repository в одном логически связанным контейнере и содержать в себе те функсионали который относится в абстрактном манере для всех репозиторий. Например в какой то момент времени мы должны сохранить изменяемое Entities.тогда u Unit of Work'a должен быть метод Save()
Вот кусок кода из моей реальный программы:

 public interface IUnitOfWork : IDisposable
    {
        IEventRepository Events { get; set; }
       Task<int> SaveAsync();
        int Save();
    }


//Isolation from Concrete Info Container
    public interface IRepository<TEntity, TPrimaryType> where TPrimaryType : struct where TEntity : class
    {
        Task<TEntity> GetAsync(TPrimaryType id);
         Task<IEnumerable<TEntity>> GetAllAsync();
        IEnumerable<TEntity> Find(Expression<Func<TEntity, bool>> predicate);

        Task<TEntity> SingleOrDefaultAsync(Expression<Func<TEntity, bool>> predicate);

        Task AddAsync(TEntity entity);
        Task AddRangeAsync(IEnumerable<TEntity> entities);

        void Remove(TEntity entity);
        void RemoveRange(IEnumerable<TEntity> entities);
    }


public class Repository<TEntity, TPrimaryKey> : IRepository<TEntity, TPrimaryKey> where TPrimaryKey : struct where TEntity : class
    {
        protected readonly AccreditationDbContext Context;

        public Repository(AccreditationDbContext context)
        {
            Context = context;
        }

        /// <summary>
        /// Gets Item by id
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<TEntity> GetAsync(TPrimaryKey id)
        {
            return await Context.Set<TEntity>().FindAsync(id);
        }

        /// <summary>
        /// Get All Data as List
        /// </summary>
        /// <returns></returns>
        public async Task<IEnumerable<TEntity>> GetAllAsync()
        {
            return await Context.Set<TEntity>().ToListAsync();
        }

        /// <summary>
        /// Finds data using Expression tree predicate
        /// </summary>
        /// <param name="predicate"></param>
        /// <returns></returns>
        public IEnumerable<TEntity> Find(Expression<Func<TEntity, bool>> predicate)
        {
            return Context.Set<TEntity>().Where(predicate);
        }

        /// <summary>
        /// Gets first item matching predicate
        /// </summary>
        /// <param name="predicate"></param>
        /// <returns></returns>
        public async Task<TEntity> SingleOrDefaultAsync(Expression<Func<TEntity, bool>> predicate)
        {
            return await Context.Set<TEntity>().SingleOrDefaultAsync(predicate);
        }

        /// <summary>
        /// Add data to Context
        /// </summary>
        /// <param name="entity"></param>
        public async Task AddAsync(TEntity entity)
        {
           await Context.Set<TEntity>().AddAsync(entity);
        }

        /// <summary>
        /// Add data range to Context
        /// </summary>
        /// <param name="entities"></param>
        public async Task AddRangeAsync(IEnumerable<TEntity> entities)
        {
            await Context.Set<TEntity>().AddRangeAsync(entities);
        }

        /// <summary>
        /// Remove data from Context
        /// </summary>
        /// <param name="entity"></param>
        public void Remove(TEntity entity)
        {
            Context.Set<TEntity>().Remove(entity);
        }

        /// <summary>
        /// Remove range of data from Context
        /// </summary>
        /// <param name="entities"></param>
        public void RemoveRange(IEnumerable<TEntity> entities)
        {
            Context.Set<TEntity>().RemoveRange(entities);
        }

    }

 public interface IEventRepository : IRepository<Event,int>,IDbDependency<Event>
    {
        //TODO: add Event methods
    }


  public class UnitOfWork : IUnitOfWork
    {
        private readonly AccreditationDbContext _context;
        public IEventRepository Events { get; set; }

        public UnitOfWork(AccreditationDbContext context)
        {
            _context = context;
            Events = new EventRepository(_context);
        }
        public void Dispose()
        {
            _context.Dispose();
        }

        public async Task<int> SaveAsync()
        {
          return await _context.SaveChangesAsync();
        }
        public int Save()
        {
           return _context.SaveChanges();
        }
    }
2
  • Из вашего кода отлично видно, что реализация Unit Of Work свелась к обертке поверх готовой реализации Unit Of Work в виде контекста. Т.е. вы применили не SRP (который тут вообще никак не проявлен, максимум "ответственность класса UnitOfWork - приклеивание интерфейса IUnitOfWork к классу с готовой реализации его в EF"), а Interface Segregation
    – user177221
    6 сен 2017 в 17:57
  • "связывать эти repository в одном логически связанным контейнере и содержать в себе те функсионали который относится в абстрактном манере для всех репозиторий" - именно это делает класс-контекст в EF :)
    – user177221
    6 сен 2017 в 17:57

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.