C# 访问MySQL数据库|极客笔记

C# 访问MySQL数据库

1. 简介

MySQL是一种开源的关系型数据库管理系统，它广泛用于Web应用程序的开发中。C#是一种通用的面向对象编程语言，可用于创建各种类型的应用程序，包括与数据库的交互。本文将详细介绍如何使用C#访问MySQL数据库。

2. 准备工作

在开始访问MySQL数据库之前，我们需要完成以下准备工作：

2.1 安装MySQL Connector/NET

MySQL Connector/NET是一个与MySQL服务器进行通信的.NET驱动程序。我们需要从MySQL官方网站（https://dev.mysql.com/downloads/connector/net/）下载适用于我们系统的Connector/NET，并安装在开发计算机上。

2.2 创建测试数据库和数据表

在MySQL中创建一个用于测试的数据库和数据表。我们可以使用MySQL Workbench等图形化工具或使用以下SQL语句创建测试数据库和数据表：

-- 创建数据库
CREATE DATABASE testdb;

-- 选择数据库
USE testdb;

-- 创建数据表
CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(50) NOT NULL,
    email VARCHAR(50) NOT NULL
);

3. 连接到MySQL数据库

在C#中，我们可以使用MySQL Connector/NET提供的MySqlConnection类来连接到MySQL数据库。以下是连接到MySQL数据库的示例代码：

using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;user=root;database=testdb;port=3306;password=mypassword;";

        MySqlConnection connection = new MySqlConnection(connectionString);

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

        Console.ReadLine();
    }
}

在上面的示例代码中，我们首先定义了一个连接字符串connectionString，其中包括了连接到MySQL数据库所需的信息，如服务器地址、用户名、密码等。然后，我们创建一个MySqlConnection对象，并使用连接字符串初始化该对象。接下来，我们调用Open()方法来打开与数据库的连接。如果连接成功，将会输出成功连接到MySQL数据库的消息；否则，将会输出连接失败的消息。最后，我们使用Close()方法关闭与数据库的连接。

4. 执行SQL查询

连接到MySQL数据库后，我们可以执行SQL查询来获取、插入、更新或删除数据。在C#中，我们可以使用MySqlCommand对象来执行SQL查询。以下是执行SQL查询的示例代码：

using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;user=root;database=testdb;port=3306;password=mypassword;";

        MySqlConnection connection = new MySqlConnection(connectionString);

        try
        {
            connection.Open();
            Console.WriteLine("成功连接到MySQL数据库！");

            // 查询数据
            string sql = "SELECT * FROM users";
            MySqlCommand command = new MySqlCommand(sql, connection);
            MySqlDataReader reader = command.ExecuteReader();

            while (reader.Read())
            {
                int id = reader.GetInt32("id");
                string name = reader.GetString("name");
                string email = reader.GetString("email");

                Console.WriteLine("ID: {0}, Name: {1}, Email: {2}", id, name, email);
            }

            reader.Close();
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("无法连接到MySQL数据库：" + ex.Message);
        }
        finally
        {
            connection.Close();
        }

        Console.ReadLine();
    }
}

在上面的示例代码中，我们首先定义了一个SQL查询语句sql，用于从users表中检索所有数据。然后，我们创建一个MySqlCommand对象，并将SQL查询和数据库连接对象传递给该对象。接下来，我们调用ExecuteReader()方法执行SQL查询，并使用MySqlDataReader对象读取结果集中的数据。最后，我们根据需要使用读取到的数据执行相应的操作。

5. 执行SQL修改

除了执行SQL查询之外，我们还可以执行SQL修改来插入、更新或删除数据库中的数据。在C#中，我们可以使用MySqlCommand对象的ExecuteNonQuery()方法来执行SQL修改。以下是执行SQL修改的示例代码：

using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;user=root;database=testdb;port=3306;password=mypassword;";

        MySqlConnection connection = new MySqlConnection(connectionString);

        try
        {
            connection.Open();
            Console.WriteLine("成功连接到MySQL数据库！");

            // 插入数据
            string sql = "INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com')";
            MySqlCommand command = new MySqlCommand(sql, connection);
            int rowsAffected = command.ExecuteNonQuery();

            Console.WriteLine("插入了 {0} 行数据。", rowsAffected);
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("无法连接到MySQL数据库：" + ex.Message);
        }
        finally
        {
            connection.Close();
        }

        Console.ReadLine();
    }
}

在上面的示例代码中，我们首先定义了一个SQL修改语句sql，用于向users表中插入一条数据。然后，我们创建一个MySqlCommand对象，并将SQL修改和数据库连接对象传递给该对象。接下来，我们调用ExecuteNonQuery()方法执行SQL修改，并使用返回的受影响行数来判断操作是否成功。