90 lines
3.4 KiB
C#
90 lines
3.4 KiB
C#
using BeautySalonDBModels.Models;
|
|
using Npgsql;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace BeautySalonDBModels.Implements
|
|
{
|
|
public class ServiceDatabase : AbstractWorkWithStorage<Service>
|
|
{
|
|
public override void Add(Service service)
|
|
{
|
|
using var conn = GetConnection();
|
|
conn.Open();
|
|
using var cmd = new NpgsqlCommand("INSERT INTO services (service_id, service_name, price, specialisation_id) " +
|
|
"VALUES ((nextval('seq_service')), @ServiceName, @Price, @SpecialisationId)", conn);
|
|
cmd.Parameters.AddWithValue("@ServiceName", service.ServiceName);
|
|
cmd.Parameters.AddWithValue("@Price", service.Price);
|
|
cmd.Parameters.AddWithValue("@SpecialisationId", service.SpecialisationId);
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
public override Service? GetObject(int id)
|
|
{
|
|
using var conn = GetConnection();
|
|
conn.Open();
|
|
using var cmd = new NpgsqlCommand("SELECT * FROM services WHERE service_id = @id", conn);
|
|
cmd.Parameters.AddWithValue("@id", id);
|
|
using var reader = cmd.ExecuteReader();
|
|
if (reader.Read())
|
|
{
|
|
return new Service
|
|
{
|
|
ServiceId = reader.GetInt32(0),
|
|
ServiceName = reader.GetString(1),
|
|
Price = reader.GetDouble(2),
|
|
SpecialisationId = reader.GetInt32(3)
|
|
};
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public override List<Service> GetObjects()
|
|
{
|
|
var services = new List<Service>();
|
|
using var conn = GetConnection();
|
|
conn.Open();
|
|
using var cmd = new NpgsqlCommand("SELECT * FROM services order by service_id", conn);
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
services.Add(new Service
|
|
{
|
|
ServiceId = reader.GetInt32(0),
|
|
ServiceName = reader.GetString(1),
|
|
Price = reader.GetDouble(2),
|
|
SpecialisationId = reader.GetInt32(3)
|
|
});
|
|
}
|
|
return services;
|
|
}
|
|
|
|
public override Service? Remove(int id)
|
|
{
|
|
var service = GetObject(id);
|
|
using var conn = GetConnection();
|
|
conn.Open();
|
|
using var cmd = new NpgsqlCommand("delete from services where service_id = @id", conn);
|
|
cmd.Parameters.AddWithValue("@id", id);
|
|
cmd.ExecuteNonQuery();
|
|
return service;
|
|
}
|
|
|
|
public override void Update(Service service)
|
|
{
|
|
using var conn = GetConnection();
|
|
conn.Open();
|
|
using var cmd = new NpgsqlCommand("update service set service_name = @name, " +
|
|
"price = @price, specialisation_id = @SpecialisationId where service_id = @id", conn);
|
|
cmd.Parameters.AddWithValue("@name", service.ServiceName);
|
|
cmd.Parameters.AddWithValue("@price", service.Price);
|
|
cmd.Parameters.AddWithValue("@SpecialisationId", service.SpecialisationId);
|
|
cmd.Parameters.AddWithValue("@id", service.ServiceId);
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
}
|