Отдел компьютерных комплектирующих

            List<BO.Buyer> result = new List<BO.Buyer>();

            OdbcCommand cmd = connection.CreateCommand();

            cmd.CommandText = "SELECT Buyer.* FROM Buyer";

            connection.Close();

            connection.Open();

            OdbcDataReader reader = cmd.ExecuteReader();

            while (reader.Read())

            {

                result.Add(new BO.Buyer(Convert.ToString(reader["first_name"]), Convert.ToString(reader["last_name"]), Convert.ToString(reader["email"]), Convert.ToString(reader["address"])));

            }

            return result;

        }

        public void Update(BO.Buyer item)

        {

            throw new NotImplementedException();

        }

        public void Create(BO.Buyer item)

        {

            OdbcCommand cmd = connection.CreateCommand();

            cmd.CommandText = "INSERT INTO Buyer (first_name,last_name,email,address) VALUES ('" + item.first + "','" + item.last + "','" + item.email + "','" + item.address + "')";

            connection.Close();

            connection.Open();

            cmd.ExecuteNonQuery();

        }

        public void Delete(int id)

        {

            throw new NotImplementedException();

        }

    }

}

9.Вихідний код класу HardwareRepository:

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Collections.Specialized;

using System.Data.Odbc;

using DAL.Factories;

using BO;

namespace DAL.Repositories

{

    public class HardwareRepository : IRepository<BO.Hardware>

    {

        OdbcConnection connection;

        public HardwareRepository(OdbcConnection con)

        {

            connection = con;

        }

        public List<BO.Hardware> GetAll() //повертаемо список обладнання

        {

            List<BO.Hardware> result = new List<BO.Hardware>();

            OdbcCommand cmd = this.connection.CreateCommand();

            cmd.CommandText = "SELECT Hardware.* FROM Hardware";

            connection.Close();

            connection.Open();

            OdbcDataReader reader = cmd.ExecuteReader();

            while (reader.Read())

            {

                int id = Convert.ToInt32(reader["ID"]);

                string title = Convert.ToString(reader["title"]);

                string description = Convert.ToString(reader["description"]);

                string cost = Convert.ToString(reader["cost"]);

                string manufacturer = Convert.ToString(reader["manufacturer"]);

                string type = Convert.ToString(reader["type"]);

                result.Add(new BO.Hardware(id, title, description, cost, manufacturer, type));

            }

            return result;

        }

        public void Update(BO.Hardware item)

        {

            OdbcCommand cmd = connection.CreateCommand();

            cmd.CommandText = "UPDATE Hardware SET title='" + item.title + "',description='" + item.description + "',cost='" + item.cost + "',manufacturer='" + item.manufacturer + "' WHERE id=" + item.id;

            connection.Close();

            connection.Open();

            cmd.ExecuteNonQuery();

        }

        public void Create(BO.Hardware item)

        {

            OdbcCommand cmd = connection.CreateCommand();

            connection.Close();

            connection.Open();

            string fields = "";

            string values = "'";

            foreach (string spec in item.specifications.Keys)

            {

                cmd.CommandText = "SELECT specification FROM SpecificationType WHERE title='" + spec + "';";

                fields += Convert.ToString(cmd.ExecuteScalar()) + ",";

                values += item.specifications[spec] + "','";

            }

            fields = fields.Substring(0, fields.Length - 1);

            values = values.Substring(0, values.Length - 2);

            cmd.CommandText = "INSERT INTO Specification (" + fields + ") VALUES (" + values + ");";

            cmd.ExecuteNonQuery();

            cmd.CommandText = "SELECT ID FROM Specification ORDER BY ID DESC;";

            string specID = Convert.ToString(cmd.ExecuteScalar());

            cmd.CommandText = "INSERT INTO Hardware(title, description, cost, manufacturer, specs, type) VALUES ('" +

                item.title + "','" + item.description + "','" + item.cost + "','" + item.manufacturer + "','" + specID + "','" + item.type + "')";

            System.Console.WriteLine(cmd.CommandText);

            cmd.ExecuteNonQuery();

        }

        public void Delete(int id)

        {

            OdbcCommand cmd = connection.CreateCommand();

            cmd.CommandText = "DELETE * FROM Hardware WHERE Hardware.ID=" + id + ";";

            connection.Close();

            connection.Open();

            cmd.ExecuteNonQuery();

        }

    }

}