124 lines
4.4 KiB
C#
124 lines
4.4 KiB
C#
using Dapper;
|
|
using Microsoft.Extensions.Logging;
|
|
using Newtonsoft.Json;
|
|
using Npgsql;
|
|
using ProjectTimeTable.Entites;
|
|
using ProjectTimeTable.Entites.Enums;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace ProjectTimeTable.Repositories.Implementation;
|
|
|
|
public class TeacherRepositories : ITeacherRepositories
|
|
{
|
|
private readonly IConnectionString _connectionString;
|
|
private readonly ILogger<TeacherRepositories> _logger;
|
|
public TeacherRepositories(IConnectionString connectionString, ILogger<TeacherRepositories> logger)
|
|
{
|
|
_connectionString = connectionString;
|
|
_logger = logger;
|
|
}
|
|
public void CreateTeacher(Teacher teacher)
|
|
{
|
|
_logger.LogInformation("Добавление объекта");
|
|
_logger.LogDebug("Объект: {json}", JsonConvert.SerializeObject(teacher));
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
var queryInsert = @"INSERT INTO teacher (FirstName, SecondName, LastName, TeacherPost)
|
|
VALUES (@FirstName, @SecondName, @LastName, @TeacherPost)";
|
|
connection.Execute(queryInsert, teacher);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при редактировании объекта");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
public void DeleteTeacher(int id)
|
|
{
|
|
_logger.LogInformation("Удаление объекта");
|
|
_logger.LogDebug("Объект: {id}", id);
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
var queryDelete = @"DELETE FROM teacher WHERE Id=@id";
|
|
connection.Execute(queryDelete, new { id });
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при удалении объекта");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
public IEnumerable<Teacher> ReadTeacher()
|
|
{
|
|
_logger.LogInformation("Получение всех объектов");
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
var querySelect = "SELECT * FROM teacher";
|
|
var teacher = connection.Query<Teacher>(querySelect);
|
|
_logger.LogDebug("Полученные объекты: {json}",
|
|
JsonConvert.SerializeObject(teacher));
|
|
return teacher;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при чтении объектов");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
public Teacher ReadTeacherById(int id)
|
|
{
|
|
_logger.LogInformation("Получение объекта по идентификатору");
|
|
_logger.LogDebug("Объект: {id}", id);
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
var querySelect = @"SELECT * FROM teacher WHERE Id=@id";
|
|
var teacher = connection.QueryFirst<Teacher>(querySelect, new
|
|
{
|
|
id
|
|
});
|
|
_logger.LogDebug("Найденный объект: {json}",
|
|
JsonConvert.SerializeObject(teacher));
|
|
return teacher;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при поиске объекта");
|
|
throw;
|
|
}
|
|
}
|
|
|
|
public void UpdateTeacher(Teacher teacher)
|
|
{
|
|
_logger.LogInformation("Редактирование объекта");
|
|
_logger.LogDebug("Объект: {json}",
|
|
JsonConvert.SerializeObject(teacher));
|
|
try
|
|
{
|
|
using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
|
|
var queryUpdate = @"UPDATE Teacher SET
|
|
FirstName=@FirstName,
|
|
SecondName=@SecondName,
|
|
LastName=@LastName,
|
|
TeacherPost=@TeacherPost
|
|
WHERE Id=@id";
|
|
connection.Execute(queryUpdate, teacher);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "Ошибка при редактировании объекта");
|
|
|
|
}
|
|
}
|
|
}
|