当前位置：首页 > 技术教程 > 正文

ASP.NET如何操作MySQL数据库？实例代码详解与关键步骤解析

admin
技术教程
2026-01-07
4710

ASP.NET操作MySQL数据库的实例代码讲解

开发环境与依赖安装

硬件与软件准备

操作系统：Windows 10/11（推荐64位）
开发工具：Visual Studio 2026（或更高版本）
数据库：MySQL 8.0+（安装后创建测试数据库testdb）
表结构：在testdb中创建Users表（字段：id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(50), email VARCHAR(100)）

安装.NET依赖

在Visual Studio中，通过NuGet包管理器安装MySql.Data库：

右键项目 → 管理NuGet包 → 搜索MySql.Data → 安装

建立数据库连接

配置连接字符串

推荐在web.config中配置连接字符串，便于管理：

注意：providerName是关键标识符，确保代码能识别MySQL连接

ASP.NET如何操作MySQL数据库？实例代码详解与关键步骤解析第1张

代码中获取连接

若不使用配置文件,可通过代码动态获取连接：

ASP.NET如何操作MySQL数据库？实例代码详解与关键步骤解析第2张

基础CRUD操作实例

以Users表为例，演示增删改查的核心代码。

插入（Insert）新记录

查询（Select）所有记录

List<User> users = new List<User>(); using (MySqlConnection conn = new MySqlConnection(connStr)) { conn.Open(); string sql = "SELECT id, name, email FROM Users"; using (MySqlCommand cmd = new MySqlCommand(sql, conn)) { using (MySqlDataReader reader = cmd.ExecuteReader()) { while (reader.Read()) { users.Add(new User { Id = reader.GetInt32("id"), Name = reader.GetString("name"), Email = reader.GetString("email") }); } } } }

注：User为实体类，需手动映射字段

ASP.NET如何操作MySQL数据库？实例代码详解与关键步骤解析第3张

更新（Update）记录

using (MySqlConnection conn = new MySqlConnection(connStr)) { conn.Open(); string sql = "UPDATE Users SET name = @Name WHERE id = @Id"; using (MySqlCommand cmd = new MySqlCommand(sql, conn)) { cmd.Parameters.AddWithValue("@Name", "Bob"); cmd.Parameters.AddWithValue("@Id", 1); cmd.ExecuteNonQuery(); } }

删除（Delete）记录

using (MySqlConnection conn = new MySqlConnection(connStr)) { conn.Open(); string sql = "DELETE FROM Users WHERE id = @Id"; using (MySqlCommand cmd = new MySqlCommand(sql, conn)) { cmd.Parameters.AddWithValue("@Id", 1); cmd.ExecuteNonQuery(); } }

高级应用与优化

事务处理（多步骤操作）

using (MySqlConnection conn = new MySqlConnection(connStr)) { conn.Open(); MySqlTransaction trans = conn.BeginTransaction(); // 开始事务 try { string sql1 = "INSERT INTO Users (name, email) VALUES (@Name, @Email)"; using (MySqlCommand cmd1 = new MySqlCommand(sql1, conn, trans)) { cmd1.Parameters.AddWithValue("@Name", "Carol"); cmd1.Parameters.AddWithValue("@Email", "carol@example.com"); cmd1.ExecuteNonQuery(); } string sql2 = "UPDATE Users SET email = @Email WHERE id = @Id"; using (MySqlCommand cmd2 = new MySqlCommand(sql2, conn, trans)) { cmd2.Parameters.AddWithValue("@Email", "carol_new@example.com"); cmd2.Parameters.AddWithValue("@Id", 3); cmd2.ExecuteNonQuery(); } trans.Commit(); // 提交事务 } catch { trans.Rollback(); // 回滚事务 throw; } }

批量插入（提高性能）

using (MySqlConnection conn = new MySqlConnection(connStr)) { conn.Open(); string sql = "INSERT INTO Users (name, email) VALUES (@Name, @Email)"; using (MySqlCommand cmd = new MySqlCommand(sql, conn)) { cmd.Prepare(); // 预编译SQL语句 // 批量添加参数 cmd.Parameters.AddWithValue("@Name", "Eve"); cmd.Parameters.AddWithValue("@Email", "eve@example.com"); cmd.ExecuteNonQuery(); cmd.Parameters.AddWithValue("@Name", "Frank"); cmd.Parameters.AddWithValue("@Email", "frank@example.com"); cmd.ExecuteNonQuery(); } }