位置：首页-资讯-数据库

C# 连接 MySQL 数据库

2023-09-02 19:22

短信预约 -IT技能 免费直播动态提醒

C# 使用 MySQL 数据库的情况还是比较少的，大部分使用 Windows 平台一般使用 SQL Server，在两年前我买过100元一年的学生服务器，当时也是买着玩的，装 MySQL 数据库使用起来就非常卡，也不知道为什么，但 SQL Server 操作起来不但不卡，还非常的流畅，但是 SQL Server 安装起来比较麻烦，卸载也容易出问题，尤其是盗版系统，我在工作中，也出现了几次 SQL Server 卸载不了的事，我自己电脑用的正版Win10系统，从没出现这种事。MySQL 和 SQL Server 各有自己的优点，如果非要使用 MySQL，也是可以的，下面就会介绍 C# 如何去调用 MySQL。

新建一个控制台项目，取名 CSharpConnectMySQL

这里我使用的不使用顶级语句

项目创建完成后，如下

namespace CSharpConnectMySQL{    internal class Program    {        static void Main(string[] args)        {            Console.WriteLine("Hello, World!");        }    }}

MySQL 的安装，可以在百度搜一下，这里就不演示了

下面不搞复杂的流程，随便弄点数据，就以 shop 数据库中的 goods_type 来演示好了。

各位可以自己动手操作一下，数据库和表不一定和我的一样，在后面的 sql 语句中，自己改下就好了。

在使用之前，先安装 MySql.Data 插件

接着安装 System.Data.SqlClient

这样就安装完成了，接下来就是代码了

MySqlHelper.cs

using MySql.Data.MySqlClient;using System;using System.Collections.Generic;using System.Data;using System.Linq;using System.Text;using System.Threading.Tasks;namespace CSharpConnectMySQL{    public class MySqlHelper    {        private static string connstr = "server=127.0.0.1;database=shop;username=root;password=123456;";        #region 执行查询语句，返回MySqlDataReader        ///         /// 执行查询语句，返回MySqlDataReader        /// 
        ///         ///         public static MySqlDataReader ExecuteReader(string sqlString)        {            MySqlConnection connection = new MySqlConnection(connstr);            MySqlCommand cmd = new MySqlCommand(sqlString, connection);            MySqlDataReader myReader = null;            try            {                connection.Open();                myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);                return myReader;            }            catch (System.Data.SqlClient.SqlException e)            {                connection.Close();                throw new Exception(e.Message);            }            finally            {                if (myReader == null)                {                    cmd.Dispose();                    connection.Close();                }            }        }        #endregion        #region 执行带参数的查询语句，返回 MySqlDataReader        ///         /// 执行带参数的查询语句，返回MySqlDataReader        /// 
        ///         ///         ///         public static MySqlDataReader ExecuteReader(string sqlString, params MySqlParameter[] cmdParms)        {            MySqlConnection connection = new MySqlConnection(connstr);            MySqlCommand cmd = new MySqlCommand();            MySqlDataReader myReader = null;            try            {                PrepareCommand(cmd, connection, null, sqlString, cmdParms);                myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);                cmd.Parameters.Clear();                return myReader;            }            catch (System.Data.SqlClient.SqlException e)            {                connection.Close();                throw new Exception(e.Message);            }            finally            {                if (myReader == null)                {                    cmd.Dispose();                    connection.Close();                }            }        }        #endregion        #region 执行sql语句,返回执行行数        ///         /// 执行sql语句,返回执行行数        /// 
        ///         ///         public static int ExecuteSql(string sql)        {            using (MySqlConnection conn = new MySqlConnection(connstr))            {                using (MySqlCommand cmd = new MySqlCommand(sql, conn))                {                    try                    {                        conn.Open();                        int rows = cmd.ExecuteNonQuery();                        return rows;                    }                    catch (MySql.Data.MySqlClient.MySqlException e)                    {                        conn.Close();                        //throw e;                        Console.WriteLine(e.Message);                    }                    finally                    {                        cmd.Dispose();                        conn.Close();                    }                }            }            return -1;        }        #endregion        #region 执行带参数的sql语句，并返回执行行数        ///         /// 执行带参数的sql语句，并返回执行行数        /// 
        ///         ///         ///         public static int ExecuteSql(string sqlString, params MySqlParameter[] cmdParms)        {            using (MySqlConnection connection = new MySqlConnection(connstr))            {                using (MySqlCommand cmd = new MySqlCommand())                {                    try                    {                        PrepareCommand(cmd, connection, null, sqlString, cmdParms);                        int rows = cmd.ExecuteNonQuery();                        cmd.Parameters.Clear();                        return rows;                    }                    catch (System.Data.SqlClient.SqlException E)                    {                        throw new Exception(E.Message);                    }                    finally                    {                        cmd.Dispose();                        connection.Close();                    }                }            }        }        #endregion        #region 执行查询语句，返回DataSet        ///         /// 执行查询语句，返回DataSet        /// 
        ///         ///         public static DataSet GetDataSet(string sql)        {            using (MySqlConnection conn = new MySqlConnection(connstr))            {                DataSet ds = new DataSet();                try                {                    conn.Open();                    MySqlDataAdapter DataAdapter = new MySqlDataAdapter(sql, conn);                    DataAdapter.Fill(ds);                }                catch (Exception ex)                {                    //throw ex;                    Console.WriteLine(ex.Message);                }                finally                {                    conn.Close();                }                return ds;            }        }        #endregion        #region 执行带参数的查询语句，返回DataSet        ///         /// 执行带参数的查询语句，返回DataSet        /// 
        ///         ///         ///         public static DataSet GetDataSet(string sqlString, params MySqlParameter[] cmdParms)        {            using (MySqlConnection connection = new MySqlConnection(connstr))            {                MySqlCommand cmd = new MySqlCommand();                PrepareCommand(cmd, connection, null, sqlString, cmdParms);                using (MySqlDataAdapter da = new MySqlDataAdapter(cmd))                {                    DataSet ds = new DataSet();                    try                    {                        da.Fill(ds, "ds");                        cmd.Parameters.Clear();                    }                    catch (System.Data.SqlClient.SqlException ex)                    {                        throw new Exception(ex.Message);                    }                    finally                    {                        cmd.Dispose();                        connection.Close();                    }                    return ds;                }            }        }        #endregion        #region 执行带参数的sql语句，并返回 object        ///         /// 执行带参数的sql语句，并返回object        /// 
        ///         ///         ///         public static object GetSingle(string sqlString, params MySqlParameter[] cmdParms)        {            using (MySqlConnection connection = new MySqlConnection(connstr))            {                using (MySqlCommand cmd = new MySqlCommand())                {                    try                    {                        PrepareCommand(cmd, connection, null, sqlString, cmdParms);                        object obj = cmd.ExecuteScalar();                        cmd.Parameters.Clear();                        if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))                        {return null;                        }                        else                        {return obj;                        }                    }                    catch (System.Data.SqlClient.SqlException e)                    {                        throw new Exception(e.Message);                    }                    finally                    {                        cmd.Dispose();                        connection.Close();                    }                }            }        }        #endregion        ///         /// 执行存储过程,返回数据集        /// 
        /// 存储过程名        /// 存储过程参数        /// DataSet        public static DataSet RunProcedureForDataSet(string storedProcName, IDataParameter[] parameters)        {            using (MySqlConnection connection = new MySqlConnection(connstr))            {                DataSet dataSet = new DataSet();                connection.Open();                MySqlDataAdapter sqlDA = new MySqlDataAdapter();                sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);                sqlDA.Fill(dataSet);                connection.Close();                return dataSet;            }        }        ///         /// 构建 SqlCommand 对象(用来返回一个结果集，而不是一个整数值)        /// 
        /// 数据库连接        /// 存储过程名        /// 存储过程参数        /// SqlCommand        private static MySqlCommand BuildQueryCommand(MySqlConnection connection, string storedProcName,            IDataParameter[] parameters)        {            MySqlCommand command = new MySqlCommand(storedProcName, connection);            command.CommandType = CommandType.StoredProcedure;            foreach (MySqlParameter parameter in parameters)            {                command.Parameters.Add(parameter);            }            return command;        }        #region 装载MySqlCommand对象        ///         /// 装载MySqlCommand对象        /// 
        private static void PrepareCommand(MySqlCommand cmd, MySqlConnection conn, MySqlTransaction trans, string cmdText,            MySqlParameter[] cmdParms)        {            if (conn.State != ConnectionState.Open)            {                conn.Open();            }            cmd.Connection = conn;            cmd.CommandText = cmdText;            if (trans != null)            {                cmd.Transaction = trans;            }            cmd.CommandType = CommandType.Text; //cmdType;            if (cmdParms != null)            {                foreach (MySqlParameter parm in cmdParms)                {                    cmd.Parameters.Add(parm);                }            }        }        #endregion    }}

connstr 中的配置，根据个人的设置来，也可以写配置文件中。

MySqlHelper 代码基本功能都有，代码不是我写的，我也是复制别人的

代码

using System.Data;namespace CSharpConnectMySQL{    internal class Program    {        static void Main(string[] args)        {            string sql = "SELECT * FROM goods_type";            DataSet dataSet = MySqlHelper.GetDataSet(sql);            DataTable dt = dataSet.Tables[0];            if(dt.Rows.Count > 0)            {                //打印所有列名                string columnName = string.Empty;                for (int i = 0; i < dt.Columns.Count; i++)                {                    columnName += dt.Columns[i].ColumnName + " | ";                }                Console.WriteLine(columnName);                Console.WriteLine("-------------------------");                //打印每一行的数据                foreach (DataRow row in dt.Rows)                {                    string columnStr = string.Empty;                    foreach (DataColumn column in dt.Columns)                    {                        columnStr += row[column] + " | ";                    }                    Console.WriteLine(columnStr);                }            }            Console.ReadKey();        }    }}

运行：