63 lines
2.6 KiB
C#

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace WebsiteForPlacingAds
{
public class PostgreSqlDatabase : AbstractDatabase
{
public PostgreSqlDatabase(string connectionString) : base(connectionString)
{
}
public void addAd(string heading, int price, string date, string status, int id_client, int id_category, int id_subcategory)
{
string query = String.Format("INSERT INTO ads VALUES (nextval('seq_ads'), '{0}', {1}, '{2}', '{3}', {4}, {5}, {6})", heading, price, date, status, id_client, id_category, id_subcategory);
ExecuteNonQuery(query);
}
public void addClient(string name, string surname, string patronymic, string email, string phone_number, string registration_date, int client_rating)
{
string query = String.Format($"INSERT INTO clients VALUES (nextval('seq_clients'), {name}', '{surname}', '{patronymic}', '{email}', '{phone_number}', '{registration_date}', '{client_rating}')");
ExecuteNonQuery(query);
}
public void addClientsRating(int number_of_reviews, int number_of_sales, int number_of_subscribers, float average_rating)
{
string query = String.Format($"INSERT INTO clients_rating VALUES (nextval('seq_user_rating'), {number_of_reviews}', '{number_of_sales}', '{number_of_subscribers}', '{average_rating}')");
ExecuteNonQuery(query);
}
public void addSubcategory(string name)
{
string query = String.Format($"INSERT INTO subcategories VALUES (nextval('seq_subcategory'), {name}')");
ExecuteNonQuery(query);
}
public void addCategory(string name)
{
string query = String.Format($"INSERT INTO categories VALUES (nextval('seq_category'), {name}')");
ExecuteNonQuery(query);
}
public DataTable getAllCategories()
{
string query = "SELECT category_id, name FROM categories";
return ExecuteQuery(query);
}
public DataTable getAllSubcategories()
{
string query = "SELECT subcategory_id, name FROM subcategories";
return ExecuteQuery(query);
}
public DataTable getAllClients()
{
string query = "SELECT client_id, name, surname FROM clients";
return ExecuteQuery(query);
}
public DataTable getClient(int id_client)
{
string query = $"SELECT * FROM clients where id = {id_client}";
return ExecuteQuery(query);
}
}
}