diff --git a/ShoeStore/ShoeStore/Repositories/IConnectionString.cs b/ShoeStore/ShoeStore/Repositories/IConnectionString.cs index fb8dabe..6bc84fb 100644 --- a/ShoeStore/ShoeStore/Repositories/IConnectionString.cs +++ b/ShoeStore/ShoeStore/Repositories/IConnectionString.cs @@ -6,7 +6,7 @@ using System.Threading.Tasks; namespace ShoeStore.Repositories; -internal interface IConnectionString +public interface IConnectionString { - string ConnectionString { get; } + public string ConnectionString { get; } } diff --git a/ShoeStore/ShoeStore/Repositories/Implementations/ConnectionString.cs b/ShoeStore/ShoeStore/Repositories/Implementations/ConnectionString.cs index 2243db0..e332974 100644 --- a/ShoeStore/ShoeStore/Repositories/Implementations/ConnectionString.cs +++ b/ShoeStore/ShoeStore/Repositories/Implementations/ConnectionString.cs @@ -8,6 +8,6 @@ namespace ShoeStore.Repositories.Implementations; internal class ConnectionString : IConnectionString { - string IConnectionString.ConnectionString => ""; + string IConnectionString.ConnectionString => "Server=localhost;Port=5432;Database=BDOTP;User Id=postgres;Password=postgres;"; } diff --git a/ShoeStore/ShoeStore/Repositories/Implementations/FactoryRepository.cs b/ShoeStore/ShoeStore/Repositories/Implementations/FactoryRepository.cs index cd83fa4..45b3022 100644 --- a/ShoeStore/ShoeStore/Repositories/Implementations/FactoryRepository.cs +++ b/ShoeStore/ShoeStore/Repositories/Implementations/FactoryRepository.cs @@ -1,6 +1,7 @@ using Dapper; using Microsoft.Extensions.Logging; using Newtonsoft.Json; +using Npgsql; using ShoeStore.Entities; using ShoeStore.Entities.Enums; using System; @@ -32,7 +33,7 @@ internal class FactoryRepository : IFactoryRepository try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryInsert = @" INSERT INTO Factorys (FactoryName, Manufacturer) VALUES (@FactoryName, @Manufacturer)"; @@ -52,7 +53,7 @@ VALUES (@FactoryName, @Manufacturer)"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryUpdate = @" UPDATE Factorys SET @@ -75,7 +76,7 @@ WHERE [Id]=@Id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryDelete = @" DELETE FROM Factorys WHERE Id=@id"; @@ -95,7 +96,7 @@ WHERE Id=@id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var querySelect = @" SELECT * FROM Factorys WHERE Id=@id"; diff --git a/ShoeStore/ShoeStore/Repositories/Implementations/ShoesReplenishmentRepository.cs b/ShoeStore/ShoeStore/Repositories/Implementations/ShoesReplenishmentRepository.cs index 992c664..6582d96 100644 --- a/ShoeStore/ShoeStore/Repositories/Implementations/ShoesReplenishmentRepository.cs +++ b/ShoeStore/ShoeStore/Repositories/Implementations/ShoesReplenishmentRepository.cs @@ -1,6 +1,7 @@ using Dapper; using Microsoft.Extensions.Logging; using Newtonsoft.Json; +using Npgsql; using ShoeStore.Entities; using ShoeStore.Entities.Enums; using System; @@ -30,7 +31,7 @@ internal class ShoesReplenishmentRepository : IShoesReplenishmentRepository try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); connection.Open(); using var transaction = connection.BeginTransaction(); var queryInsert = @" @@ -66,7 +67,7 @@ VALUES (@ShoesReplenishmentId,@ShoesId, @Count)"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryDelete = @" DELETE FROM ShoesReplenishments WHERE Id=@id"; @@ -86,7 +87,7 @@ WHERE Id=@id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var querySelect = @"SELECT * FROM ShoesReplenishments"; var shoesReplenishments = connection.Query(querySelect); diff --git a/ShoeStore/ShoeStore/Repositories/Implementations/ShoesRepository.cs b/ShoeStore/ShoeStore/Repositories/Implementations/ShoesRepository.cs index 40fe3f2..4d3f7bd 100644 --- a/ShoeStore/ShoeStore/Repositories/Implementations/ShoesRepository.cs +++ b/ShoeStore/ShoeStore/Repositories/Implementations/ShoesRepository.cs @@ -2,6 +2,7 @@ using Microsoft.Extensions.Logging; using Microsoft.VisualBasic.FileIO; using Newtonsoft.Json; +using Npgsql; using ShoeStore.Entities; using ShoeStore.Entities.Enums; using System; @@ -31,7 +32,7 @@ internal class ShoesRepository : IShoesRepository try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryInsert = @" INSERT INTO Shoess (ShoesType, Name, Description) VALUES (@ShoesType, @Name, @Description)"; @@ -51,7 +52,7 @@ VALUES (@ShoesType, @Name, @Description)"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryUpdate = @" UPDATE Shoess SET @@ -74,7 +75,7 @@ WHERE Id=@Id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryDelete = @" DELETE FROM Shoess WHERE Id=@id"; @@ -93,7 +94,7 @@ WHERE Id=@id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var querySelect = @" SELECT * FROM Shoess WHERE Id=@id"; @@ -117,7 +118,7 @@ WHERE Id=@id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var querySelect = "SELECT * FROM Shoess"; var shoess = connection.Query(querySelect); _logger.LogDebug("Полученные объекты: {json}", diff --git a/ShoeStore/ShoeStore/Repositories/Implementations/ShoesSaleRepository.cs b/ShoeStore/ShoeStore/Repositories/Implementations/ShoesSaleRepository.cs index 346b015..60a8c6f 100644 --- a/ShoeStore/ShoeStore/Repositories/Implementations/ShoesSaleRepository.cs +++ b/ShoeStore/ShoeStore/Repositories/Implementations/ShoesSaleRepository.cs @@ -1,6 +1,7 @@ using Dapper; using Microsoft.Extensions.Logging; using Newtonsoft.Json; +using Npgsql; using ShoeStore.Entities; using System; using System.Collections.Generic; @@ -29,7 +30,7 @@ internal class ShoesSaleRepository : IShoesSaleRepository try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryInsert = @" INSERT INTO ShoesSales (ShoesId, FactoryId, StoreId, SaleDate, Specificity) VALUES (@ShoesId, @FactoryId, @StoreId, @SaleDate, @Specificity)"; @@ -49,7 +50,7 @@ VALUES (@ShoesId, @FactoryId, @StoreId, @SaleDate, @Specificity)"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var querySelect = "SELECT * FROM ShoesSales"; var shoesSales = connection.Query(querySelect); diff --git a/ShoeStore/ShoeStore/Repositories/Implementations/StoreRepository.cs b/ShoeStore/ShoeStore/Repositories/Implementations/StoreRepository.cs index 2733b34..03c2290 100644 --- a/ShoeStore/ShoeStore/Repositories/Implementations/StoreRepository.cs +++ b/ShoeStore/ShoeStore/Repositories/Implementations/StoreRepository.cs @@ -1,6 +1,7 @@ using Dapper; using Microsoft.Extensions.Logging; using Newtonsoft.Json; +using Npgsql; using ShoeStore.Entities; using ShoeStore.Entities.Enums; using System; @@ -30,7 +31,7 @@ internal class StoreRepository : IStoreRepository try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryInsert = @" INSERT INTO Stores (StoreType, StoreName, Employees, Visitors) VALUES (@StoreType, @StoreName, @Employees, @Visitors)"; @@ -49,7 +50,7 @@ VALUES (@StoreType, @StoreName, @Employees, @Visitors)"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryUpdate = @" UPDATE Store SET @@ -74,7 +75,7 @@ WHERE Id=@Id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var queryDelete = @" DELETE FROM Store WHERE Id=@id"; @@ -94,7 +95,7 @@ WHERE Id=@id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var querySelect = @" SELECT * FROM Store WHERE [Id]=@id"; @@ -118,7 +119,7 @@ WHERE [Id]=@id"; try { using var connection = new - SqlConnection(_connectionString.ConnectionString); + NpgsqlConnection(_connectionString.ConnectionString); var querySelect = "SELECT * FROM Stores"; var stores = connection.Query(querySelect); _logger.LogDebug("Полученные объекты: {json}", JsonConvert.SerializeObject(stores)); diff --git a/ShoeStore/ShoeStore/ShoeStore.csproj b/ShoeStore/ShoeStore/ShoeStore.csproj index a2dd8b6..14f791f 100644 --- a/ShoeStore/ShoeStore/ShoeStore.csproj +++ b/ShoeStore/ShoeStore/ShoeStore.csproj @@ -14,6 +14,7 @@ +