C#连接MySQL|极客笔记

C#连接MySQL

介绍

在软件开发中，连接数据库是一项非常重要的任务。而作为全球流行的关系型数据库管理系统之一，MySQL被广泛应用于各种应用程序中。本文将详细介绍如何使用C#编程语言来连接MySQL数据库，并进行常见的操作。

环境准备

在开始之前，我们需要确保已经具备以下环境准备：

安装MySQL数据库：确保计算机上已经安装了MySQL数据库，并记住数据库的连接信息（例如IP地址、端口、用户名和密码等）。
安装Visual Studio：本文以Visual Studio作为开发工具，确保已经安装了适用于C#开发的Visual Studio版本。
安装MySQL Connector/NET：这是一个官方提供的MySQL数据库连接器，可在C#程序中使用。请前往MySQL官方网站下载并安装合适的版本。

创建连接

在C#中连接MySQL数据库，需要使用MySQL Connector/NET提供的命名空间 MySql.Data.MySqlClient。以下示例演示了如何创建一个MySQL连接：

using MySql.Data.MySqlClient;

string connectionString = "Server=localhost;Port=3306;Database=myDatabase;Uid=myUsername;Pwd=myPassword;";
MySqlConnection connection = new MySqlConnection(connectionString);
connection.Open();

// 连接已经创建，可以进行其他操作

connection.Close();

在上面的示例中，我们先定义了一个 connectionString 变量，该变量指定了连接MySQL数据库需要的信息，如服务器地址、端口、数据库名称、用户名和密码等。为了连接数据库，我们创建了一个 MySqlConnection 对象，并将连接字符串作为参数传递给它的构造函数。然后，我们通过调用 Open() 方法打开连接，连接准备就绪后可以进行后续操作。连接使用完毕后，通过调用 Close() 方法关闭连接。

执行SQL查询

连接到MySQL数据库后，我们可以执行各种SQL查询，例如查询、插入、更新和删除等。下面的示例演示了如何执行一个简单的查询，并输出查询结果：

using MySql.Data.MySqlClient;

string connectionString = "Server=localhost;Port=3306;Database=myDatabase;Uid=myUsername;Pwd=myPassword;";
MySqlConnection connection = new MySqlConnection(connectionString);
connection.Open();

string sql = "SELECT * FROM myTable";
MySqlCommand command = new MySqlCommand(sql, connection);
MySqlDataReader reader = command.ExecuteReader();

while (reader.Read())
{
    Console.WriteLine(reader.GetString(0));
    Console.WriteLine(reader.GetString(1));
    // ...
}

reader.Close();
connection.Close();

在上面的示例中，我们首先定义了一个SQL查询语句 SELECT * FROM myTable，该语句用于查询名为 myTable 的表的所有记录。然后，我们创建了一个 MySqlCommand 对象，并将SQL查询语句和连接对象作为参数传递给它的构造函数。通过调用 ExecuteReader() 方法，我们执行了查询，并返回一个 MySqlDataReader 对象，该对象可以用于逐行读取查询结果。

在 while 循环中，我们可以使用 GetInt32()、GetString() 等方法从读取器中提取特定列的值，并进行相应的操作。在上面的示例中，我们假设查询结果的第一列和第二列都是字符串类型，因此使用了 GetString() 方法。

最后，我们通过调用 Close() 方法关闭读取器和连接。

执行SQL语句

除了查询之外，我们还可以执行其他类型的SQL语句，例如插入、更新和删除等。以下示例演示了如何执行一个插入语句：

using MySql.Data.MySqlClient;

string connectionString = "Server=localhost;Port=3306;Database=myDatabase;Uid=myUsername;Pwd=myPassword;";
MySqlConnection connection = new MySqlConnection(connectionString);
connection.Open();

string sql = "INSERT INTO myTable (Column1, Column2) VALUES ('Value1', 'Value2')";
MySqlCommand command = new MySqlCommand(sql, connection);
command.ExecuteNonQuery();

connection.Close();

在上面的示例中，我们定义了一个插入语句 INSERT INTO myTable (Column1, Column2) VALUES ('Value1', 'Value2')，该语句将向名为 myTable 的表中插入一行数据，其中 Column1 和 Column2 是表中的列名，'Value1' 和 'Value2' 是要插入的值。

然后，我们创建了一个 MySqlCommand 对象，并将插入语句和连接对象作为参数传递给它的构造函数。通过调用 ExecuteNonQuery() 方法，我们执行了插入语句，并返回受影响的行数（即插入的行数）。

最后，我们通过调用 Close() 方法关闭连接。

处理异常

在连接数据库和执行SQL操作的过程中，可能会遇到各种异常情况，如网络连接断开、无效的SQL语句等。为了保证程序的稳定性和可靠性，我们需要适当地处理这些异常。以下示例演示了如何使用 try-catch 块处理异常：

using MySql.Data.MySqlClient;

string connectionString = "Server=localhost;Port=3306;Database=myDatabase;Uid=myUsername;Pwd=myPassword;";
try
{
    MySqlConnection connection = new MySqlConnection(connectionString);
    connection.Open();

    // 执行数据库操作

    connection.Close();
}
catch (MySqlException ex)
{
    Console.WriteLine("发生了MySQL异常：" + ex.Message);
}
catch (Exception ex)
{
    Console.WriteLine("发生了其他异常：" + ex.Message);
}

在上面的示例中，我们使用了 try-catch 块来捕获可能发生的异常。首先，我们在 try 块中创建了一个MySQL连接，并执行数据库操作。如果发生了MySQL相关的异常，我们将在 catch (MySqlException ex) 块中捕获并处理这些异常，例如输出相关错误信息。而对于其他类型的异常，我们将在 catch (Exception ex) 块中捕获和处理。