摘要
本篇文章主要介绍C#链接MySQL数据库的接口介绍，使用实例及注意事项，辅助类的封装及调用实例，可以直接移植到项目里面使用。
目录
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();
}
}
}