C#连接MySQL|极客笔记

C#连接MySQL

在C#开发中，我们经常需要连接数据库来存储、查询数据。其中，MySQL是一个流行的关系型数据库管理系统，许多开发人员选择使用它来存储数据。在本文中，我们将详细介绍如何在C#中连接MySQL数据库。

准备工作

在开始连接MySQL数据库之前，我们需要确保以下几个准备工作已经完成：

安装MySQL数据库：首先需要安装MySQL数据库，可以到官方网站下载并按照指引安装。
安装MySQL连接器：在C#中连接MySQL数据库需要使用MySQL官方提供的连接器。可以在MySQL官方网站下载并安装。
创建一个数据库和表：在MySQL数据库中创建一个数据库和一张表，用于存储我们的数据。

连接MySQL数据库

在C#中连接MySQL数据库，我们需要使用MySQL连接器提供的一些类和方法。以下是一个简单的示例代码，演示了如何连接MySQL数据库并查询数据：

using System;
using MySql.Data.MySqlClient;

namespace ConnectMySQL
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "server=localhost;database=mydatabase;uid=root;pwd=password;";

            MySqlConnection connection = new MySqlConnection(connectionString);

            try
            {
                connection.Open();

                string query = "SELECT * FROM mytable";
                MySqlCommand command = new MySqlCommand(query, connection);

                MySqlDataReader reader = command.ExecuteReader();

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

                reader.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine("An error occurred: " + ex.Message);
            }
            finally
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们首先定义了一个连接字符串connectionString，其中包含了连接到MySQL数据库所需的信息，如服务器地址、数据库名、用户名和密码。然后创建了一个MySqlConnection对象connection，并调用Open()方法打开连接。

接着，我们定义了一个查询语句query，并创建了一个MySqlCommand对象command，并将查询语句和连接对象传入构造函数。然后调用ExecuteReader()方法执行查询，并通过MySqlDataReader对象reader读取查询结果。

最后，在一个while循环中遍历查询结果，并输出每行数据的指定列。最后关闭读取器和连接，并在catch块中处理可能出现的异常。

插入数据

除了查询数据，我们还经常需要往数据库中插入数据。以下是一个简单的示例代码，演示了如何插入数据到MySQL数据库中：

using System;
using MySql.Data.MySqlClient;

namespace ConnectMySQL
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "server=localhost;database=mydatabase;uid=root;pwd=password;";

            MySqlConnection connection = new MySqlConnection(connectionString);

            try
            {
                connection.Open();

                string query = "INSERT INTO mytable (column1, column2) VALUES (@value1, @value2)";
                MySqlCommand command = new MySqlCommand(query, connection);
                command.Parameters.AddWithValue("@value1", "value1");
                command.Parameters.AddWithValue("@value2", "value2");

                int rowsAffected = command.ExecuteNonQuery();

                Console.WriteLine("Rows affected: " + rowsAffected);
            }
            catch (Exception ex)
            {
                Console.WriteLine("An error occurred: " + ex.Message);
            }
            finally
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们定义了一个插入数据的查询语句query，并创建了一个MySqlCommand对象command。在执行插入操作之前，我们用Parameters.AddWithValue()方法添加了两个参数，并传入要插入的值。

然后通过ExecuteNonQuery()方法执行插入操作，并获取受影响的行数。最后输出受影响的行数，关闭连接，并在catch块中处理可能出现的异常。

更新和删除数据

类似地，我们也可以通过类似的方法来更新和删除数据。以下是一个示例代码，演示了如何更新和删除MySQL数据库中的数据：

更新数据

using System;
using MySql.Data.MySqlClient;

namespace ConnectMySQL
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "server=localhost;database=mydatabase;uid=root;pwd=password;";

            MySqlConnection connection = new MySqlConnection(connectionString);

            try
            {
                connection.Open();

                string query = "UPDATE mytable SET column1 = @newValue WHERE column2 = @condition";
                MySqlCommand command = new MySqlCommand(query, connection);
                command.Parameters.AddWithValue("@newValue", "newValue");
                command.Parameters.AddWithValue("@condition", "condition");

                int rowsAffected = command.ExecuteNonQuery();

                Console.WriteLine("Rows affected: " + rowsAffected);
            }
            catch (Exception ex)
            {
                Console.WriteLine("An error occurred: " + ex.Message);
            }
            finally
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们定义了一个更新数据的查询语句query，并创建了一个MySqlCommand对象command。在执行更新操作之前，我们用Parameters.AddWithValue()方法添加了两个参数，并传入更新的新值和更新的条件。

删除数据

using System;
using MySql.Data.MySqlClient;

namespace ConnectMySQL
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "server=localhost;database=mydatabase;uid=root;pwd=password;";

            MySqlConnection connection = new MySqlConnection(connectionString);

            try
            {
                connection.Open();

                string query = "DELETE FROM mytable WHERE column1 = @condition";
                MySqlCommand command = new MySqlCommand(query, connection);
                command.Parameters.AddWithValue("@condition", "condition");

                int rowsAffected = command.ExecuteNonQuery();

                Console.WriteLine("Rows affected: " + rowsAffected);
            }
            catch (Exception ex)
            {
                Console.WriteLine("An error occurred: " + ex.Message);
            }
            finally
            {
                connection.Close();
            }
        }
    }
}

在上面的代码中，我们定义了一个删除数据的查询语句query，并创建了一个MySqlCommand对象command。在执行删除操作之前，我们用Parameters.AddWithValue()方法添加了一个参数，并传入删除的条件。