连接MySQL数据库|极客笔记

连接MySQL数据库

在开发过程中，我们经常需要和数据库进行交互，而MySQL是一个广泛使用的关系型数据库管理系统，因此学会如何连接MySQL数据库是非常重要的。本文将详细介绍在C#中如何连接MySQL数据库，并进行常见数据库操作。

安装MySQL Connector/Net

在C#中连接MySQL数据库需要使用MySQL官方提供的Connector/Net，首先我们需要下载并安装这个组件。打开 MySQL官方网站，选择对应的版本进行下载安装。

创建MySQL数据库

在进行数据库连接之前，我们首先需要有一个MySQL数据库。可以通过MySQL Workbench等工具新建一个数据库，示例代码中我们将使用一个名为test的数据库。

创建C#项目并引入MySQL Connector/Net

接下来我们创建一个C#项目，例如一个控制台应用。在Visual Studio中，右击项目名称，选择“管理NuGet程序包”，搜索MySql.Data并安装，这样就可以引入MySQL Connector/Net库到项目中。

连接MySQL数据库

编写C#代码连接MySQL数据库，首先需要引入MySQL Connector/Net库：

using MySql.Data.MySqlClient;

接下来可以编写连接数据库的代码：

string connectionString = "server=localhost;user=root;database=test;port=3306;password=yourpassword";
MySqlConnection connection = new MySqlConnection(connectionString);
try
{
    connection.Open();
    Console.WriteLine("MySQL数据库连接成功！");
}
catch (MySqlException ex)
{
    Console.WriteLine("MySQL数据库连接失败：" + ex.Message);
}
finally
{
    connection.Close();
}

在上面的代码中，我们建立了一个名为test的数据库连接，并打印出连接成功的消息。需要注意的是，connectionString中的参数需要根据实际情况进行修改，比如数据库服务器地址、用户名、密码等。

执行SQL查询

连接成功后，我们可以执行SQL查询操作。以下是一个简单的查询示例：

string query = "SELECT * FROM users";
MySqlCommand command = new MySqlCommand(query, connection);
try
{
    MySqlDataReader reader = command.ExecuteReader();
    while (reader.Read())
    {
        Console.WriteLine(reader["id"] + " " + reader["name"]);
    }
    reader.Close();
}
catch (MySqlException ex)
{
    Console.WriteLine("SQL查询错误：" + ex.Message);
}

以上代码会查询users表中的所有记录，并打印出每条记录的id和name字段的值。

执行SQL插入操作

除了查询，我们还可以执行SQL插入操作。以下是一个简单的插入示例：

string query = "INSERT INTO users (name, age) VALUES ('Alice', 25)";
MySqlCommand command = new MySqlCommand(query, connection);
try
{
    int rowsAffected = command.ExecuteNonQuery();
    Console.WriteLine("插入成功，影响行数：" + rowsAffected);
}
catch (MySqlException ex)
{
    Console.WriteLine("SQL插入错误：" + ex.Message);
}

以上代码会向users表中插入一个名为Alice、年龄为25的记录，并打印出影响的行数。

执行SQL更新操作

类似地，我们还可以执行SQL更新操作。以下是一个简单的更新示例：

string query = "UPDATE users SET age = 26 WHERE name = 'Alice'";
MySqlCommand command = new MySqlCommand(query, connection);
try
{
    int rowsAffected = command.ExecuteNonQuery();
    Console.WriteLine("更新成功，影响行数：" + rowsAffected);
}
catch (MySqlException ex)
{
    Console.WriteLine("SQL更新错误：" + ex.Message);
}

以上代码会更新users表中名为Alice的记录的年龄为26，并打印出影响的行数。

执行SQL删除操作

最后，我们还可以执行SQL删除操作。以下是一个简单的删除示例：

string query = "DELETE FROM users WHERE name = 'Alice'";
MySqlCommand command = new MySqlCommand(query, connection);
try
{
    int rowsAffected = command.ExecuteNonQuery();
    Console.WriteLine("删除成功，影响行数：" + rowsAffected);
}
catch (MySqlException ex)
{
    Console.WriteLine("SQL删除错误：" + ex.Message);
}

以上代码会从users表中删除名为Alice的记录，并打印出影响的行数。