Compare commits

..

2 Commits

Author SHA1 Message Date
Nikolai Papin
e45c143afc UserPolis repo 2024-09-07 12:42:31 +03:00
Nikolai Papin
d75f179ad4 Car, Polis & User repos + moved to dedicated folders 2024-09-07 12:34:55 +03:00
8 changed files with 124 additions and 0 deletions

View File

@ -0,0 +1,48 @@
using Microsoft.EntityFrameworkCore;
using Renis.Database;
using Renis.Database.Models;
namespace Renis.Repositories;
public class CarRepository(ApplicationContext db) : ICarRepository
{
private readonly ApplicationContext _db = db;
public async Task<bool> AddCar(Car car)
{
_db.Cars.Add(car);
return await Save();
}
public async Task<bool> DeleteCar(Car car)
{
_db.Cars.Remove(car);
return await Save();
}
public async Task<Car?> GetCarById(long id)
{
return await _db.Cars.FirstOrDefaultAsync(x => x.Id == id);
}
public async Task<Car?> GetCarByNumber(string number)
{
return await _db.Cars.FirstOrDefaultAsync(x => x.Number == number);
}
public IQueryable<Car> GetCars()
{
return _db.Cars.AsQueryable();
}
public async Task<bool> Save()
{
return await _db.SaveChangesAsync() > 0;
}
public async Task<bool> UpdateCar(Car car)
{
_db.Cars.Update(car);
return await Save();
}
}

View File

@ -0,0 +1,14 @@
using Renis.Database.Models;
namespace Renis.Repositories;
public interface ICarRepository
{
public Task<bool> AddCar(Car car);
public Task<bool> UpdateCar(Car car);
public Task<bool> DeleteCar(Car car);
public Task<Car?> GetCarById(long id);
public Task<Car?> GetCarByNumber(string number);
public IQueryable<Car> GetCars();
public Task<bool> Save();
}

View File

@ -0,0 +1,14 @@
using Renis.Database.Models;
namespace Renis.Repositories;
public interface IUserPolisRepository
{
public Task<bool> AddUserPolis(UserPolis userPolis);
public Task<bool> UpdateUserPolis(UserPolis userPolis);
public Task<bool> DeleteUserPolis(UserPolis userPolis);
public Task<UserPolis?> GetUserPolisById(long id);
public Task<UserPolis?> GetUserPolisByUserIdAndPolisId(long userId, long polisId);
public IQueryable<UserPolis> GetUserPolises();
public Task<bool> Save();
}

View File

@ -0,0 +1,48 @@
using Microsoft.EntityFrameworkCore;
using Renis.Database;
using Renis.Database.Models;
namespace Renis.Repositories;
public class UserPolisRepository(ApplicationContext db) : IUserPolisRepository
{
private readonly ApplicationContext _db = db;
public async Task<bool> AddUserPolis(UserPolis userPolis)
{
_db.UserPolises.Add(userPolis);
return await Save();
}
public async Task<bool> UpdateUserPolis(UserPolis userPolis)
{
_db.UserPolises.Update(userPolis);
return await Save();
}
public async Task<bool> DeleteUserPolis(UserPolis userPolis)
{
_db.UserPolises.Remove(userPolis);
return await Save();
}
public async Task<UserPolis?> GetUserPolisById(long id)
{
return await _db.UserPolises.FirstOrDefaultAsync(x => x.Id == id);
}
public async Task<UserPolis?> GetUserPolisByUserIdAndPolisId(long userId, long polisId)
{
return await _db.UserPolises.FirstOrDefaultAsync(x => x.UserId == userId && x.PolisId == polisId);
}
public IQueryable<UserPolis> GetUserPolises()
{
return _db.UserPolises.AsQueryable();
}
public async Task<bool> Save()
{
return await _db.SaveChangesAsync() > 0;
}
}