C#与MySQL数据库连接与操作|极客笔记

C#与MySQL数据库连接与操作

在软件开发中，数据库是非常重要的一部分。MySQL是一个流行的关系型数据库管理系统，而C#是一种功能强大的编程语言。在本文中，我们将详细讨论如何在C#中连接和操作MySQL数据库。

准备工作

在开始之前，确保你已经完成了以下准备工作：

安装MySQL数据库
下载并安装MySQL Connector/NET驱动程序
创建一个MySQL数据库和表

连接到MySQL数据库

在C#中连接到MySQL数据库需要使用MySQL Connector/NET库。该库是MySQL官方提供的用于与C#语言集成的驱动程序。

首先，你需要在你的项目中引用MySql.Data.dll库。你可以从MySQL官方网站下载并安装MySQL Connector/NET驱动程序，然后在Visual Studio中添加对应的引用。

接下来，你需要添加以下命名空间：

using MySql.Data.MySqlClient;

然后，创建一个MySQL连接对象，并使用连接字符串连接到数据库：

string connectionString = "Server=localhost;Database=mydatabase;Uid=root;Pwd=password;";
MySqlConnection connection = new MySqlConnection(connectionString);

try
{
    connection.Open();
    Console.WriteLine("成功连接到MySQL数据库");
}
catch (MySqlException ex)
{
    Console.WriteLine("连接失败：" + ex.Message);
}
finally
{
    connection.Close();
}

在这个示例中，我们使用了一个简单的连接字符串，其中包含了MySQL服务器地址、数据库名称、用户名和密码。如果连接成功，会输出”成功连接到MySQL数据库”，否则会输出连接失败的错误信息。

执行SQL查询

一旦连接到了MySQL数据库，我们就可以执行SQL查询了。我们可以使用MySqlCommand对象来执行SQL语句。

下面是一个简单的示例，插入一条数据到数据库中：

string insertQuery = "INSERT INTO users (name, age) VALUES ('Alice', 25);";

MySqlCommand command = new MySqlCommand(insertQuery, connection);

try
{
    connection.Open();
    int rowsAffected = command.ExecuteNonQuery();
    Console.WriteLine("插入了" + rowsAffected + "行数据");
}
catch (MySqlException ex)
{
    Console.WriteLine("插入数据失败：" + ex.Message);
}
finally
{
    connection.Close();
}

在这个示例中，我们执行了一个插入语句，向名为users的表中插入了一条数据。如果插入成功，会输出”插入了1行数据”，否则会输出插入失败的错误信息。

查询数据

除了插入数据，我们还可以查询数据。下面是一个简单的示例，查询数据库中的所有用户：

string selectQuery = "SELECT * FROM users;";
MySqlCommand command = new MySqlCommand(selectQuery, connection);

try
{
    connection.Open();
    MySqlDataReader reader = command.ExecuteReader();

    while (reader.Read())
    {
        Console.WriteLine("ID: " + reader["id"] + ", Name: " + reader["name"] + ", Age: " + reader["age"]);
    }
}
catch (MySqlException ex)
{
    Console.WriteLine("查询数据失败：" + ex.Message);
}
finally
{
    connection.Close();
}

在这个示例中，我们执行了一个查询语句，获取名为users的表中所有用户的数据，并将其打印在控制台上。

更新数据

除了插入和查询数据，我们还可以更新数据。下面是一个简单的示例，更新数据库中某个用户的年龄：

string updateQuery = "UPDATE users SET age = 30 WHERE name = 'Alice';";
MySqlCommand command = new MySqlCommand(updateQuery, connection);

try
{
    connection.Open();
    int rowsAffected = command.ExecuteNonQuery();
    Console.WriteLine("更新了" + rowsAffected + "行数据");
}
catch (MySqlException ex)
{
    Console.WriteLine("更新数据失败：" + ex.Message);
}
finally
{
    connection.Close();
}

在这个示例中，我们执行了一个更新语句，将名为Alice的用户的年龄更新为30岁。如果更新成功，会输出”更新了1行数据”，否则会输出更新失败的错误信息。

删除数据

最后，我们还可以删除数据。下面是一个简单的示例，删除数据库中某个用户的记录：

string deleteQuery = "DELETE FROM users WHERE name = 'Alice';";
MySqlCommand command = new MySqlCommand(deleteQuery, connection);

try
{
    connection.Open();
    int rowsAffected = command.ExecuteNonQuery();
    Console.WriteLine("删除了" + rowsAffected + "行数据");
}
catch (MySqlException ex)
{
    Console.WriteLine("删除数据失败：" + ex.Message);
}
finally
{
    connection.Close();
}

在这个示例中，我们执行了一个删除语句，删除名为Alice的用户记录。如果删除成功，会输出”删除了1行数据”，否则会输出删除失败的错误信息。