摘要
主要讲述MySQL数据库链接操作C#的操作
目录
1、添加引用
2、接口介绍
2.1、MySqlConnection
2.2、MySqlCommand
2.3、MySqlDataReader
2.4、MySqlDataAdapter
2.5、MySqlTransaction
3、全网功能最全辅助类实现
4、辅助类调用实例
1、添加引用
IDE为Visual Studio 2022，选择工具->NuGet包管理器->管理解决方案的NuGet程序包
选择浏览，在输入框中输入MySql进行搜索，选中MySql.Data选项
版本选择和数据库安装版本最接近的，我这里选择8.0.33版本，然后点击安装，安装完成后引用自动添加完成。
2、接口介绍
访问数据库主要用到如下几个类，下面对其功能进行依次介绍
2.1、MySqlConnection
功能：建立数据库连接，通过MySqlConnection对象，可以建立与MySQL数据库的连接，以便执行SQL语句和访问数据。
常用方法和属性：
Open()用于打开连接
Close()用于关闭连接
State获取当前MySqlConnection对象数据库链接状态
使用实例
static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作//关闭数据库conn.Close();
}2.2、MySqlCommand
MySqlCommand类是.NET Framework中用于与MySQL数据库交互的一个重要类，它属于MySql.Data.MySqlClient命名空间。这个类提供了一系列方法和属性，用于执行SQL语句、管理事务、处理参数化查询等。以下是对MySqlCommand类接口的详细说明：
MySqlCommand类的构造函数
MySqlCommand类提供了多个构造函数，允许用户以不同的方式创建MySqlCommand对象。常用的构造函数包括：
接受一个SQL语句字符串和一个MySqlConnection对象作为参数的构造函数。
仅接受一个SQL语句字符串作为参数的构造函数（但通常需要在后续操作中设置Connection属性以指定数据库连接）。
主要方法和属性
CommandText属性：获取或设置要执行的SQL语句或存储过程的名称。
Connection属性：获取或设置与MySQL数据库的连接。
CommandType属性：获取或设置CommandText属性的类型（如Text、StoredProcedure等）。
Parameters属性：获取表示参数集合的MySqlParameterCollection对象，用于参数化查询。
ExecuteNonQuery方法：执行诸如INSERT、UPDATE、DELETE等非查询SQL语句，并返回受影响的行数。
ExecuteReader方法：执行诸如SELECT等查询SQL语句，并返回一个MySqlDataReader对象，用于读取查询结果。
ExecuteScalar方法：执行查询，并返回查询结果中的第一行第一列的值。如果查询结果为空，则返回null。
2.3、MySqlDataReader
MySqlDataReader是.NET Framework中用于从MySQL数据库中读取数据的一个快速、高效的类。以下是对MySqlDataReader接口的详细说明：
基本功能
MySqlDataReader允许你从MySQL数据库中读取数据行，并且以只读、向前只进的方式访问数据集中的每一行。它提供了一种从数据库中检索数据的高效方法，特别是在处理大量数据时。
使用方法
创建数据库连接：首先，你需要创建一个MySqlConnection对象，并使用适当的连接字符串打开与MySQL数据库的连接。
执行SQL查询：然后，创建一个MySqlCommand对象，将你的SQL查询语句传递给该对象，并指定要使用的MySqlConnection对象。
读取数据：接下来，使用MySqlCommand对象的ExecuteReader方法执行查询，并返回一个MySqlDataReader对象。你可以通过调用MySqlDataReader对象的Read方法逐行读取数据。
使用实例
static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作MySqlCommand cmd = new MySqlCommand();cmd.CommandType = CommandType.Text;//设置执行SQL语句cmd.Connection = conn;//数据库链接string strSql;//插入一条数据strSql = "insert into t_user (user_name,password,nick_name,user_no,status,phone) values('张三6','12345678','红太阳','131024685941523145',0,'13465231586')";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();//修改一条数据strSql = "update t_user set nick_name = '王麻子' where id = 1";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();//删除一条数据strSql = "delete from t_user where id = 11";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();//执行查询，并返回查询结果中的第一行第一列的值strSql = "select count(*) from t_user";cmd.CommandText = strSql;//执行的SQL语句Object resutl = cmd.ExecuteScalar();Console.WriteLine(resutl.ToString());//查看所有数据strSql = "select * from t_user";cmd.CommandText = strSql;MySqlDataReader reader = cmd.ExecuteReader();for (int i = 0; i < reader.FieldCount; i++){string name = reader.GetName(i);//获取字段名称Console.Write(name);if(i != reader.FieldCount - 1){Console.Write(" | ");}else{Console.Write("\r\n");}}while (reader.Read())//循环读取每一行数据{Console.Write(reader["id"].ToString());Console.Write(" | ");Console.Write(reader["user_name"].ToString());Console.Write(" | ");Console.Write(reader["password"].ToString());Console.Write(" | ");Console.Write(reader["nick_name"].ToString());Console.Write(" | ");Console.Write(reader["user_no"].ToString());Console.Write(" | ");Console.Write(reader["status"].ToString());Console.Write(" | ");Console.Write(reader["phone"].ToString());Console.Write("\r\n");}reader.Close();//关闭数据库conn.Close();Console.ReadKey();
}2.4、MySqlDataAdapter
MySqlDataAdapter类是ADO.NET提供的一个用于与MySQL数据库进行交互的重要类，它充当DataSet和MySQL数据库之间的桥梁，用于检索和保存数据。以下是对MySqlDataAdapter类的详细说明：
主要功能
数据检索：MySqlDataAdapter通过Fill方法从MySQL数据库中检索数据，并将数据填充到DataSet或DataTable对象中。这允许开发人员在内存中存储和操作数据库数据。
数据更新：除了检索数据外，MySqlDataAdapter还可以通过Update方法将DataSet或DataTable对象中的更改保存回MySQL数据库。这实现了数据的双向同步。
命令管理：MySqlDataAdapter包含SelectCommand、InsertCommand、DeleteCommand和UpdateCommand等属性，这些属性允许开发人员指定用于执行相应数据库操作的SQL命令。
使用方法
创建连接：首先，需要创建一个MySqlConnection对象来打开与MySQL数据库的连接。
创建命令：然后，创建一个MySqlCommand对象，并设置其CommandText属性为要执行的SQL语句。此外，还可以根据需要设置其他属性，如CommandType和Parameters等。
创建适配器：接下来，创建一个MySqlDataAdapter对象，并将之前创建的MySqlCommand对象传递给它。这样，MySqlDataAdapter就知道要执行哪个SQL语句来检索或更新数据。
执行操作
要检索数据，调用MySqlDataAdapter的Fill方法，并将DataSet或DataTable对象作为参数传递给它。Fill方法将执行SQL语句，并将结果填充到指定的DataSet或DataTable对象中。
要更新数据，首先修改DataSet或DataTable对象中的数据，然后调用MySqlDataAdapter的Update方法。Update方法将使用适当的SQL语句（如INSERT、UPDATE或DELETE）将更改保存回MySQL数据库。
重要属性
SelectCommand：获取或设置用于从数据库中选择数据的SQL命令对象。
InsertCommand：获取或设置用于向数据库中插入数据的SQL命令对象。
UpdateCommand：获取或设置用于更新数据库中数据的SQL命令对象。
DeleteCommand：获取或设置用于从数据库中删除数据的SQL命令对象。
TableMappings：获取或设置用于简化数据的加载和更新操作的表映射信息。
注意事项
资源管理：由于MySqlDataAdapter使用了非托管资源，因此在使用完毕后应确保正确释放资源。通常，可以使用using语句来自动管理MySqlDataAdapter对象的生命周期。
异常处理：在执行数据库操作时，应始终考虑异常处理。可以使用try-catch块来捕获和处理可能发生的异常，如连接失败、查询错误等。
性能优化：在处理大量数据时，应注意性能优化。例如，可以使用参数化查询来提高查询效率和安全性；可以通过设置适当的命令超时时间来避免长时间等待数据库响应等
使用实例
static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作MySqlCommand cmd = new MySqlCommand();cmd.CommandType = CommandType.Text;//设置执行SQL语句cmd.Connection = conn;//数据库链接//查看所有数据string strSql = "select * from t_user";cmd.CommandText = strSql;DataTable table = new DataTable();MySqlDataAdapter adapter = new MySqlDataAdapter(cmd);adapter.Fill(table);if (table.Rows.Count > 0){//打印所有列名string columnName = string.Empty;for (int i = 0; i < table.Columns.Count; i++){columnName += table.Columns[i].ColumnName + " | ";}Console.WriteLine(columnName);Console.WriteLine("-------------------------");//打印每一行的数据foreach (DataRow row in table.Rows){string columnStr = string.Empty;foreach (DataColumn column in table.Columns){columnStr += row[column] + " | ";}Console.WriteLine(columnStr);}}//关闭数据库conn.Close();Console.ReadKey();
}2.5、MySqlTransaction
MySqlTransaction类是ADO.NET中用于在MySQL数据库上执行事务操作的类。事务是一组要么全都成功要么全都失败的数据库操作序列，它确保了数据的一致性和完整性。以下是对MySqlTransaction类接口的详细说明：
主要功能和用途
MySqlTransaction类主要用于在MySQL数据库上开始、提交和回滚事务。它提供了对事务边界的控制，确保了一组数据库操作要么全部成功，要么在遇到错误时全部回滚，从而保持数据的一致性和完整性。
重要方法和属性
BeginTransaction方法
功能：开始一个数据库事务。
返回值：返回一个MySqlTransaction对象，表示新开始的事务。
注意事项：在开始事务之前，必须确保已经建立了与MySQL数据库的连接，并且该连接是打开的。
Commit方法
功能：提交当前事务中的所有更改，并将它们永久保存到数据库中。
返回值：无。
注意事项：在调用Commit方法之前，必须确保所有的数据库操作都已经成功完成，并且没有发生任何错误。
Rollback方法
功能：回滚当前事务中的所有更改，撤销自事务开始以来所做的所有操作。
返回值：无。
注意事项：在发生错误或需要取消事务时，应调用Rollback方法来撤销所做的更改。
IsolationLevel属性
功能：获取或设置当前事务的隔离级别。
隔离级别选项：包括读未提交（ReadUncommitted）、读已提交（ReadCommitted）、可重复读（RepeatableRead）和可串行化（Serializable）等。
注意事项：隔离级别决定了事务之间的可见性和并发性。选择合适的隔离级别对于确保数据的一致性和优化性能至关重
使用步骤和示例
建立数据库连接：首先，需要创建一个MySqlConnection对象来打开与MySQL数据库的连接。
开始事务：通过调用BeginTransaction方法来开始一个新的事务。这将返回一个MySqlTransaction对象，用于表示该事务。
执行数据库操作：在事务的上下文中执行所需的数据库操作。这些操作可以是插入、更新、删除等。
提交或回滚事务：根据操作的结果，决定是调用Commit方法来提交事务，还是调用Rollback方法来回滚事务。
以下是一个使用MySqlTransaction类的示例代码：
static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作MySqlCommand cmd = new MySqlCommand();cmd.CommandType = CommandType.Text;//设置执行SQL语句cmd.Connection = conn;//数据库链接cmd.Transaction = conn.BeginTransaction();//插入一条数据string strSql = "insert into t_user (user_name,password,nick_name,user_no,status,phone) values('张三6','12345678','红太阳','131024685941523145',0,'13465231586')";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();cmd.Transaction.Commit();//cmd.Transaction.Rollback();//查看所有数据strSql = "select * from t_user";cmd.CommandText = strSql;MySqlDataReader reader = cmd.ExecuteReader();for (int i = 0; i < reader.FieldCount; i++){string name = reader.GetName(i);//获取字段名称Console.Write(name);if (i != reader.FieldCount - 1){Console.Write(" | ");}else{Console.Write("\r\n");}}while (reader.Read())//循环读取每一行数据{Console.Write(reader["id"].ToString());Console.Write(" | ");Console.Write(reader["user_name"].ToString());Console.Write(" | ");Console.Write(reader["password"].ToString());Console.Write(" | ");Console.Write(reader["nick_name"].ToString());Console.Write(" | ");Console.Write(reader["user_no"].ToString());Console.Write(" | ");Console.Write(reader["status"].ToString());Console.Write(" | ");Console.Write(reader["phone"].ToString());Console.Write("\r\n");}reader.Close();//关闭数据库conn.Close();Console.ReadKey();
}3、全网功能最全辅助类实现
using System;
using System.Collections.Generic;
using MySql.Data.MySqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data;namespace MySQLTestDemo
{public class MySqlHelper{#region 私有/// <summary>/// 数据库链接字符串/// </summary>private static readonly string strConn = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";/// <summary>/// 数据库链接类/// </summary>private MySqlConnection conn = null;/// <summary>/// 数据库指令执行类/// </summary>private MySqlCommand cmd = null;#endregion/// <summary>/// 指令执行类/// </summary>public MySqlCommand Cmd{get { return cmd;}}/// <summary>/// 外部调用简化接口/// </summary>/// <returns></returns>public static MySqlHelper NewMySql{get{return new MySqlHelper();}}/// <summary>/// 初始化Mysql/// </summary>public void Init(string strSql = "", CommandType commandType = CommandType.Text){Close();if (conn == null){conn = new MySqlConnection(strConn);}if (cmd == null){cmd = new MySqlCommand();cmd.Connection = conn;cmd.CommandType = commandType;}if (strSql != ""){cmd.CommandText = strSql;}}/// <summary>/// 关闭MySql/// </summary>public void Close(){if (cmd != null){if (cmd.Transaction != null){cmd.Transaction = null;}cmd.Dispose();cmd = null;}if (conn != null){conn.Close();conn = null;}}/// <summary>/// 执行增、删、改操作/// </summary>/// <param name="strSql"></param>/// <returns></returns>public int ExecuteNonSql(string strSql, ref string errMsg, MySqlParameter[] param = null){Init(strSql);try{conn.Open();if (param != null){cmd.Parameters.AddRange(param);}return cmd.ExecuteNonQuery();}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行ExecuteNonSql方法时发生错误，具体信息：" + ex.Message;return -1;}finally{Close();}}/// <summary>/// 执行单一结果的查询/// </summary>/// <param name="strSql"></param>/// <returns></returns>public object ExecuteSingleResult(string strSql, ref string errMsg, MySqlParameter[] param = null){Init(strSql);try{conn.Open();if (param != null){cmd.Parameters.AddRange(param);}return cmd.ExecuteScalar();}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行GetSingleResult方法时发生错误，具体信息：" + ex.Message;return null;}finally{Close();}}/// <summary>/// 执行结果集的查询/// </summary>/// <param name="strSql"></param>/// <returns></returns>public MySqlDataReader ExecuteReader(string strSql, ref string errMsg, MySqlParameter[] param = null){Init(strSql);try{conn.Open();if (param != null){cmd.Parameters.AddRange(param);}return cmd.ExecuteReader(CommandBehavior.CloseConnection);}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行GetReader(string sql)时发生错误，具体信息：" + ex.Message;return null;}}/// <summary>/// 执行数据集返回DataTable/// </summary>/// <param name="strSql"></param>/// <returns></returns>public DataTable ExecuteDataTable(string strSql, ref string errMsg){Init(strSql);MySqlDataAdapter da = new MySqlDataAdapter(cmd);DataTable dt = new DataTable();try{conn.Open();da.Fill(dt);return dt;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行GetDataSet(string sql)时发生错误，具体信息：" + ex.Message;return null;}finally{Close();}}#region 事务/// <summary>/// 开启事务/// </summary>/// <returns></returns>public bool BeginTransaction(ref string errMsg){try{if (conn.State != ConnectionState.Open){conn.Open();}cmd.Transaction = conn.BeginTransaction();return true;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行BeginTransaction方法时发生错误，具体信息：" + ex.Message;return false;}}/// <summary>/// 提交事务/// </summary>/// <returns></returns>public bool CommitTransaction(ref string errMsg){try{cmd.Transaction.Commit();//提交事务（同时自动清除事务）return true;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行CommitTransaction方法时发生错误，具体信息：" + ex.Message;return false;}}/// <summary>/// 回滚事务/// </summary>/// <returns></returns>public bool RollbackTransaction(ref string errMsg){try{cmd.Transaction.Rollback();return true;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行RollbackTransaction方法时发生错误，具体信息：" + ex.Message;return false;}}#endregion}//class
}//namespace4、辅助类调用实例
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace MySQLTestDemo
{internal class Program{static void Main(string[] args){//执行增删改操作{Console.WriteLine("----------------执行增删改操作---------------------");string strSql = "update t_user set nick_name = '王麻子1' where id = 1";string errMsg = string.Empty;int flag = MySqlHelper.NewMySql.ExecuteNonSql(strSql, ref errMsg);Console.WriteLine(flag);if (flag == -1){Console.WriteLine(errMsg);}}//执行单一结果操作{Console.WriteLine("-----------------执行单一结果操作--------------------");string strSql = "select count(*) from t_user";string errMsg = string.Empty;object obj = MySqlHelper.NewMySql.ExecuteSingleResult(strSql, ref errMsg);Console.WriteLine(obj);if(obj == null){Console.WriteLine(errMsg);}}//执行结果集操作{Console.WriteLine("----------------执行结果集操作---------------------");string strSql = "select * from t_user";string errMsg = string.Empty;MySqlHelper mySqlHelper = new MySqlHelper();MySqlDataReader reader = mySqlHelper.ExecuteReader(strSql, ref errMsg);if (reader == null){Console.WriteLine(errMsg);}for (int i = 0; i < reader.FieldCount; i++){string name = reader.GetName(i);//获取字段名称Console.Write(name);if (i != reader.FieldCount - 1){Console.Write(" | ");}else{Console.Write("\r\n");}}while (reader.Read())//循环读取每一行数据{Console.Write(reader["id"].ToString());Console.Write(" | ");Console.Write(reader["user_name"].ToString());Console.Write(" | ");Console.Write(reader["password"].ToString());Console.Write(" | ");Console.Write(reader["nick_name"].ToString());Console.Write(" | ");Console.Write(reader["user_no"].ToString());Console.Write(" | ");Console.Write(reader["status"].ToString());Console.Write(" | ");Console.Write(reader["phone"].ToString());Console.Write("\r\n");}reader.Close();mySqlHelper.Close();}//执行DataTable结果集操作{Console.WriteLine("----------------执行DataTable结果集操作---------------------");string strSql = "select * from t_user";string errMsg = string.Empty;MySqlHelper mySqlHelper = new MySqlHelper();DataTable table = mySqlHelper.ExecuteDataTable(strSql, ref errMsg);if (table.Rows.Count > 0){//打印所有列名string columnName = string.Empty;for (int i = 0; i < table.Columns.Count; i++){columnName += table.Columns[i].ColumnName + " | ";}Console.WriteLine(columnName);Console.WriteLine("-------------------------");//打印每一行的数据foreach (DataRow row in table.Rows){string columnStr = string.Empty;foreach (DataColumn column in table.Columns){columnStr += row[column] + " | ";}Console.WriteLine(columnStr);}}mySqlHelper.Close();}//执行事务操作{Console.WriteLine("----------------执行事务操作---------------------");MySqlHelper mySqlHelper = new MySqlHelper();string errMsg = "";try{mySqlHelper.Init();if(!mySqlHelper.BeginTransaction(ref errMsg)){Console.WriteLine(errMsg);}string strSql = "update t_user set nick_name = '王麻子3' where id = 1";mySqlHelper.Cmd.CommandText = strSql;mySqlHelper.Cmd.ExecuteNonQuery();if (!mySqlHelper.CommitTransaction(ref errMsg)){Console.WriteLine(errMsg);}//if (!mySqlHelper.RollbackTransaction(ref errMsg))//{// Console.WriteLine(errMsg);//}Console.WriteLine("执行成功");}catch (Exception ex){if (!mySqlHelper.RollbackTransaction(ref errMsg)){Console.WriteLine(errMsg);}Console.WriteLine(ex.Message);}mySqlHelper.Close();}Console.ReadKey();}}
}
