正文

揭秘.NET轻松连接MySQL：实战代码示例，助你快速上手数据库操作

/0 浏览量
0322

.NET框架是一个强大的开发平台，它提供了丰富的类库和工具，使得开发者可以轻松地构建各种类型的应用程序。MySQL是一个流行的开源关系型数据库管理系统，广泛应用于各种规模的组织中。本文将详细介绍如何在.NET中连接MySQL数据库，并提供实战代码示例，帮助读者快速上手数据库操作。

一、准备工作

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

  1. 安装.NET开发环境，如Visual Studio。
  2. 安装MySQL数据库，并创建一个数据库和表。
  3. 安装MySQL .NET驱动程序，如MySql.Data。

二、连接MySQL数据库

在.NET中连接MySQL数据库，首先需要使用MySQL .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("连接成功！");
            }
            catch (MySqlException ex)
            {
                Console.WriteLine("连接失败：" + ex.Message);
            }
        }
    }
}

在上面的代码中，我们首先创建了一个MySqlConnection对象，并传入连接字符串。连接字符串包含了MySQL数据库的连接信息，如服务器地址、端口号、数据库名、用户名和密码。接着，我们使用Open方法尝试打开连接。如果连接成功，控制台将输出“连接成功！”，否则输出错误信息。

三、执行数据库操作

连接到MySQL数据库后，我们可以执行各种数据库操作，如查询、插入、更新和删除。以下是一些常见的数据库操作示例：

1. 查询数据

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

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=testdb;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();
                    MySqlDataReader reader = command.ExecuteReader();

                    while (reader.Read())
                    {
                        Console.WriteLine("ID: {0}, Name: {1}", reader["id"], reader["name"]);
                    }
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("查询失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象的ExecuteReader方法执行查询操作，并使用MySqlDataReader对象遍历查询结果。

2. 插入数据

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

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

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(query, connection))
            {
                try
                {
                    connection.Open();
                    int result = command.ExecuteNonQuery();

                    if (result > 0)
                    {
                        Console.WriteLine("插入成功！");
                    }
                    else
                    {
                        Console.WriteLine("插入失败！");
                    }
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("插入失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象的ExecuteNonQuery方法执行插入操作。如果插入成功，result变量将大于0。

3. 更新数据

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

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=testdb;user=root;password=root;";
        string query = "UPDATE users SET age = 21 WHERE name = '张三'";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(query, connection))
            {
                try
                {
                    connection.Open();
                    int result = command.ExecuteNonQuery();

                    if (result > 0)
                    {
                        Console.WriteLine("更新成功！");
                    }
                    else
                    {
                        Console.WriteLine("更新失败！");
                    }
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("更新失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象的ExecuteNonQuery方法执行更新操作。

4. 删除数据

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

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=testdb;user=root;password=root;";
        string query = "DELETE FROM users WHERE name = '张三'";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(query, connection))
            {
                try
                {
                    connection.Open();
                    int result = command.ExecuteNonQuery();

                    if (result > 0)
                    {
                        Console.WriteLine("删除成功！");
                    }
                    else
                    {
                        Console.WriteLine("删除失败！");
                    }
                }
                catch (MySqlException ex)
                {
                    Console.WriteLine("删除失败：" + ex.Message);
                }
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象的ExecuteNonQuery方法执行删除操作。

四、总结

本文介绍了如何在.NET中连接MySQL数据库，并提供了查询、插入、更新和删除等数据库操作的实战代码示例。通过学习本文，读者可以快速上手.NET数据库操作，为后续开发打下坚实基础。

-- 展开阅读全文 --