using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using MySql.Data.MySqlClient;

namespace ConsoleApplication3
{
    class DBConnect
    {
        // Variabler för koppling till databas
        private MySqlConnection connection;
        private string server;
        private string database;
        private string User;
        private string password;

        // Konstuktor
        public DBConnect()
        {
            Initialize();
        }

        // Initiera kontakt till DB
        private void Initialize()
        {
            server = "localhost";
            database = "hem_invent";
            User = "root";
            password = "Trinity06!";
            string connectionString;
            connectionString = "SERVER=" + server + ";" + "DATABASE=" +
            database + ";" + "UID=" + User + ";" + "PASSWORD=" + password + ";";

            connection = new MySqlConnection(connectionString);
        }

        // Metod för att öppna en kontakt till DB
        private bool OpenConnection()
        {
            try
            {
                connection.Open();
                return true;
            }
            catch (MySqlException ex)
            {

                switch (ex.Number) //case finns inbyggda i mysql
                {
                    case 0:
                        Console.WriteLine("Cannot connect to server.  Contact administrator");
                        break;

                    case 1045:
                        Console.WriteLine("Invalid username/password, please try again");
                        break;
                }
                return false;
            }
        }

        // Metod för att stänga kontakt till DB
        private bool CloseConnection()
        {
            {
                try
                {
                    connection.Close();
                    return true;
                }
                catch (MySqlException ex) // exceptions finns innbygda i mysql
                {
                    Console.WriteLine(ex.Message);
                    return false;
                }
            }
        }

        //Insert Kommando
        public void Insert(int Ean, string Namn, int Bästföre)
        {
            string query = ("INSERT INTO Lager (Ean, Namn, Bästföre) VALUES (" + Ean + ",'" + Namn + "'," + Bästföre +")");



            //Öppna Kontakt till DB
            if (this.OpenConnection() == true)
            {
                //Skapa ett kommando med en kö och en kontakt
                MySqlCommand cmd = new MySqlCommand(query, connection);

                //utför kommandot
                cmd.ExecuteNonQuery();

                //Stäng kontakten
                this.CloseConnection();
            }
        }

        //Updatera kommando
        public void Update(int Ean, string Namn, int Bästföre)
        {
            string query = "UPDATE Lager SET Ean=" +Ean+ "," + "Namn= '" +Namn+ "'," + "Bästföre=" +Bästföre+ " WHERE Ean=" + Ean ;

            //Öppna Kontakt till DB
            if (this.OpenConnection() == true)
            {
                //SKapa nytt kommando
                MySqlCommand cmd = new MySqlCommand();

                cmd.CommandText = query;

                cmd.Connection = connection;

                //utför kommandot
                cmd.ExecuteNonQuery();

                //Stäng kontakten
                this.CloseConnection();
            }
        }

        //Delete Kommando
        public void Delete(int Ean)
        {
            string query = "DELETE FROM Lager WHERE Ean=" + Ean;

            if (this.OpenConnection() == true)
            {
                MySqlCommand cmd = new MySqlCommand(query, connection);
                cmd.ExecuteNonQuery();
                this.CloseConnection();
            }
        }

        //Select Kommando,
        public void Select()
        {
            MySqlDataReader rdr = null;
            // kommandot till sql
            string query = "SELECT * FROM Lager";

            //öppna conenction
            if (this.OpenConnection() == true)
            {
                // nytt kommande som skickar kommandot till vår connection
                MySqlCommand cmd = new MySqlCommand(query, connection);
                rdr = cmd.ExecuteReader();
                while (rdr.Read())
                {
                    Console.WriteLine("Ean\t Namn\t Bästföre\n" + rdr.GetInt32(0) + "  \t"
                        + rdr.GetString(1) + "  \t" + rdr.GetInt32(2));
                }
            }

            else
            {
                Console.WriteLine("unkwon error");
            }




        }









    }


}