RepositoryModel implemented

This commit is contained in:
2019-12-19 20:30:04 +01:00
parent 5e4da3d966
commit fc11be2baf
25 changed files with 397 additions and 16 deletions

View File

@ -0,0 +1,57 @@
using H_Plus_Sports.Contracts;
using H_Plus_Sports.Models;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace H_Plus_Sports.Repositories
{
public class CustomerRepository : ICustomerRepository
{
private H_Plus_SportsContext _context;
public CustomerRepository(H_Plus_SportsContext context )
{
_context = context;
}
public async Task<Customer> Add(Customer customer)
{
await _context.Customer.AddAsync(customer);
await _context.SaveChangesAsync();
return customer;
}
public async Task<bool> Exist(int id)
{
return await _context.Customer.AnyAsync(x => x.CustomerId == id);
}
public async Task<Customer> Find(int id)
{
return await _context.Customer.Include(customer => customer.Order).SingleOrDefaultAsync(a => a.CustomerId == id);
}
public IEnumerable<Customer> GetAll()
{
return _context.Customer;
}
public async Task<Customer> Remove(int id)
{
var customer = await _context.Customer.SingleAsync(a => a.CustomerId == id);
_context.Customer.Remove(customer);
await _context.SaveChangesAsync();
return customer;
}
public async Task<Customer> Update(Customer customer)
{
_context.Customer.Update(customer);
await _context.SaveChangesAsync();
return customer;
}
}
}

View File

@ -0,0 +1,55 @@
using H_Plus_Sports.Contracts;
using H_Plus_Sports.Models;
using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace H_Plus_Sports.Repositories
{
public class OrderItemRepository : IOrderItemRepository
{
private H_Plus_SportsContext _context;
public OrderItemRepository(H_Plus_SportsContext context)
{
_context = context;
}
public IEnumerable<OrderItem> GetAll()
{
return _context.OrderItem;
}
public async Task<OrderItem> Add(OrderItem orderItem)
{
await _context.OrderItem.AddAsync(orderItem);
await _context.SaveChangesAsync();
return orderItem;
}
public async Task<OrderItem> Find(int id)
{
return await _context.OrderItem.Include(orderItem => orderItem.Order).Include(orderItem => orderItem.Product).SingleOrDefaultAsync(a => a.OrderItemId == id);
}
public async Task<OrderItem> Remove(int id)
{
var orderItem = await _context.OrderItem.SingleAsync(a => a.OrderItemId == id);
_context.OrderItem.Remove(orderItem);
await _context.SaveChangesAsync();
return orderItem;
}
public async Task<OrderItem> Update(OrderItem orderItem)
{
_context.OrderItem.Update(orderItem);
await _context.SaveChangesAsync();
return orderItem;
}
public async Task<bool> Exists(int id)
{
return await _context.OrderItem.AnyAsync(e => e.OrderItemId == id);
}
}
}

View File

@ -0,0 +1,56 @@
using H_Plus_Sports.Contracts;
using H_Plus_Sports.Models;
using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace H_Plus_Sports.Repositories
{
public class OrderRepository : IOrderRepository
{
private H_Plus_SportsContext _context;
public OrderRepository(H_Plus_SportsContext context)
{
_context = context;
}
public IEnumerable<Order> GetAll()
{
return _context.Order;
}
public async Task<Order> Add(Order order)
{
await _context.Order.AddAsync(order);
await _context.SaveChangesAsync();
return order;
}
public async Task<Order> Find(int id)
{
return await _context.Order.Include(order => order.OrderItem).Include(order => order.Customer).SingleOrDefaultAsync(a => a.OrderId == id);
}
public async Task<Order> Remove(int id)
{
var order = _context.Order.Single(a => a.OrderId == id);
_context.Order.Remove(order);
await _context.SaveChangesAsync();
return order;
}
public async Task<Order> Update(Order order)
{
_context.Order.Update(order);
await _context.SaveChangesAsync();
return order;
}
public async Task<bool> Exists(int id)
{
return await _context.Order.AnyAsync(e => e.OrderId == id);
}
}
}

View File

@ -0,0 +1,55 @@
using H_Plus_Sports.Contracts;
using H_Plus_Sports.Models;
using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace H_Plus_Sports.Repositories
{
public class ProductRepository : IProductRepository
{
private H_Plus_SportsContext _context;
public ProductRepository(H_Plus_SportsContext context)
{
_context = context;
}
public IEnumerable<Product> GetAll()
{
return _context.Product;
}
public async Task<Product> Add(Product product)
{
await _context.Product.AddAsync(product);
await _context.SaveChangesAsync();
return product;
}
public async Task<Product> Find(string id)
{
return await _context.Product.Include(product => product.OrderItem).SingleOrDefaultAsync(a => a.ProductId == id);
}
public async Task<Product> Remove(string id)
{
var product = await _context.Product.SingleAsync(a => a.ProductId == id);
_context.Product.Remove(product);
await _context.SaveChangesAsync();
return product;
}
public async Task<Product> Update(Product product)
{
_context.Product.Update(product);
await _context.SaveChangesAsync();
return product;
}
public async Task<bool> Exists(string id)
{
return await _context.Product.AnyAsync(e => e.ProductId == id);
}
}
}

View File

@ -0,0 +1,55 @@
using H_Plus_Sports.Contracts;
using H_Plus_Sports.Models;
using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace H_Plus_Sports.Repositories
{
public class SalespersonRepository : ISalespersonRepository
{
private H_Plus_SportsContext _context;
public SalespersonRepository(H_Plus_SportsContext context)
{
_context = context;
}
public IEnumerable<Salesperson> GetAll()
{
return _context.Salesperson;
}
public async Task<Salesperson> Add(Salesperson salesperson)
{
await _context.Salesperson.AddAsync(salesperson);
await _context.SaveChangesAsync();
return salesperson;
}
public async Task<Salesperson> Find(int id)
{
return await _context.Salesperson.Include(salesperson => salesperson.Order).SingleOrDefaultAsync(a => a.SalespersonId == id);
}
public async Task<Salesperson> Remove(int id)
{
var salesperson = await _context.Salesperson.SingleAsync(a => a.SalespersonId == id);
_context.Salesperson.Remove(salesperson);
await _context.SaveChangesAsync();
return salesperson;
}
public async Task<Salesperson> Update(Salesperson salesperson)
{
_context.Salesperson.Update(salesperson);
await _context.SaveChangesAsync();
return salesperson;
}
public async Task<bool> Exists(int id)
{
return await _context.Order.AnyAsync(e => e.OrderId == id);
}
}
}