Реализация общего репозитория с базовым репозиторием в качестве абстрактного класса

2020-08-01 c# asp.net-core ef-core-3.1 generic-repository

Чистый основной проект. Я пытаюсь реализовать общий шаблон хранилища. У меня есть базовый репозиторий, который является абстрактным. Поэтому я переопределяю базовый репозиторий и создаю другие мои репозитории. Реализация выглядит ниже.

BaseRepository.cs

 public abstract class BaseRepository<T>: IBaseRepository<T>
        where T : class
    {
       private readonly DbContext dbContext;
       private readonly DbSet<T> dbSet;
       public BaseRepository(DbContext dbContext)
        {
            this.dbContext = dbContext;
            this.dbSet = dbContext?.Set<T>();
        }
      public async Task<IEnumerable<T>> GetAsync(Expression<Func<T, bool>> filter = null, Func<IQueryable<T>, IOrderedQueryable<T>> orderBy = null, params Expression<Func<T, object>>[] includes)
        {
            IQueryable<T> query = this.dbSet;
            foreach (Expression<Func<T, object>> include in includes)
            {
                query = query.Include(include);
            }

            if (filter != null)
            {
                query = query.Where(filter);
            }

            if (orderBy != null)
            {
                query = orderBy(query);
            }

            return await query.ToListAsync().ConfigureAwait(false);
        }
     }
   }

Repository.cs

public class Repository<T> : BaseRepository<T>, IRepository<T>
        where T : class
    {
     private readonly DbContext dbContext;
     private readonly DbSet<T> dbSet;
     public Repository(DbContext context) : base(context)
        {
        }
     public async Task<IEnumerable<T>> GetAsync(Expression<Func<T, bool>> filter = null, Func<IQueryable<T>, IOrderedQueryable<T>> orderBy = null, params Expression<Func<T, object>>[] includes)
        {
            IQueryable<T> query = this.dbSet;
            foreach (Expression<Func<T, object>> include in includes)
            {
                query = query.Include(include);
            }

            if (filter != null)
            {
                query = query.Where(filter);
            }

            if (orderBy != null)
            {
                query = orderBy(query);
            }

            return await query.ToListAsync().ConfigureAwait(false);
        }
     }
   }

UnitOfWork.cs

public class UnitOfWork<TContext> : IUnitOfWork<TContext>
        where TContext : DbContext, IDisposable
    {
     private readonly MyContext context;
     private Dictionary<(Type type, string name), object> _repositories;
     public UnitOfWork(MyContext myContext)
        {
            if (this.context == null)
            {
                this.context = myContext;
            }
        }
     public IRepository<TEntity> GetRepository<TEntity>() where TEntity : class
        {
            return (IRepository<TEntity>)GetOrAddRepository(typeof(TEntity), new Repository<TEntity>(Context));
        }
      public async Task<int> CompleteAsync()
        {
            try
            {
                return await this.context.SaveChangesAsync().ConfigureAwait(false);
            }
            catch (DbUpdateConcurrencyException ex)
            {
                ex.Entries.Single().Reload();
                return await this.context.SaveChangesAsync().ConfigureAwait(false);
            }
        }
      internal object GetOrAddRepository(Type type, object repo)
        {
            _repositories ??= new Dictionary<(Type type, string Name), object>();

            if (_repositories.TryGetValue((type, repo.GetType().FullName), out var repository)) return repository;
            _repositories.Add((type, repo.GetType().FullName), repo);
            return repo;
        }
    }
  }

Тогда в моем файле startup.cs при регистрации

services.AddDbContext<MyContext>(options =>
       options.UseSqlServer(this.Configuration["AzureSQLConnectionString"]));
        services.AddScoped(typeof(IRepository<>), typeof(Repository<>));
        services.AddScoped<IUnitOfWork, UnitOfWork>();

UnitofWork выдает ошибку, используя универсальный тип 'UnitofWork', требующий аргумента 1 типа. Затем я добавил services.AddScoped<IUnitOfWork, UnitOfWork<MyContext>>() . Теперь ошибка в методе GetAsync в Repository.cs. Ошибка: Параметр: источник обязателен, он не может быть пустым. Потом я нашел

IQueryable query = this.dbSet;

запрос пуст Итак, я понял, что у меня есть некоторые проблемы с установлением соединения с БД. Может кто-нибудь помочь мне, что именно я здесь делаю неправильно? Любая помощь будет принята с благодарностью. Спасибо

Answers

Измените эти классы следующим образом:

public abstract class BaseRepository<T>: IBaseRepository<T>
        where T : class
    {
       protected readonly DbContext dbContext;
       protected readonly DbSet<T> dbSet;

       public BaseRepository(DbContext dbContext)
        {
            this.dbContext = dbContext;
            this.dbSet = dbContext?.Set<T>();
        }
      public virtual async Task<IEnumerable<T>> GetAsync(Expression<Func<T, bool>> filter = null, Func<IQueryable<T>, IOrderedQueryable<T>> orderBy = null, params Expression<Func<T, object>>[] includes)
        {
            IQueryable<T> query = this.dbSet;
            foreach (Expression<Func<T, object>> include in includes)
            {
                query = query.Include(include);
            }

            if (filter != null)
            {
                query = query.Where(filter);
            }

            if (orderBy != null)
            {
                query = orderBy(query);
            }

            return await query.ToListAsync().ConfigureAwait(false);
        }
     }

public class Repository<T> : BaseRepository<T>, IRepository<T>
        where T : class
    {
     
        public Repository(DbContext context) : base(context)
        {
        }

        //override GetAsync if different than base. In your case it is not.
     }

Related