博客

需要引用的命名空间：

using MySql.Data.MySqlClient;//为连接mysql服务
using System.Configuration;//为连接配置文件服务
using System.Data;//为Datatabel服务

注意：需要提前引用Mysql.Data。不知到如何引用的请看`在

C#连接mysql

代码：

public  class SQLHELPER
    {
        private MySqlConnection conn = null;//数据库连接
        private MySqlCommand cmd = null;//对数据库进行操作，也就是增删改查
        private MySqlDataReader sdr = null;//从数据库中只读

        public SQLHELPER()
        {
            string connStr = ConfigurationManager.AppSettings["connStr"]; //客户端访问配置文件,读取连接数据库信息;引用程序集的命名空间
            conn = new MySqlConnection(connStr);//打开数据库的连接,此时并未连接成功
        }
        /// <summary>
        /// 判断数据源的连接情况
        /// </summary>
        /// <returns>连接</returns>
        private MySqlConnection GetConn()
        {
            if (conn.State == ConnectionState.Closed) //枚举ConnectionState,用于描述数据源当前的连接状态
            {
                conn.Open();//连接数据库
            }
            return conn;
        }

        /// <summary>
        /// 通过ExecuteQuery()方法。执行带参的SQL查询语句或存储过程
        /// </summary>
        /// <param name="cmdText">查询文本</param>
        /// <param name="paras">参数</param>
        /// <param name="ct">执行类型</param>
        /// <returns>受影响的行</returns>
        public DataTable ExecuteQuery(string cmdText, MySqlParameter[] paras, CommandType ct)
        {
            DataTable dt = new DataTable();//实例化数据库内存中的一个表
            cmd = new MySqlCommand(cmdText, GetConn());  //cmdText：查询的文本;getConn():连接数据库的方法
            cmd.CommandType = ct;//指定命令对象的执行形式,默认为text
            cmd.Parameters.AddRange(paras);//将参数加入到参数集中
            using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection)) //在执行命令时,将关联 Connection 对象已关闭时关联 DataReader 对象已关闭
            {
                dt.Load(sdr);   //将提供的数据源中的值填充到DataTable,如果已存在,则合并
            }
            return dt;  //返回表到DAL层
        }

        /// <summary>
        /// 执行不带参数的SQL查询语句或者存储过程
        /// </summary>
        /// <param name="cmdText">查询SQL语句或存储过程</param>
        /// <param name="ct">命令类型</param>
        /// <returns>返回受影响的行数</returns>
        public DataTable ExecuteQuery(string cmdText, CommandType ct)
        {
            DataTable dt = new DataTable();
            cmd = new MySqlCommand(cmdText, GetConn());
            cmd.CommandType = ct;
            using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))
            {
                dt.Load(sdr);
            }
            return dt;
        }


        /// <summary>
        /// 执行不带参数的数据库操作或者存储过程heihei
        /// </summary>
        /// <param name="cmdText">增删改查操作</param>
        /// <param name="ct">命令类型</param>
        /// <returns>返回受影响的行数</returns>
        public int ExecuteNonQuery(string cmdText, CommandType ct)
        {
            int res;
            cmd = new MySqlCommand(cmdText, GetConn());
            cmd.CommandType = ct;
            res = cmd.ExecuteNonQuery();
            if (conn.State == ConnectionState.Open)
            {
                conn.Close();
            }

            return res;
        }


        /// <summary>
        /// 执行带参数的数据库操作或者存储过程
        /// </summary>
        /// <param name="cmdText">增删改查操作</param>
        /// <param name="paras">要查询的参数</param>
        /// <param name="ct">命令类型</param>
        /// <returns>返回受影响的行数</returns>
        public int ExecuteNonQuery(string cmdText, MySqlParameter[] paras, CommandType ct)
        {
            int res;
            using (cmd = new MySqlCommand(cmdText, GetConn()))
            {
                cmd.CommandType = ct;
                cmd.Parameters.AddRange(paras);
                res = cmd.ExecuteNonQuery();
            }
            return res;
        }

         
    }

解析：