MySql數據封裝操作類

1.先引用MySQL的DLL文件

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Configuration;
using System.Data.SqlClient;
using MySql.Data.MySqlClient;

namespace MySQLHelper
{
    public static class MySqlHelper
    {
        //從配置文件中獲取連接字符串   readonly修飾的變量只能在初始化或構造函數中賦值；其他地方只能讀取
        //private static readonly string constr = ConfigurationManager.ConnectionStrings["OperationHistory"].ConnectionString;
        private static readonly string constr = "server=127.0.0.1;port=3306;database=mygamedb;user=root;password=root";

        /// <summary>
        /// 增、刪、改的方法[ExecuteNonQuery] 返回所影響的行數，執行其他
        /// </summary>
        /// <param name="sql">Sql命令</param>
        /// <param name="cmdtype">SQL語句（CommandType.Text）或者存儲過程(CommandType.StoredProcedure)</param>
        /// <param name="pms"></param>
        /// <returns></returns>
        public static int ExecuteNonQuery(string sql, CommandType cmdtype, params SqlParameter[] pms)
        {
            int i = -1;
            try
            {
                using (MySqlConnection con = new MySqlConnection(constr))
                {
                    using (MySqlCommand cmd = new MySqlCommand(sql, con))
                    {
                        //存儲過程或者Sql語句
                        cmd.CommandType = cmdtype;
                        if (pms != null)
                        {
                            cmd.Parameters.AddRange(pms);
                        }

                        con.Open();
                        i = cmd.ExecuteNonQuery();
                    }
                }
            }
            catch (Exception)
            {
                throw;
            }

            return i;
        }

        /// <summary>
        /// 執行查詢、查詢多少條數據；返回第一行，第一列方法[ExecuteScalar] 返回-1執行失敗 
        /// </summary>
        /// <param name="sql">Sql命令</param>
        /// <param name="cmdtype">SQL語句（CommandType.Text）或者存儲過程(CommandType.StoredProcedure)</param>
        /// <param name="pms"></param>
        /// <returns></returns>
        public static object ExecuteScalar(string sql, CommandType cmdtype, params SqlParameter[] pms)
        {
            try
            {
                using (MySqlConnection con = new MySqlConnection(constr))
                {
                    using (MySqlCommand cmd = new MySqlCommand(sql, con))
                    {
                        //存儲過程或者Sql語句
                        cmd.CommandType = cmdtype;
                        if (pms != null)
                        {
                            cmd.Parameters.AddRange(pms);
                        }

                        con.Open();
                        return cmd.ExecuteScalar();
                    }
                }
            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 執行查詢，返回多行、多列的方法ExecuteReader()
        /// </summary>
        /// <param name="sql">Sql命令</param>
        /// <param name="cmdtype">SQL語句（CommandType.Text）或者存儲過程(CommandType.StoredProcedure)</param>
        /// <param name="pms"></param>
        /// <returns></returns>
        public static MySqlDataReader ExecuteReader(string sql, CommandType cmdtype, params SqlParameter[] pms)
        {
            using (MySqlConnection con = new MySqlConnection(constr))
            {
                using (MySqlCommand cmd = new MySqlCommand(sql, con))
                {
                    //存儲過程或者Sql語句
                    cmd.CommandType = cmdtype;
                    if (pms != null)
                    {
                        cmd.Parameters.AddRange(pms);
                    }

                    try
                    {
                        con.Open();
                        return cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
                    }
                    catch
                    {
                        con.Close();
                        con.Dispose();
                        throw;
                    }
                }
            }
        }

        /// <summary>
        /// 執行返回多個查詢時使用,返回DataTable類型
        /// </summary>
        /// <param name="sql">Sql命令</param>
        /// <param name="cmdtype">SQL語句（CommandType.Text）或者存儲過程(CommandType.StoredProcedure)</param>
        /// <param name="pms">參數</param>
        /// <returns></returns>
        public static DataTable ExecuteDataTable(string sql, CommandType cmdtype, params SqlParameter[] pms)
        {
            DataTable dt = new DataTable();
            try
            {
                //通過adapter讀取數據。
                using (MySqlDataAdapter adapter = new MySqlDataAdapter(sql, constr))
                {
                    adapter.SelectCommand.CommandType = cmdtype;
                    if (pms != null)
                    {
                        adapter.SelectCommand.Parameters.AddRange(pms);
                    }

                    adapter.Fill(dt);
                    return dt;
                }
            }
            catch (Exception)
            {
                throw;
            }
        }

         /// <summary>
        /// 需要獲得多個結果集的時候用該方法，返回DataSet對象。
        /// </summary>
        /// <param name="sql語句"></param>
        /// <returns></returns>
        
        public static DataSet ExecuteDataSet(string sql, params SqlParameter[] paras)
        {
            using (MySqlConnection con = new MySqlConnection(constr))
            {
                //數據適配器
                MySqlDataAdapter sqlda = new MySqlDataAdapter(sql, con);
                sqlda.SelectCommand.Parameters.AddRange(paras);
                DataSet ds = new DataSet();
                sqlda.Fill(ds);
                return ds;
                //不需要打開和關閉鏈接.
            }
        }
    }
}