正文

轻松入门：Net环境下MySQL数据库操作实战代码解析

/0 浏览量
0322

MySQL 是一款流行的开源关系型数据库管理系统，而 .NET 是一个强大的开发平台，广泛应用于 Windows 应用程序的开发。本文将带您入门，通过实战代码解析，学习在 .NET 环境下如何进行 MySQL 数据库的操作。

1. 准备工作

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

  • 安装 .NET 开发环境。
  • 安装 MySQL 数据库并创建数据库和表。
  • 安装 MySQL .NET Connector（MySQL 的 .NET 数据库驱动）。

2. 连接 MySQL 数据库

首先，我们需要创建一个 SqlConnection 对象来连接 MySQL 数据库。

using System;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                Console.WriteLine("数据库连接成功！");
            }
            catch (Exception ex)
            {
                Console.WriteLine("数据库连接失败：" + ex.Message);
            }
        }
    }
}

在上面的代码中，我们使用 SqlConnection 类创建了一个连接字符串，其中包含了服务器地址、数据库名、用户名和密码。然后，我们尝试打开连接，如果成功，则输出“数据库连接成功！”，否则输出错误信息。

3. 查询数据

查询数据是数据库操作中最常见的一种。以下是一个查询示例：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string query = "SELECT * FROM yourTable";
            SqlCommand command = new SqlCommand(query, connection);
            SqlDataReader reader = command.ExecuteReader();

            while (reader.Read())
            {
                Console.WriteLine(reader["column1"].ToString() + " " + reader["column2"].ToString());
            }

            reader.Close();
        }
    }
}

在上面的代码中，我们首先创建了一个 SqlCommand 对象，并指定了要执行的 SQL 查询语句。然后，我们使用 ExecuteReader 方法执行查询，并通过 SqlDataReader 对象遍历结果集，输出查询到的数据。

4. 插入数据

以下是一个插入数据的示例：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string query = "INSERT INTO yourTable (column1, column2) VALUES (@value1, @value2)";
            SqlCommand command = new SqlCommand(query, connection);
            command.Parameters.AddWithValue("@value1", "value1");
            command.Parameters.AddWithValue("@value2", "value2");

            int result = command.ExecuteNonQuery();
            if (result > 0)
            {
                Console.WriteLine("数据插入成功！");
            }
            else
            {
                Console.WriteLine("数据插入失败！");
            }
        }
    }
}

在上面的代码中，我们创建了一个 SqlCommand 对象，并指定了要执行的 SQL 插入语句。然后，我们使用 Parameters.AddWithValue 方法为查询参数赋值，并使用 ExecuteNonQuery 方法执行插入操作。如果插入成功，则输出“数据插入成功！”，否则输出“数据插入失败！”。

5. 更新数据

以下是一个更新数据的示例：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string query = "UPDATE yourTable SET column1 = @value1 WHERE column2 = @value2";
            SqlCommand command = new SqlCommand(query, connection);
            command.Parameters.AddWithValue("@value1", "newValue1");
            command.Parameters.AddWithValue("@value2", "value2");

            int result = command.ExecuteNonQuery();
            if (result > 0)
            {
                Console.WriteLine("数据更新成功！");
            }
            else
            {
                Console.WriteLine("数据更新失败！");
            }
        }
    }
}

在上面的代码中，我们创建了一个 SqlCommand 对象，并指定了要执行的 SQL 更新语句。然后，我们使用 Parameters.AddWithValue 方法为查询参数赋值，并使用 ExecuteNonQuery 方法执行更新操作。如果更新成功，则输出“数据更新成功！”，否则输出“数据更新失败！”。

6. 删除数据

以下是一个删除数据的示例：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string query = "DELETE FROM yourTable WHERE column2 = @value2";
            SqlCommand command = new SqlCommand(query, connection);
            command.Parameters.AddWithValue("@value2", "value2");

            int result = command.ExecuteNonQuery();
            if (result > 0)
            {
                Console.WriteLine("数据删除成功！");
            }
            else
            {
                Console.WriteLine("数据删除失败！");
            }
        }
    }
}

在上面的代码中，我们创建了一个 SqlCommand 对象，并指定了要执行的 SQL 删除语句。然后，我们使用 Parameters.AddWithValue 方法为查询参数赋值，并使用 ExecuteNonQuery 方法执行删除操作。如果删除成功，则输出“数据删除成功！”，否则输出“数据删除失败！”。

-- 展开阅读全文 --