C# MySQL 查询

在C#中连接和查询MySQL数据库是很常见的任务。这可以通过使用MySQL连接器和执行SQL语句来实现。本文将介绍如何在C#中进行MySQL查询的基本步骤。

准备工作

在开始之前，请确保已经安装了MySQL数据库，并且已经在C#项目中添加了MySQL连接器。可以使用NuGet包管理器来搜索和安装MySQL连接器。

PM> Install-Package MySql.Data

在项目的代码文件中添加以下命名空间：

using MySql.Data.MySqlClient;

连接到MySQL数据库

要连接到MySQL数据库，需要提供连接字符串，其中包含必要的连接信息，例如服务器地址、用户名、密码和数据库名称。以下是一个连接到MySQL数据库的示例代码：

string connectionString = "server=localhost;user=root;database=mydatabase;password=mypassword";
using (MySqlConnection connection = new MySqlConnection(connectionString))
{
    connection.Open();
    // 执行查询
}

执行查询

一旦连接到数据库，可以使用MySqlCommand对象执行查询语句。以下是一个执行SELECT语句并读取查询结果的示例代码：

string query = "SELECT * FROM customers";
using (MySqlCommand command = new MySqlCommand(query, connection))
{
    using (MySqlDataReader reader = command.ExecuteReader())
    {
        while (reader.Read())
        {
            // 处理查询结果
        }
    }
}

在查询结果中，可以使用reader对象读取特定的列值。例如，如果查询结果有一个名为name的列，可以使用以下代码读取它的值：

string name = reader.GetString("name");

参数化查询

为了防止SQL注入攻击，建议使用参数化查询。参数化查询可以将值作为查询的参数传递，而不是直接将值嵌入到查询字符串中。以下是一个使用参数化查询的示例：

string query = "SELECT * FROM customers WHERE age > @age";
using (MySqlCommand command = new MySqlCommand(query, connection))
{
    command.Parameters.AddWithValue("@age", 18);
    // 执行查询
}

在上述示例中，@age是一个参数占位符，可以使用command.Parameters.AddWithValue()方法为其提供值。

错误处理

在执行MySQL查询时，可能会出现错误。为了捕获和处理这些错误，使用try-catch语句块。以下是一个处理MySQL查询错误的示例：

try
{
    // 执行查询
}
catch (MySqlException ex)
{
    Console.WriteLine("MySQL查询错误：" + ex.Message);
}

在catch块中，可以对MySQL异常进行适当的处理。

总结

通过使用MySQL连接器和执行SQL语句，可以在C#中连接和查询MySQL数据库。本文提供了一个基本的步骤指南，介绍了连接到数据库、执行查询、参数化查询和错误处理等重要知识点。希望这篇文章对程序员在C#中进行MySQL查询有所帮助。

注意：以上示例代码仅供参考，请根据具体的需求和场景进行适当的修改和优化。

参考链接：

• MySQL Connector/NET Developer Guide