137 lines
3.8 KiB
C#
137 lines
3.8 KiB
C#
using Dapper;
|
|
using Microsoft.Extensions.Logging;
|
|
using Newtonsoft.Json;
|
|
using Npgsql;
|
|
using ProjectCompRepair.Entities;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Diagnostics.Metrics;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace ProjectCompRepair.Repositories.Implemantations;
|
|
|
|
public class MasterRepository : IMasterRepository
|
|
{
|
|
private readonly IConnectionString _connectionString;
|
|
|
|
private readonly ILogger<AccessoriesRepository> _logger;
|
|
|
|
public MasterRepository(IConnectionString connectionString, ILogger<AccessoriesRepository> logger)
|
|
{
|
|
_connectionString = connectionString;
|
|
_logger = logger;
|
|
}
|
|
public void CreateMaster(Master master)
|
|
{
|
|
_logger.LogInformation("Добавление объекта");
|
|
_logger.LogDebug("Объект : {json}", JsonConvert.SerializeObject(master));
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
connection.Open();
|
|
|
|
var queryInsert = @"
|
|
INSERT INTO Master (Name)
|
|
VALUES (@Name)";
|
|
connection.Execute(queryInsert, master);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при добавлении объекта");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
|
|
public void DeleteMaster(int id)
|
|
{
|
|
_logger.LogInformation("Удаление объекта");
|
|
_logger.LogDebug("Объект : {id}", id);
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
connection.Open();
|
|
|
|
var queryDelete = @"
|
|
DELETE FROM Master
|
|
WHERE ID = @id
|
|
"
|
|
;
|
|
connection.Execute(queryDelete, new { id });
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при удалении объекта");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
public IEnumerable<Master> ReadMaster()
|
|
{
|
|
_logger.LogInformation("Получение всех объектов");
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
connection.Open();
|
|
|
|
var querySelect = @"SELECT * FROM Master";
|
|
var master = connection.Query<Master>(querySelect);
|
|
_logger.LogDebug("Полученные объекты : {json}", JsonConvert.SerializeObject(master));
|
|
return master;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при чтении объектов");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
public Master ReadMasterById(int id)
|
|
{
|
|
_logger.LogInformation("Получение объекта по идентификатору");
|
|
_logger.LogDebug("Объект : {id}", id);
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
connection.Open();
|
|
|
|
var querySelect = @"
|
|
SELECT * FROM Master
|
|
WHERE ID = @id
|
|
";
|
|
var master = connection.QueryFirst<Master>(querySelect, new { id });
|
|
_logger.LogDebug("Найденный объект {json}", JsonConvert.SerializeObject(master));
|
|
return master;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при поиске объекта");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
public void UpdateMaster(Master master)
|
|
{
|
|
_logger.LogInformation("Редактирование объекта");
|
|
_logger.LogDebug("Объект : {json}", JsonConvert.SerializeObject(master));
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
connection.Open();
|
|
|
|
var queryUpdate = @"UPDATE Master
|
|
SET
|
|
Name = @Name
|
|
WHERE ID = @Id;";
|
|
connection.Execute(queryUpdate, master);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при редактировании объекта");
|
|
throw;
|
|
}
|
|
}
|
|
}
|