1

Нужно реализовать набор классов для работы с СУБД.

Хочу реализовать шаблон Репозиторий.

Сначала я описываю сущности в виде классов, которые наследую от IRepository.

На этом этапе все ясно.

После того, как я описал все сущности по всей видимости мне их нужно сгруппировать в некоторую общую сущность, которая отвечает за соединение с БД и вот тут возникают вопросы...

Пришел вот к такой иерархии:

 public class Entity
{

    public int PrimaryKey;

}
public class Repository
{
    protected DbConnection Context;

    protected Repository(DbConnection context)
    {
        Context = context;
    }
}

interface IRepository<TEntity> where TEntity : Entity
{
    void Insert(TEntity entity);
    void Update(TEntity entity);
    void Delete(TEntity entity);
}

public class BookRepository : Repository, IRepository<Book>
{
    public BookRepository(DbConnection context) : base(context){}

    public void Insert(Book entity) { }

    public void Update(Book entity) { }

    public void Delete(Book entity) { }
}
public class Book : Entity
{

    public Book() { }
}

public class BookMarketRepositoy : Repository, IRepository<BookMarket>
{
    public BookMarketRepositoy(DbConnection context) : base(context){}

    public void Insert(BookMarket entity) { }


    public void Update(BookMarket entity) { }


    public void Delete(BookMarket entity) { }

}
public class BookMarket : Entity
{
    public BookMarket() { }
}

public class DbContext
{
    private DbConnection _conn;
    public BookMarketRepositoy BookMarkets { get; private set; }
    public BookRepository Books { get; private set; }

    public DbContext(DbConnection conn)
    {
        _conn = conn;
        if (_conn.State != ConnectionState.Open)
        {
            _conn.Open();
        }
        BookMarkets = new BookMarketRepositoy(conn);
        Books = new BookRepository(conn);
    }
}

Похоже ли реализация на правду или можно сделать иначе и лучше?

Готовое ORM использовать не хочется, так как схема данных и набор оперций примитивна.

12
  • 2
    Сначала я описываю сущности в виде классов, которые наследую от IRepository. зачем?
    – tym32167
    17 янв 2018 в 12:29
  • Я когда то делал подобное ( Entity, Repository )
    – tym32167
    17 янв 2018 в 12:31
  • @tym32167, С этим особо проблем нету. Мне бы пример агрегации репозиториев в контексте БД.
    – iluxa1810
    17 янв 2018 в 12:35
  • Книга является репозиторием книг? 17 янв 2018 в 12:39
  • 1
    Мне кажется, вам надо отталкиваться от юзкейсов, а то вы пишете код ради кода. Вам обязательно надо отдельный репозиторий на сущность? Вам обязательно нужны все эти методы CRUD в каждом репозитории? Вам точно не понадобится Unit of work? А что делать будете, если понадобится транзакция на несколько репозиториев? Шарить соединение? Как вы это планируете делать? Я предлагаю сперва подумать ЧТО вы хотите получить, а потом уже думать КАК написать код для этого.
    – tym32167
    17 янв 2018 в 13:43

1 ответ 1

3

Я бы посоветовал написать generic репозиторий вместе с UnitOfWork. Для этого сначала выделим интерфейс репозитория и базовую сущность модели:

public abstract class Entity
{
    public int Id { get; set; }
}

public interface IRepository<T>
    where T : Entity
{
    void Add(T entity);

    void Remove(T entity);

    IQueryable<T> Get();

    Task<T> GetAsync(int id);
}

Теперь нужно создать реализацию для этого репозитория. Поскольку мы пользуемся EF, то создадим реализацию на основе DbSet:

internal sealed class Repository<T> : IRepository<T>
    where T : Entity
{
    private readonly DbSet<T> dbSet;

    public Repository(DbSet<T> dbSet)
    {
        this.dbSet = dbSet;
    }

    public void Add(T entity)
    {
        dbSet.Add(entity);
    }

    public IQueryable<T> Get()
    {
        return dbSet;
    }

    public Task<T> GetAsync(int id)
    {
        return dbSet.SingleAsync(e => e.Id == id);
    }

    public void Remove(T entity)
    {
        dbSet.Remove(entity);
    }
}

Теперь нужно создать сущность, которая будет предоставлять нам репозитории для любого типа. Это и есть UnitOfWork:

internal sealed class UnitOfWork // Dispose context
{
    private readonly DbContext context;
    private readonly Dictionary<Type, object> repositories;

    public UnitOfWork(DbContext context)
    {
        this.context = context;
        repositories = new Dictionary<Type, object>();
    }

    public IRepository<T> GetRepository<T>()
        where T : Entity
    {
        object result;
        if (repositories.TryGetValue(typeof(T), out result))
        {
            return (IRepository<T>)result;
        }

        var newRepository = new Repository<T>(context.Set<T>());
        repositories[typeof(T)] = newRepository;
        return newRepository;
    }

    public Task SaveChangesAsync(CancellationToken cancellationToken)
    {
        return context.SaveChangesAsync(cancellationToken);
    }
}

Теперь напишем небольшой пример. Сначала определим сущность "книга", а потом поработаем с этой сущностью через наш репозиторий:

public class Book : Entity
{
    public string Name { get; set; }

    public string Author { get; set; }
}

using (var dbContext = new DbContext(""))
using (var uof = new UnitOfWork(dbContext))
{
    // достаем все книги Толкина
    var books = await uof
        .GetRepository<Book>()               // получили репозиторий
        .Get()                               // получили queryable
        .Where(b => b.Author == "Tolkien")   // отфильтровали
        .ToArrayAsync(cancellationToken);    // выполнили запрос и получили результаты

    // добавляем книгу Лема и сохраняем изменения
    var newBook = new Book
    {
        Author = "Lem",
        Name = "Solaris"
    };

    uof.GetRepository<Book>().Add(newBook);

    await uof.SaveChangesAsync(cancellationToken);
}
6
  • 1
    По поводу EF - автор пишет: Готовое ORM использовать не хочется
    – tym32167
    17 янв 2018 в 14:26
  • Не очень ясно, чем отличается ваш вариант от этого?
    – tym32167
    17 янв 2018 в 14:27
  • @tym32167, в том варианте репозитории для отдельных типов выставлены как свойства. Здесь же выставлен generic метод для получения репозитория сущностей нужного типа. Автор использует DbContext в своем примере. Я предположил, что он неправильно понимает термин ORM. Ну и хотелось размять мозг и написать код :) зы. С контекстом промашка - он самописный
    – Vlad
    17 янв 2018 в 15:40
  • ха, про словарь я проглядел. А почему обычный словарь? UoW не сможет жеж с многопоточностью работать с такой реализацией.
    – tym32167
    17 янв 2018 в 16:24
  • @tym32167, не сможет. Ну так и DbContext не умеет работать с многопоточностью. Поэтому нет смысла втыкать ConcurrentDictionary.
    – Vlad
    17 янв 2018 в 20:23

Ваш ответ

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

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