正文

揭秘C#连接MySQL数据库的实战攻略，轻松上手，高效管理数据！

/0 浏览量
0322

引言

在.NET开发中，C#是常用的编程语言之一，而MySQL则是广泛使用的关系型数据库。将C#与MySQL数据库相结合，可以实现对数据的有效管理和操作。本文将详细介绍如何在C#中连接MySQL数据库，并展示如何进行数据的增删改查操作，帮助读者轻松上手，高效管理数据。

准备工作

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

  1. 安装MySQL数据库：从MySQL官网下载并安装MySQL数据库。
  2. 创建数据库和表：使用MySQL命令行工具或图形界面工具创建所需的数据库和表。
  3. 安装MySQL C#驱动程序：在项目中添加MySQL C#驱动程序引用，例如MySql.Data。

连接MySQL数据库

以下是一个使用C#连接MySQL数据库的示例代码：

using System;
using MySql.Data.MySqlClient;

public class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;port=3306;database=your_database;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对象，并通过connectionString指定了连接信息。然后，我们尝试打开连接，并在成功或失败时输出相应的信息。

数据库操作

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

查询数据

以下是一个查询数据库中数据的示例代码：

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

public class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;port=3306;database=your_database;user=root;password=root;";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand command = new MySqlCommand("SELECT * FROM your_table", connection);

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

            while (reader.Read())
            {
                Console.WriteLine(reader["column_name"].ToString());
            }
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("查询失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们首先创建了一个MySqlCommand对象，并通过commandText指定了查询语句。然后，我们执行查询并遍历结果集，输出每条记录的值。

插入数据

以下是一个向数据库中插入数据的示例代码：

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

public class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;port=3306;database=your_database;user=root;password=root;";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand command = new MySqlCommand("INSERT INTO your_table (column1, column2) VALUES (@value1, @value2)", connection);

        command.Parameters.AddWithValue("@value1", "value1");
        command.Parameters.AddWithValue("@value2", "value2");

        try
        {
            connection.Open();
            int result = command.ExecuteNonQuery();

            if (result > 0)
            {
                Console.WriteLine("插入成功！");
            }
            else
            {
                Console.WriteLine("插入失败！");
            }
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("插入失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们首先创建了一个MySqlCommand对象，并通过commandText指定了插入语句。然后，我们添加了两个参数，并使用Parameters.AddWithValue方法设置了参数值。最后，我们执行插入操作并输出结果。

更新数据

以下是一个更新数据库中数据的示例代码：

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

public class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;port=3306;database=your_database;user=root;password=root;";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand command = new MySqlCommand("UPDATE your_table SET column1 = @value1 WHERE column2 = @value2", connection);

        command.Parameters.AddWithValue("@value1", "new_value1");
        command.Parameters.AddWithValue("@value2", "value2");

        try
        {
            connection.Open();
            int result = command.ExecuteNonQuery();

            if (result > 0)
            {
                Console.WriteLine("更新成功！");
            }
            else
            {
                Console.WriteLine("更新失败！");
            }
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("更新失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们首先创建了一个MySqlCommand对象，并通过commandText指定了更新语句。然后，我们添加了两个参数，并使用Parameters.AddWithValue方法设置了参数值。最后，我们执行更新操作并输出结果。

删除数据

以下是一个删除数据库中数据的示例代码：

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

public class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;port=3306;database=your_database;user=root;password=root;";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand command = new MySqlCommand("DELETE FROM your_table WHERE column2 = @value2", connection);

        command.Parameters.AddWithValue("@value2", "value2");

        try
        {
            connection.Open();
            int result = command.ExecuteNonQuery();

            if (result > 0)
            {
                Console.WriteLine("删除成功！");
            }
            else
            {
                Console.WriteLine("删除失败！");
            }
        }
        catch (MySqlException ex)
        {
            Console.WriteLine("删除失败：" + ex.Message);
        }
        finally
        {
            if (connection.State == System.Data.ConnectionState.Open)
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们首先创建了一个MySqlCommand对象，并通过commandText指定了删除语句。然后，我们添加了一个参数，并使用Parameters.AddWithValue方法设置了参数值。最后，我们执行删除操作并输出结果。

总结

本文详细介绍了如何在C#中连接MySQL数据库，并展示了如何进行数据的增删改查操作。通过本文的学习，读者可以轻松上手，高效管理MySQL数据库。在实际开发中，请根据具体需求调整代码，确保数据安全和性能。

-- 展开阅读全文 --