51 lines
1.3 KiB
C#
51 lines
1.3 KiB
C#
|
using NG_2023_Kanban.DataLayer.DbStartup;
|
|||
|
|
using NG_2023_Kanban.DataLayer.Entities;
|
|||
|
|
using NG_2023_Kanban.DataLayer.Interfaces;
|
|||
|
|
using Microsoft.EntityFrameworkCore;
|
|||
|
|
|
|||
|
|
namespace NG_2023_Kanban.DataLayer.Repositories;
|
|||
|
|
|
|||
|
|
public class BaseRepository<T> : IRepository<T> where T : BaseEntity
|
|||
|
|
{
|
|||
|
|
private DatabaseContext _context;
|
|||
|
|
|
|||
|
|
public BaseRepository(DatabaseContext context)
|
|||
|
|
=> _context = context;
|
|||
|
|
|
|||
|
|
public async Task<ICollection<T>> GetAllAsync()
|
|||
|
|
=> await _context.Set<T>().Select(x => x).ToListAsync();
|
|||
|
|
|
|||
|
|
public async Task<T> GetAsync(int id)
|
|||
|
|
=> await _context.Set<T>().FirstAsync(x => x.Id == id);
|
|||
|
|
|
|||
|
|
public async Task<ICollection<T>> FindAsync(Func<T, bool> predicate)
|
|||
|
|
{
|
|||
|
|
var entities = await GetAllAsync();
|
|||
|
|
return entities.Where(predicate).ToList();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task CreateAsync(T entity)
|
|||
|
|
{
|
|||
|
|
await _context.Set<T>().AddAsync(entity);
|
|||
|
|
await _context.SaveChangesAsync();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task UpdateAsync(T entity)
|
|||
|
|
{
|
|||
|
|
_context.Set<T>().Update(entity);
|
|||
|
|
await _context.SaveChangesAsync();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task DeleteAsync(int id)
|
|||
|
|
{
|
|||
|
|
var entity = await GetAsync(id);
|
|||
|
|
await DeleteAsync(entity);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task DeleteAsync(T entity)
|
|||
|
|
{
|
|||
|
|
_context.Set<T>().Remove(entity);
|
|||
|
|
await _context.SaveChangesAsync();
|
|||
|
|
}
|
|||
|
|
}
|