.net core 连接 mysql数据库

.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;