正文

揭秘C#与MySQL高效连接：实战示例，轻松实现数据库交互

/0 浏览量
0322

在开发过程中，C#与MySQL数据库的连接是一个基础且重要的环节。本文将详细介绍如何高效地使用C#连接到MySQL数据库，并通过实战示例展示如何轻松实现数据库交互。

1. 准备工作

在开始之前，请确保您已安装以下内容：

  • .NET环境：您可以使用Visual Studio或其他IDE进行开发。
  • MySQL数据库：您可以在MySQL官方网站下载并安装MySQL数据库。
  • MySQL Connector/NET：这是MySQL官方提供的C#驱动程序，用于在C#应用程序中与MySQL数据库进行交互。

2. 创建MySQL数据库和表

首先，您需要在MySQL数据库中创建一个数据库和一张表。以下是一个简单的SQL语句示例：

CREATE DATABASE TestDB;
USE TestDB;

CREATE TABLE Students (
    ID INT PRIMARY KEY AUTO_INCREMENT,
    Name VARCHAR(50),
    Age INT
);

3. 添加MySQL Connector/NET引用

在您的C#项目中，您需要添加MySQL Connector/NET引用。以下是在Visual Studio中添加引用的步骤：

  1. 在Visual Studio中，打开您的C#项目。
  2. 在“解决方案资源管理器”中，右键点击“引用”，然后选择“添加引用”。
  3. 在“引用管理器”中，找到“MySQL Connector/NET”并勾选它。
  4. 点击“确定”完成引用添加。

4. 连接MySQL数据库

以下是一个简单的示例，展示了如何使用C#连接到MySQL数据库：

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;user=root;password=root;";
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                Console.WriteLine("连接成功！");
            }
            catch (MySqlException ex)
            {
                Console.WriteLine("连接失败：" + ex.Message);
            }
        }
    }
}

在上面的代码中，我们首先创建了一个MySqlConnection对象，并将其连接字符串设置为MySQL数据库的连接信息。然后，我们尝试打开连接，并在成功或失败时输出相应的信息。

5. 实现数据库交互

现在我们已经成功连接到MySQL数据库，接下来将展示如何进行基本的数据库交互，包括插入、查询、更新和删除数据。

5.1 插入数据

以下是一个插入数据的示例：

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;user=root;password=root;";
        string insertQuery = "INSERT INTO Students (Name, Age) VALUES ('张三', 20)";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(insertQuery, connection))
            {
                try
                {
                    connection.Open();
                    command.ExecuteNonQuery();
                    Console.WriteLine("数据插入成功！");
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("数据插入失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象执行了一个插入数据的SQL语句。如果成功，我们将在控制台输出“数据插入成功！”，否则输出错误信息。

5.2 查询数据

以下是一个查询数据的示例：

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;user=root;password=root;";
        string selectQuery = "SELECT * FROM Students";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(selectQuery, connection))
            {
                using (MySqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine($"ID: {reader["ID"]}, Name: {reader["Name"]}, Age: {reader["Age"]}");
                    }
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象执行了一个查询数据的SQL语句，并通过MySqlDataReader对象遍历结果集，输出每条记录的详细信息。

5.3 更新数据

以下是一个更新数据的示例：

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;user=root;password=root;";
        string updateQuery = "UPDATE Students SET Age = 21 WHERE Name = '张三'";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(updateQuery, connection))
            {
                try
                {
                    connection.Open();
                    command.ExecuteNonQuery();
                    Console.WriteLine("数据更新成功！");
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("数据更新失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象执行了一个更新数据的SQL语句，如果成功，我们将在控制台输出“数据更新成功！”，否则输出错误信息。

5.4 删除数据

以下是一个删除数据的示例：

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;user=root;password=root;";
        string deleteQuery = "DELETE FROM Students WHERE Name = '张三'";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(deleteQuery, connection))
            {
                try
                {
                    connection.Open();
                    command.ExecuteNonQuery();
                    Console.WriteLine("数据删除成功！");
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("数据删除失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象执行了一个删除数据的SQL语句，如果成功，我们将在控制台输出“数据删除成功！”，否则输出错误信息。

6. 总结

本文介绍了如何使用C#连接到MySQL数据库，并通过实战示例展示了如何轻松实现数据库交互。通过阅读本文，您应该已经掌握了C#与MySQL数据库的基本操作。在实际开发过程中，您可以根据需要调整和优化这些示例代码，以满足您的具体需求。

-- 展开阅读全文 --