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

namespace laserPTZ
{
    class DatabaseHelper
    {
        public static MySqlConnection mySqlConnect = null;

        /// <summary>
        /// 打开数据库连接     
        /// </summary>
        /// <param name="sConnection"> connection </param>
        /// <returns> 0 on success </returns>
        public static int OpenDB()
        {
            int iRetval = -1;
            try
            {
                string localDatabaseName = ConfigHelper.GetAppConfig("localDatabaseName");
                string localDatabasePort = ConfigHelper.GetAppConfig("localDatabasePort");
                string localDatabaseUser = ConfigHelper.GetAppConfig("localDatabaseUser");
                string localDatabasePassword = ConfigHelper.GetAppConfig("localDatabasePassword");
                string sConnection = "server=localhost"
                                   + ";port=" + localDatabasePort
                                   + ";user=" + localDatabaseUser
                                   + ";database=" + localDatabaseName
                                   + ";password=" + localDatabasePassword
                                   + ";Charset=utf8"
                                   + ";Allow User Variables=True";
                mySqlConnect = new MySqlConnection(sConnection);
                mySqlConnect.Open();
                iRetval = 0;
            }
            catch (Exception ex)
            {
                iRetval = -1;
                //LogHelper.WriteLog(MethodBase.GetCurrentMethod().DeclaringType, "  OpenDB : " + ex.Message);
            }

            return iRetval;
        }


        /// <summary>
        /// 关闭数据库连接    
        /// </summary>
        /// <returns> 0 on success </returns>
        /// 
        public static int CloseDB()
        {
            int iRetval = -1;
            try
            {
                mySqlConnect.Close();
            }
            catch (MySqlException exSql)
            {
                iRetval = exSql.ErrorCode;
            }
            catch (Exception ex)
            {
                LogHelper.WriteLog("  CloseDB : " + ex.Message);
            }

            return iRetval;
        }

    }
}