作者：zg18156zg你 | 来源：互联网 | 2023-09-06 20:38
一、需求
C# 使用 MySQL 数据库的情况还是比较少的，大部分使用 Windows 平台一般使用 SQL Server，在两年前我买过100元一年的学生服务器，当时也是买着玩的，装 MySQL 数据库使用起来就非常卡，也不知道为什么，但 SQL Server 操作起来不但不卡，还非常的流畅，但是 SQL Server 安装起来比较麻烦，卸载也容易出问题，尤其是盗版系统，我在工作中，也出现了几次 SQL Server 卸载不了的事，我自己电脑用的正版Win10系统，从没出现这种事。MySQL 和 SQL Server 各有自己的优点，如果非要使用 MySQL，也是可以的，下面就会介绍 C# 如何去调用 MySQL。
二、新建 C# 项目
新建一个控制台项目，取名 CSharpConnectMySQL
这里我使用的不使用顶级语句
项目创建完成后，如下
namespace CSharpConnectMySQL
{internal class Program{static void Main(string[] args){Console.WriteLine("Hello, World!");}}
}
这里忘了，应该先准备好数据库的，那就先把数据库弄完。
三、MySQL数据库
MySQL 的安装，可以在百度搜一下，我这里就演示了
下面不搞复杂的流程，随便弄点数据，就以 shop 数据库 中的 goods_type 表来演示好了。
各位可以自己动手操作一下，数据库和表不一定和我的一样，这里在后面的 sql 语句中，自己改下就好了。
四、MySqlHelper
在使用之前，先安装 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/// /// 执行存储过程,返回数据集/// ///
存储过程名///
存储过程参数/// DataSetpublic 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 对象(用来返回一个结果集，而不是一个整数值)/// ///
数据库连接///
存储过程名///
存储过程参数/// SqlCommandprivate 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 }
运行：
这样就 O拉个K
end
京公网安备 11010802041100号