一、引言

在现代软件开发中，数据持久化是一个至关重要的环节，无论是开发桌面应用、Web应用还是移动应用，都不可避免地需要与数据库进行交互，MySQL作为一款开源的关系型数据库管理系统，因其高效、稳定和易用而被广泛应用，而C#作为一种强大的面向对象编程语言，常用于.NET框架下的各种应用程序开发，本文将详细介绍如何在C#中连接并操作MySQL数据库，包括准备工作、代码实现以及一些高级技巧。

二、准备工作

安装MySQL数据库

您需要在您的计算机上安装MySQL数据库，您可以从MySQL官方网站下载最新版本的MySQL Community Server，并根据安装向导完成安装过程，安装完成后，请确保MySQL服务正在运行。

安装MySQL连接器

为了在C#中连接MySQL数据库，我们需要使用MySQL官方提供的MySQL Connector/NET，这个连接器提供了一组.NET API，使得C#应用程序能够与MySQL数据库进行通信，您可以从MySQL官方网站下载与您的MySQL服务器版本相匹配的MySQL Connector/NET，并在项目中添加引用。

创建MySQL数据库和表

在开始编写C#代码之前，我们需要先在MySQL中创建一个数据库和至少一个表，以便后续进行数据操作，您可以使用MySQL Workbench等工具来创建数据库和表，或者直接在命令行中使用SQL语句进行创建，以下是一个简单的示例SQL脚本，用于创建一个名为“testdb”的数据库和一个名为“users”的表：

CREATE DATABASE IF NOT EXISTS testdb;
USE testdb;
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    password VARCHAR(50) NOT NULL,
    email VARCHAR(100) NOT NULL
);

执行上述SQL脚本后，您将拥有一个包含“users”表的“testdb”数据库，可以用于后续的C#连接和操作测试。

三、C#连接MySQL数据库的基本步骤

引入命名空间

在C#项目的代码文件中，首先需要引入MySql.Data命名空间，该命名空间包含了所有必要的类和方法来连接和操作MySQL数据库，如果您已经正确安装了MySQL Connector/NET并添加了引用，那么可以直接在代码文件的顶部添加以下using指令：

using MySql.Data.MySqlClient;

创建连接字符串

连接字符串是C#应用程序与MySQL数据库建立连接的关键配置信息，它通常包含数据库服务器的地址、端口号、数据库名称、用户名和密码等参数，以下是一个典型的连接字符串示例：

string connectionString = "Server=localhost;Port=3306;Database=testdb;User ID=root;Password=yourpassword;";

请根据实际情况替换Server（数据库服务器地址）、Port（端口号，默认为3306）、Database（要连接的数据库名称）、User ID（用户名）和Password（密码）的值。

建立连接

使用连接字符串创建一个MySqlConnection对象，并通过调用其Open方法来建立与MySQL数据库的连接，以下是建立连接的示例代码：

// 创建连接对象
MySqlConnection conn = new MySqlConnection(connectionString);
try
{
    // 打开连接
    conn.Open();
    Console.WriteLine("连接成功！");
}
catch (Exception ex)
{
    Console.WriteLine("连接失败：" + ex.Message);
}
finally
{
    // 确保在结束时关闭连接
    conn.Close();
}

执行SQL命令

连接建立后，您可以使用MySqlCommand对象来执行SQL命令。MySqlCommand对象表示将在数据库上执行的SQL语句或存储过程，您可以设置其CommandText属性来指定要执行的SQL命令，并通过ExecuteNonQuery、ExecuteReader或ExecuteScalar等方法来执行命令并处理结果，以下是一个简单的示例，演示如何向“users”表中插入一条新记录：

// 创建SQL插入命令
string sql = "INSERT INTO users (username, password, email) VALUES (@username, @password, @email)";
MySqlCommand cmd = new MySqlCommand(sql, conn);
// 添加参数以避免SQL注入攻击
cmd.Parameters.AddWithValue("@username", "john_doe");
cmd.Parameters.AddWithValue("@password", "securepassword123");
cmd.Parameters.AddWithValue("@email", "john.doe@example.com");
try
{
    // 打开连接并执行命令
    conn.Open();
    int rowsAffected = cmd.ExecuteNonQuery();
    Console.WriteLine($"插入{rowsAffected}条记录。");
}
catch (Exception ex)
{
    Console.WriteLine("操作失败：" + ex.Message);
}
finally
{
    // 确保在结束时关闭连接
    conn.Close();
}

在这个示例中，我们使用了参数化查询来避免SQL注入攻击，这是一种常见的安全威胁，通过Parameters.AddWithValue方法，我们可以为SQL命令中的参数赋值。

读取和处理数据

除了插入数据外，您还可以使用MySqlCommand对象来查询数据，通过设置CommandText属性为SELECT语句，并使用ExecuteReader方法来获取查询结果，以下是一个示例，演示如何查询并遍历“users”表中的所有记录：

// 创建SQL查询命令
string query = "SELECT id, username, email FROM users";
MySqlCommand cmd = new MySqlCommand(query, conn);
try
{
    // 打开连接并执行命令
    conn.Open();
    MySqlDataReader reader = cmd.ExecuteReader();
    // 遍历查询结果
    while (reader.Read())
    {
        int id = reader.GetInt32("id");
        string username = reader.GetString("username");
        string email = reader.GetString("email");
        Console.WriteLine($"ID: {id}, Username: {username}, Email: {email}");
    }
}
catch (Exception ex)
{
    Console.WriteLine("查询失败：" + ex.Message);
}
finally
{
    // 确保在结束时关闭连接和读取器
    reader.Close();
    conn.Close();
}

在这个示例中，我们使用了MySqlDataReader对象来读取查询结果，通过调用Read方法逐行遍历结果集，并使用列名或索引作为参数传递给GetInt32、GetString等方法来获取各列的值，在使用完MySqlDataReader对象后，应及时调用其Close方法以释放资源。

事务处理和错误处理

在数据库操作中，事务处理和错误处理是非常重要的部分，通过使用事务，您可以确保一系列操作要么全部成功，要么全部回滚，从而保持数据的一致性和完整性，合理的错误处理机制可以帮助您捕获并处理各种可能的异常情况，提高应用程序的稳定性和可靠性，以下是一个简单的事务处理示例：

MySqlConnection conn = new MySqlConnection(connectionString);
MySqlTransaction transaction = null;
try
{
    // 打开连接
    conn.Open();
    // 开始事务
    transaction = conn.BeginTransaction();
    // 创建并执行SQL命令1（如插入记录）
    string sql1 = "INSERT INTO users (username, password, email) VALUES (@username, @password, @email)";
    MySqlCommand cmd1 = new MySqlCommand(sql1, conn, transaction);
    cmd1.Parameters.AddWithValue("@username", "jane_doe");
    cmd1.Parameters.AddWithValue("@password", "anotherpassword123");
    cmd1.Parameters.AddWithValue("@email", "jane.doe@example.com");
    cmd1.ExecuteNonQuery();
    // 创建并执行SQL命令2（如更新记录）
    string sql2 = "UPDATE users SET email = @newemail WHERE id = @userId";
    MySqlCommand cmd2 = new MySqlCommand(sql2, conn, transaction);
    cmd2.Parameters.AddWithValue("@newemail", "newemail@example.com");
    cmd2.Parameters.AddWithValue("@userId", 1); // 假设刚插入的记录ID为1
    cmd2.ExecuteNonQuery();
    // 如果一切顺利，则提交事务
    transaction.Commit();
    Console.