正文

揭秘Net框架高效操作MySQL数据库：实战示例代码全解析

/0 浏览量
0322

MySQL是一种流行的开源关系型数据库管理系统，而.NET框架是微软推出的一个强大的开发平台，广泛应用于各种Windows桌面和服务器应用程序的开发。在这篇文章中，我们将探讨如何在.NET框架中高效地操作MySQL数据库，并提供实战示例代码进行全解析。

准备工作

在开始之前，确保你已经以下准备工作：

  1. 安装.NET框架环境。
  2. 安装MySQL数据库服务器。
  3. 安装MySQL .NET驱动程序（例如：MySql.Data）。

一、连接MySQL数据库

在.NET中连接MySQL数据库，首先需要使用MySql.Data命名空间提供的MySqlConnection类。

using System;
using MySql.Data.MySqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;port=3306;database=mydatabase;user=root;password=root;";
        MySqlConnection connection = new MySqlConnection(connectionString);

        try
        {
            connection.Open();
            Console.WriteLine("连接成功！");
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("连接失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们首先定义了连接字符串，包括服务器地址、端口、数据库名、用户名和密码。然后创建一个MySqlConnection对象，并尝试打开连接。如果连接成功，将输出“连接成功！”；如果连接失败，将输出错误信息。

二、执行SQL语句

在连接成功后，我们可以使用MySqlCommand类执行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;";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand command = new MySqlCommand("SELECT * FROM users", connection);

        try
        {
            connection.Open();
            MySqlDataReader reader = command.ExecuteReader();

            while (reader.Read())
            {
                Console.WriteLine("ID: " + reader["id"] + ", Name: " + reader["name"]);
            }
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("执行失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们定义了一个SQL查询语句，用于从users表中获取所有记录。然后，我们创建一个MySqlCommand对象，将SQL语句传递给它，并打开数据库连接。使用MySqlDataReader读取查询结果，并遍历输出每条记录。

三、执行SQL语句（非查询）

如果你要执行INSERT、UPDATE、DELETE等SQL语句，可以使用MySqlCommand对象的ExecuteNonQuery方法。

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;";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand command = new MySqlCommand("INSERT INTO users (name) VALUES ('John Doe')", connection);

        try
        {
            connection.Open();
            int result = command.ExecuteNonQuery();
            Console.WriteLine("影响行数：" + result);
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("执行失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们执行了一个INSERT语句，向users表中插入一条新记录。使用ExecuteNonQuery方法执行该语句，并获取影响的行数。

四、参数化查询

在实际开发中，为了防止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;";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand command = new MySqlCommand("INSERT INTO users (name) VALUES (@name)", connection);

        // 添加参数
        command.Parameters.AddWithValue("@name", "Jane Doe");

        try
        {
            connection.Open();
            int result = command.ExecuteNonQuery();
            Console.WriteLine("影响行数：" + result);
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("执行失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们使用MySqlCommand对象的Parameters集合添加了一个参数@name，并将其值设置为"Jane Doe"。通过这种方式，我们可以在执行SQL语句时防止SQL注入攻击。

总结

本文介绍了.NET框架中操作MySQL数据库的几种常见方法，包括连接数据库、执行SQL语句、参数化查询等。通过这些示例代码，你可以快速上手.NET与MySQL数据库的交互。在实际开发中，请根据具体需求选择合适的方法，并注意代码的安全性和性能。

-- 展开阅读全文 --