using Casic.Birmm.RbFreqStandMeasure.Tools;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;

namespace Casic.Birmm.RbFreqStandMeasure.R_DataBase
{
    public class DbConnectService
    {
        public static MySqlConnection mySqlConnect = null;
        private static String server = ConfigHelper.GetAppConfig("server");
        private static String databasePort = ConfigHelper.GetAppConfig("databasePort");
        private static String databaseUser = ConfigHelper.GetAppConfig("databaseUser");
        private static String databaseName = ConfigHelper.GetAppConfig("databaseName");
        private static String databasePassword = ConfigHelper.GetAppConfig("databasePassword");

        public static int openDb()
        {
            int iRetval = -1;
            try
            {
                string sConnection = "server=" + server
                                   + ";port=" + databasePort
                                   + ";user=" + databaseUser
                                   + ";database=" + databaseName
                                   + ";password=" + databasePassword
                                   + ";Charset=utf8"
                                   + ";Allow User Variables=True"
                                   + ";Pooling=true";
                mySqlConnect = new MySqlConnection(sConnection);
                mySqlConnect.Open();
                iRetval = 0;
            }
            catch (Exception ex)
            {
                iRetval = -1;
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "openDB : " + ex.Message);
            }
            return iRetval;
        }

        public static MySqlConnection getConnection()
        {
            string sConnection = "server=" + server
                                   + ";port=" + databasePort
                                   + ";user=" + databaseUser
                                   + ";database=" + databaseName
                                   + ";password=" + databasePassword
                                   + ";Charset=utf8"
                                   + ";Allow User Variables=True"
                                   + ";Pooling=true";
            MySqlConnection conn = new MySqlConnection(sConnection);
            conn.Open();

            return conn;
        }

        public static int closeDb()
        {
            int iRetval = -1;
            try
            {
                mySqlConnect.Close();
            }
            catch (MySqlException exSql)
            {
                iRetval = exSql.ErrorCode;
            }
            catch (Exception ex)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "closeDB : " + ex.Message);
            }

            return iRetval;
        }

    }
}