OnRepository.EFCore

The repository and unit of work patterns are intended to create an abstraction layer between the data access layer and the business logic layer of an application. Implementing these patterns can help insulate your application from changes in the data store and can facilitate automated unit testing or test-driven development (TDD). more

This package helps you to easily implement Repository Pattern in your programs.

Authors

• @thisisnabi

Features

• Use EntityBase for your entities
• You can use Repository & ReadOnlyRepository
• Same common method likes Read, Delete, List, Add, Update and etc.
• You can use IUnitOfWork patterns
• Use Transactional actions

Install

Install with Package Manager Console

  Install-Package OnRepository.EFCore

Extend/ Same base class you can use

Using base classes makes it easier for you to implement the pattern

// DbContext
// you must inherit, if you want use IUnitOfWork & Transactional options
public class AppDbContext : ReposDbContext

// Models
// Context Entities must inherit from EntityBase

public class CustomerKind : EntityBase
{
    // your fields
}

public class Customer : EntityBase
{
    // your fields
}

// Repository Interfaces
// You have 2 types of Repository, such as ReadOnlyRepository and 
//Full-Access Repositoy which you can inherit from those.

// IReadOnlyRepository - includes just reading methods 
public interface ICustomerKindRepository : IReadOnlyRepository<CustomerKind>
{
    // you can add custom methods
    // but be careful, just read!
    Task<List<CustomerKind>> GetFromKind(int kindId);
}

// IRepository - You can use CRUD methods
public interface ICustomerRepository : IRepository<Customer>
{
    // you can add custom methods
}

// Repository Classes

// ReadOnlyRepository - includes just reading methods 
 public class CustomerKindRepository : ReadOnlyRepository<CustomerKind>, ICustomerKindRepository
 {
    // you must pass your app db context to repository base
    public CustomerKindRepository(AppDbContext dbContext) : base(dbContext)
    {

    }
    
    // your custom method
    public async Task<List<CustomerKind>?> GetFromKind(int kindId) 
        => await ListAsync(kind => kind.Id >= kindId);
 }

// Repository 
public class CustomerRepository : Repository<Customer>, ICustomerRepository
{
    public CustomerRepository(AppDbContext dbContext) : base(dbContext)
    {

    }
}

DI/ Configuration Part

Add your repositories and IUnitOfWork

builder.Services.AddDbContext<AppDbContext>(options
    => options.UseInMemoryDatabase("AppDbContext"));

builder.Services.AddScoped<ICustomerRepository, CustomerRepository>();
builder.Services.AddScoped<ICustomerKindRepository, CustomerKindRepository>();


// use for UnitOfWork
builder.Services.AddScoped<IUnitOfWork, AppDbContext>();

How To Use - FULL

public class CustomerController : ControllerBase
{
    private readonly ICustomerRepository _customers;
    private readonly ICustomerKindRepository _kinds;

    public CustomerController(ICustomerRepository customerRepository, 
        ICustomerKindRepository customerKindRepository
        )
    {
        _customers = customerRepository;
        _kinds = customerKindRepository;
    }

    // Full Access Repository
    public async Task<IActionResult> GetCustomers()
    {
        var result = await _customers
            .ListAsync(cs => cs.Name.StartsWith("Nabi"));

        return Ok(result);
    }

    public async Task<ActionResult<Customer>> CreateCustomer(string name,string address,int kindId) 
    {
        var newCustomer = await _customers.AddAsync(new Customer
        {
            Name = name,
            Address = address,
            KindId = kindId
        });

        await _customers.UnitOfWork.SaveChangesAsync();

        return Ok(newCustomer);
    }

    public async Task<ActionResult<Customer>> CreateCustomers(string name, string address, int kindId)
    {
            // create your Transaction Scope, you can pass Isolation Level
            using var transactionScope = await _customers.UnitOfWork.BeginTransactionAsync();


            if (transactionScope is null)
                return BadRequest("Can't take a Trasaction Scope.");

            for (int i = 0; i < 10; i++)
            {
                await _customers.AddAsync(new Customer
                {
                    Name = name,
                    Address = address,
                    KindId = kindId
                });
            }

            try
            {
                await _customers.UnitOfWork.SaveChangesAsync();
                await _customers.UnitOfWork.CommitTransactionAsync(transactionScope);
                return Ok("Trasaction was done");
            }
            catch (Exception)
            {
                await _customers.UnitOfWork.RollbackTransactionAsync();
                return BadRequest("Transaction was rollbacked.");
            }
       
    }


    // readOnlyRepository
    public async Task<IActionResult> GetCustomerKinds() 
        => Ok(await _kinds.ListAsync());
 
}