using System;
using System.Collections.Generic;
using System.Text;
using MySql.Data.MySqlClient;

namespace kurier
{
    public class MySQL
    {
        private MySqlConnection conn;
        private MySqlCommand cmd;
        private string database;

        public MySQL(string database)
        {
            this.database = database;
            connect();
        }

        public void connect()
        {
            conn = new MySqlConnection((database != "" ? ("Database=" + database + ";") : "")
                + "Data Source=" + getHost() + ";User Id=" + getUser() + ";Password=" + getPass() 
                + ";Port=" + getPort() + ";charset=utf8;");

            conn.Open();
        }

        public void close()
        {
            try
            {
                conn.Close();
                conn = null;
            }
            catch (Exception)
            {
            }
        }

        public bool isOpen()
        {
            return conn != null;
        }

        public static string test()
        {
            try
            {
                MySqlConnection conn = new MySqlConnection("Data Source=" + getHost() + ";User Id=" + getUser() + ";Password=" + getPass()
                + ";Port=" + getPort() + ";charset=utf8;");
                conn.Open();
            }
            catch (MySqlException e)
            {
                return e.Message;
            }
            catch (Exception e)
            {
                return "Prawdopodobnie brakuje Ci dll-ki od MySQL'a.\n\n" + e.Message;
            }
            return "";
        }

        public MySqlDataReader select(string query)
        {
            MySqlCommand comm = new MySqlCommand(query, conn);
            return comm.ExecuteReader();
        }

        public static string getHost() { return Properties.Settings.Default.HOST; }
        public static string getUser() { return Properties.Settings.Default.USER; }
        public static string getPass() { return Properties.Settings.Default.PASS; }
        public static string getPort() { return Properties.Settings.Default.PORT; }
        public static bool getConfigured() { return Properties.Settings.Default.CONFIGURED; }

        internal void backup(string filePath)
        {
            cmd = new MySqlCommand();
            cmd.Connection = conn;
            MySqlBackup backup = new MySqlBackup(cmd);
            backup.ExportInfo.AddCreateDatabase = true;
            backup.ExportToFile(filePath);
        }
    }
}