正文

揭秘.NET连接MySQL：实战代码示例，轻松实现跨数据库交互

/0 浏览量
0322

.NET框架是一个功能强大的开发平台，它提供了丰富的API来连接和操作各种数据库。在本篇文章中，我们将深入探讨如何使用.NET连接到MySQL数据库，并提供详细的代码示例，帮助开发者轻松实现跨数据库交互。

准备工作

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

  1. 安装MySQL数据库并配置好环境。
  2. 安装.NET开发环境，包括.NET Core SDK或.NET Framework SDK。
  3. 在项目中添加MySQL驱动程序，如MySql.Data。

连接到MySQL数据库

在.NET中，可以使用MySqlConnection类来创建到MySQL数据库的连接。以下是一个基本的连接示例：

using System;
using MySql.Data.MySqlClient;

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

在上面的代码中，我们首先定义了一个connectionString，其中包含了MySQL数据库的连接信息，如服务器地址、端口号、数据库名、用户名和密码。然后，我们创建了一个MySqlConnection对象，并尝试打开连接。

执行SQL查询

连接到数据库后，我们可以执行SQL查询来检索或更新数据。以下是一个执行SQL查询的示例：

using System;
using System.Data;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=mydatabase;user=root;password=root;";
        string query = "SELECT * FROM users";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(query, connection))
            {
                try
                {
                    connection.Open();
                    using (MySqlDataReader reader = command.ExecuteReader())
                    {
                        while (reader.Read())
                        {
                            Console.WriteLine($"ID: {reader["id"]}, Name: {reader["name"]}");
                        }
                    }
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("查询失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们定义了一个SQL查询字符串query，并使用MySqlCommand对象执行这个查询。然后，我们使用MySqlDataReader读取查询结果，并打印出来。

执行SQL更新

除了查询数据，我们还可以使用.NET来执行SQL更新语句，如INSERT、UPDATE和DELETE。以下是一个执行SQL更新语句的示例：

using System;
using System.Data;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=mydatabase;user=root;password=root;";
        string query = "INSERT INTO users (name, age) VALUES ('张三', 18)";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(query, connection))
            {
                try
                {
                    connection.Open();
                    int rowsAffected = command.ExecuteNonQuery();
                    Console.WriteLine("受影响的行数：" + rowsAffected);
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("更新失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象的ExecuteNonQuery方法来执行更新操作。这个方法返回受影响的行数，我们可以根据这个值来判断更新操作是否成功。

总结

通过本篇文章的讲解和代码示例，相信您已经掌握了如何在.NET中连接到MySQL数据库，并执行基本的查询和更新操作。在实际开发中，您可以根据自己的需求对代码进行修改和扩展。希望这篇文章能够帮助您在跨数据库交互方面取得更好的成果。

-- 展开阅读全文 --