正文

轻松掌握：Net连接MySQL实战示例代码详解

/0 浏览量
0322

引言

在.NET开发中，与MySQL数据库的连接是常见的需求。本文将详细介绍如何使用.NET连接到MySQL数据库，并提供一个实战示例代码，帮助读者轻松掌握这一技能。

准备工作

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

  1. 安装MySQL数据库并启动服务。
  2. 创建一个MySQL数据库和一个表，用于后续的示例操作。
  3. 安装MySQL .NET驱动程序，例如MySql.Data。

连接MySQL数据库

在.NET中，我们可以使用MySqlConnection类来连接MySQL数据库。以下是一个简单的连接示例：

using System;
using MySql.Data.MySqlClient;

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

在上面的代码中，我们首先创建了一个connectionString字符串，其中包含了连接MySQL数据库所需的所有信息，如服务器地址、端口号、数据库名、用户名和密码。然后，我们使用MySqlConnection类创建了一个连接对象，并通过Open方法尝试打开连接。

执行SQL查询

一旦连接成功，我们就可以执行SQL查询来操作数据库。以下是一个执行查询的示例：

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=testdb;user=root;password=root;";
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                Console.WriteLine("连接成功！");

                string query = "SELECT * FROM users";
                using (MySqlCommand command = new MySqlCommand(query, connection))
                {
                    using (MySqlDataReader reader = command.ExecuteReader())
                    {
                        while (reader.Read())
                        {
                            Console.WriteLine($"ID: {reader["id"]}, Name: {reader["name"]}");
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("连接失败：" + ex.Message);
            }
        }
    }
}

在上面的代码中，我们首先创建了一个SQL查询字符串，然后使用MySqlCommand类创建了一个命令对象。通过调用ExecuteReader方法，我们可以获取一个MySqlDataReader对象，用于遍历查询结果。

执行SQL更新

除了查询，我们还可以使用.NET连接MySQL数据库来执行更新操作。以下是一个更新记录的示例：

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=testdb;user=root;password=root;";
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                Console.WriteLine("连接成功！");

                string query = "UPDATE users SET name = 'John Doe' WHERE id = 1";
                using (MySqlCommand command = new MySqlCommand(query, connection))
                {
                    int rowsAffected = command.ExecuteNonQuery();
                    Console.WriteLine($"更新了 {rowsAffected} 条记录。");
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("连接失败：" + ex.Message);
            }
        }
    }
}

在上面的代码中，我们创建了一个更新SQL语句，并通过调用ExecuteNonQuery方法来执行更新操作。这个方法返回受影响的行数，我们可以根据这个值来判断更新操作是否成功。

总结

通过本文的介绍，相信读者已经掌握了如何使用.NET连接MySQL数据库，并能够执行查询和更新操作。在实际开发中，请根据具体需求调整连接字符串和SQL语句，以确保应用程序的正常运行。

-- 展开阅读全文 --