如何将.NET Core与MySQL数据库连接实现高效的数据交互？

本文共计937个文字，预计阅读时间需要4分钟。

.NET Core 连接 MySQL 数据库，在 .NET Core 开发中，我们经常需要与数据库进行交互。MySQL 是一种常用的关系型数据库，本文将介绍如何在 .NET Core 应用程序中连接 MySQL 数据库。准备工作：在开始之前，确保已安装 MySQL 和 .NET Core 开发环境。

.NET Core 连接 MySQL 数据库

在.NET Core开发中，我们经常需要与数据库进行交互。MySQL是一种常用的关系型数据库，本文将介绍如何在.NET Core应用程序中连接MySQL数据库。

准备工作

在开始之前，我们需要先安装MySQL数据库并创建一个数据库。可以从MySQL官方网站下载并安装MySQL Community Server。

安装MySQL Connector/NET

要连接MySQL数据库，我们需要安装MySQL Connector/NET。可以在NuGet包管理器中搜索和安装MySQL Connector/NET包，或者使用以下命令行安装：

dotnet add package MySql.Data

创建连接字符串

在连接到MySQL数据库之前，我们需要创建一个连接字符串。连接字符串包含了连接到数据库所需的信息，例如服务器地址、用户名、密码、数据库名等。

using MySql.Data.MySqlClient; // 数据库连接字符串 string connectionString = "server=localhost;port=3306;user=root;password=123456;database=mydb";

连接到数据库

使用以下代码示例连接到MySQL数据库：

using MySql.Data.MySqlClient; // 数据库连接字符串 string connectionString = "server=localhost;port=3306;user=root;password=123456;database=mydb"; // 创建数据库连接 using (MySqlConnection connection = new MySqlConnection(connectionString)) { try { // 打开数据库连接 connection.Open(); Console.WriteLine("成功连接到数据库！"); } catch (Exception ex) { Console.WriteLine("连接数据库出错：" + ex.Message); } }

执行SQL查询

连接到数据库后，我们可以执行SQL查询并获取结果。以下是一个简单的示例，执行SELECT语句并打印结果：

using MySql.Data.MySqlClient; // 数据库连接字符串 string connectionString = "server=localhost;port=3306;user=root;password=123456;database=mydb"; // 创建数据库连接 using (MySqlConnection connection = new MySqlConnection(connectionString)) { try { // 打开数据库连接 connection.Open(); // 执行SQL查询 string sql = "SELECT * FROM customers"; MySqlCommand command = new MySqlCommand(sql, connection); MySqlDataReader reader = command.ExecuteReader(); // 打印查询结果 while (reader.Read()) { Console.WriteLine(reader["id"] + " " + reader["name"]); } // 关闭数据阅读器 reader.Close(); } catch (Exception ex) { Console.WriteLine("执行SQL查询出错：" + ex.Message); } }

插入数据

要插入数据到MySQL数据库，可以使用INSERT语句。以下是一个示例，向customers表中插入一条数据：

using MySql.Data.MySqlClient; // 数据库连接字符串 string connectionString = "server=localhost;port=3306;user=root;password=123456;database=mydb"; // 创建数据库连接 using (MySqlConnection connection = new MySqlConnection(connectionString)) { try { // 打开数据库连接 connection.Open(); // 执行SQL插入语句 string sql = "INSERT INTO customers (name, email) VALUES ('John Smith', 'john@example.com')"; MySqlCommand command = new MySqlCommand(sql, connection); int rowsAffected = command.ExecuteNonQuery(); Console.WriteLine("插入了 " + rowsAffected + " 行数据！"); } catch (Exception ex) { Console.WriteLine("执行SQL插入语句出错：" + ex.Message); } }

更新数据

要更新MySQL数据库中的数据，可以使用UPDATE语句。以下是一个示例，将customers表中id为1的记录的name字段更新为"Jane Doe"：

using MySql.Data.MySqlClient; // 数据库连接字符串 string connectionString = "server=localhost;port=3306;user=root;password=123456;database=mydb"; // 创建数据库连接 using (MySqlConnection connection = new MySqlConnection(connectionString)) { try { // 打开数据库连接 connection.Open(); // 执行SQL更新语句 string sql = "UPDATE customers SET name='Jane Doe' WHERE id=1"; MySqlCommand command = new MySqlCommand(sql, connection); int rowsAffected = command.ExecuteNonQuery(); Console.WriteLine("更新了 " + rowsAffected + " 行数据！"); } catch (Exception ex) { Console.WriteLine("执行SQL更新语句出错：" + ex.Message); } }

删除数据

要从MySQL数据库中删除数据，可以使用DELETE语句。以下是一个示例，删除customers表中id为1的记录：

using MySql.Data.MySqlClient; // 数据库连接字符串 string connectionString = "server=localhost;port=3306;