正文

掌握.NET，轻松玩转MySQL数据库查询秘籍揭秘

/0 浏览量
0322

.NET框架是微软开发的一种跨平台的应用程序开发框架，而MySQL是一种流行的开源关系型数据库管理系统。在.NET应用程序中，与MySQL数据库进行交互是一项基本技能。本文将详细揭秘如何在.NET中轻松玩转MySQL数据库查询。

一、环境准备

在开始之前，请确保以下环境已准备就绪：

  1. 安装.NET SDK：根据你的.NET版本安装相应的SDK。
  2. 安装MySQL数据库：从MySQL官网下载并安装MySQL数据库。
  3. 安装MySQL Connector/NET：MySQL Connector/NET是MySQL的官方.NET驱动程序，用于在.NET应用程序中连接到MySQL数据库。

二、连接MySQL数据库

在.NET应用程序中连接到MySQL数据库，首先需要创建一个MySqlConnection对象。

using System;
using MySql.Data.MySqlClient;

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

三、执行查询

连接到数据库后，可以使用MySqlCommand对象执行查询。

1. 执行SELECT查询

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

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=test;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(reader["username"] + " " + reader["password"]);
                        }
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine("查询失败：" + ex.Message);
                }
            }
        }
    }
}

2. 执行INSERT查询

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

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=test;user=root;password=root;";
        string query = "INSERT INTO users (username, password) VALUES ('newuser', 'newpassword')";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(query, connection))
            {
                try
                {
                    connection.Open();
                    int result = command.ExecuteNonQuery();
                    Console.WriteLine("影响行数：" + result);
                }
                catch (Exception ex)
                {
                    Console.WriteLine("插入失败：" + ex.Message);
                }
            }
        }
    }
}

3. 执行UPDATE查询

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

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=test;user=root;password=root;";
        string query = "UPDATE users SET password = 'newpassword' WHERE username = 'newuser'";

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

4. 执行DELETE查询

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

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=test;user=root;password=root;";
        string query = "DELETE FROM users WHERE username = 'newuser'";

        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(query, connection))
            {
                try
                {
                    connection.Open();
                    int result = command.ExecuteNonQuery();
                    Console.WriteLine("影响行数：" + result);
                }
                catch (Exception ex)
                {
                    Console.WriteLine("删除失败：" + ex.Message);
                }
            }
        }
    }
}

四、总结

通过以上步骤，你可以在.NET应用程序中轻松玩转MySQL数据库查询。在实际开发中，你可以根据需要调整查询语句和参数，以满足不同的业务需求。希望本文能帮助你更好地掌握.NET与MySQL数据库的交互技巧。

-- 展开阅读全文 --