96 lines
2.9 KiB
C#
96 lines
2.9 KiB
C#
using Microsoft.eShopWeb.ApplicationCore.Interfaces;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.eShopWeb.ApplicationCore.Entities;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Microsoft.eShopWeb.Infrastructure.Data
|
|
{
|
|
/// <summary>
|
|
/// "There's some repetition here - couldn't we have some the sync methods call the async?"
|
|
/// https://blogs.msdn.microsoft.com/pfxteam/2012/04/13/should-i-expose-synchronous-wrappers-for-asynchronous-methods/
|
|
/// </summary>
|
|
/// <typeparam name="T"></typeparam>
|
|
public class EfRepository<T> : IRepository<T>, IAsyncRepository<T> where T : BaseEntity
|
|
{
|
|
protected readonly CatalogContext _dbContext;
|
|
|
|
public EfRepository(CatalogContext dbContext)
|
|
{
|
|
_dbContext = dbContext;
|
|
}
|
|
|
|
public T GetSingleBySpec(ISpecification<T> spec)
|
|
{
|
|
return List(spec).FirstOrDefault();
|
|
}
|
|
|
|
public virtual async Task<T> GetByIdAsync(int id)
|
|
{
|
|
return await _dbContext.Set<T>().FindAsync(id);
|
|
}
|
|
|
|
public async Task<IReadOnlyList<T>> ListAllAsync()
|
|
{
|
|
return await _dbContext.Set<T>().ToListAsync();
|
|
}
|
|
|
|
public IEnumerable<T> List(ISpecification<T> spec)
|
|
{
|
|
return ApplySpecification(spec).AsEnumerable();
|
|
}
|
|
public async Task<IReadOnlyList<T>> ListAsync(ISpecification<T> spec)
|
|
{
|
|
return await ApplySpecification(spec).ToListAsync();
|
|
}
|
|
|
|
public int Count(ISpecification<T> spec)
|
|
{
|
|
return ApplySpecification(spec).Count();
|
|
}
|
|
|
|
public async Task<int> CountAsync(ISpecification<T> spec)
|
|
{
|
|
return await ApplySpecification(spec).CountAsync();
|
|
}
|
|
|
|
public async Task<T> AddAsync(T entity)
|
|
{
|
|
_dbContext.Set<T>().Add(entity);
|
|
await _dbContext.SaveChangesAsync();
|
|
|
|
return entity;
|
|
}
|
|
|
|
public void Update(T entity)
|
|
{
|
|
_dbContext.Entry(entity).State = EntityState.Modified;
|
|
_dbContext.SaveChanges();
|
|
}
|
|
|
|
public async Task UpdateAsync(T entity)
|
|
{
|
|
_dbContext.Entry(entity).State = EntityState.Modified;
|
|
await _dbContext.SaveChangesAsync();
|
|
}
|
|
|
|
public void Delete(T entity)
|
|
{
|
|
_dbContext.Set<T>().Remove(entity);
|
|
_dbContext.SaveChanges();
|
|
}
|
|
|
|
public async Task DeleteAsync(T entity)
|
|
{
|
|
_dbContext.Set<T>().Remove(entity);
|
|
await _dbContext.SaveChangesAsync();
|
|
}
|
|
|
|
private IQueryable<T> ApplySpecification(ISpecification<T> spec)
|
|
{
|
|
return SpecificationEvaluator<T>.GetQuery(_dbContext.Set<T>().AsQueryable(), spec);
|
|
}
|
|
}
|
|
}
|