C#通過MySql.Data.dll連接MySql數據庫操作

MySQL數據庫操作的C#代碼，需添加MySql.Data.dll的引用。

 

/// <summary>
    /// MySQL數據庫操作
    /// author:hhm
    /// date:2012-2-22
    /// </summary>
    public class MySqlDbHelper
    {
        #region 私有變量
        private const string defaultConfigKeyName = "DbHelper";//連接字符串 默認Key
        private string connectionString;
        private string providerName;

        #endregion

         #region 構造函數

        /// <summary>
        /// 默認構造函數(DbHelper)
        /// </summary>
        public MySqlDbHelper()
        {
            this.connectionString = ConfigurationManager.ConnectionStrings["DbHelper"].ConnectionString;
            this.providerName = ConfigurationManager.ConnectionStrings["DbHelper"].ProviderName;
        }

        /// <summary>
        /// DbHelper構造函數
        /// </summary>
        /// <param name="keyName">連接字符串名</param>
        public MySqlDbHelper(string keyName)
        {
            this.connectionString = ConfigurationManager.ConnectionStrings[keyName].ConnectionString;
            this.providerName = ConfigurationManager.ConnectionStrings[keyName].ProviderName;
        }

        #endregion

        public int ExecuteNonQuery(string sql, params  MySqlParameter[] parameters)
        {
            MySqlConnection con = new MySqlConnection(connectionString);
            con.Open();
            MySqlCommand cmd = new MySqlCommand(sql, con);
            foreach (MySqlParameter parameter in parameters)
            {
                cmd.Parameters.Add(parameter);
            }
            int res =0;
            try
            {
                res = cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                res = -1;
            }
            cmd.Dispose();
            con.Close();
            return res;
        }

        public object ExecuteScalar(string sql, params MySqlParameter[] parameters)
        {
            MySqlConnection con = new MySqlConnection(connectionString);
            con.Open();
            MySqlCommand cmd = new MySqlCommand(sql, con);
            foreach (MySqlParameter parameter in parameters)
            {
                cmd.Parameters.Add(parameter);
            }
            object res = cmd.ExecuteScalar();
            cmd.Dispose();
            con.Close();
            return res;
        }

        public DataTable ExecuteDataTable(string sql, params MySqlParameter[] parameters)
        {
            MySqlConnection con = new MySqlConnection(connectionString);
            con.Open();
            MySqlCommand cmd = new MySqlCommand(sql, con);
            foreach (MySqlParameter parameter in parameters)
            {
                cmd.Parameters.Add(parameter);
            }
            DataSet dataset = new DataSet();//dataset放執行后的數據集合
            MySqlDataAdapter adapter = new MySqlDataAdapter(cmd);
            adapter.Fill(dataset);
            cmd.Dispose();
            con.Close();
            return dataset.Tables[0];           
        }
    }