C#连接MySQL数据库操作基类详解

在C#中连接并操作MySQL数据库是许多应用程序中的常见任务，尤其在构建企业级解决方案或需要利用MySQL强大数据库特性时。本文将详细介绍C#如何与MySQL数据库进行交互，涵盖核心操作如连接、存储过程调用以及增删改查（CRUD）的基本方法。 首先，为了实现这些操作，通常会创建一个数据库操作基类，该基类封装了所有数据库操作的共通代码，以简化和复用代码。MySQL数据库操作基类可能会包含以下几个关键部分： ### 1. 连接MySQL数据库 在进行任何数据库操作前，首先需要建立一个到MySQL服务器的连接。这通常是通过一个数据库连接字符串来完成，该字符串包含了所有必要的连接信息，如服务器地址、数据库名、用户名和密码。 ```csharp public class MySQLHelper { private string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;"; public void Connect() { try { using (MySqlConnection conn = new MySqlConnection(connectionString)) { conn.Open(); // 在这里执行具体的操作 } } catch (MySqlException e) { // 处理异常，例如：显示错误信息或记录日志 } } } ``` ### 2. 存储过程操作 存储过程是数据库中为了实现特定功能而预定义的一系列SQL语句。在C#中调用存储过程，可以通过`MySqlCommand`对象来实现。传递参数和处理返回值是调用存储过程时的重要环节。 ```csharp public void CallStoredProc(string storedProcName, params MySqlParameter[] parameters) { using (MySqlConnection conn = new MySqlConnection(connectionString)) { conn.Open(); using (MySqlCommand cmd = new MySqlCommand(storedProcName, conn)) { cmd.CommandType = CommandType.StoredProcedure; foreach (MySqlParameter param in parameters) { cmd.Parameters.Add(param); } cmd.ExecuteNonQuery(); // 用于执行存储过程 } } } ``` ### 3. 增加数据 在MySQL数据库中增加数据通常是指向某个表中插入新的记录。通过创建`INSERT`语句并执行，可以实现这一操作。 ```csharp public void InsertData(string tableName, Dictionary<string, object> data) { using (MySqlConnection conn = new MySqlConnection(connectionString)) { conn.Open(); using (MySqlCommand cmd = new MySqlCommand()) { StringBuilder sb = new StringBuilder("INSERT INTO "); sb.Append(tableName); sb.Append(" ("); // 构建字段名列表 foreach (var item in data.Keys) { sb.Append(item).Append(", "); } sb.Length = sb.Length - 2; // 移除最后一个逗号 sb.Append(") VALUES ("); // 构建值列表 for (int i = 0; i < data.Values.Count; i++) { sb.Append("@p").Append(i).Append(", "); } sb.Length = sb.Length - 2; // 移除最后一个逗号 sb.Append(")"); cmd.CommandText = sb.ToString(); // 添加参数 int i = 0; foreach (var item in data.Values) { cmd.Parameters.AddWithValue("@p" + i, item); i++; } cmd.ExecuteNonQuery(); // 执行INSERT操作 } } } ``` ### 4. 删除数据 删除数据通常是指通过`DELETE`语句从表中移除记录。为了确保数据的正确删除，需要在`DELETE`语句中使用`WHERE`子句来指定条件。 ```csharp public void DeleteData(string tableName, string condition) { using (MySqlConnection conn = new MySqlConnection(connectionString)) { conn.Open(); using (MySqlCommand cmd = new MySqlCommand("DELETE FROM " + tableName + " WHERE " + condition, conn)) { cmd.ExecuteNonQuery(); // 执行DELETE操作 } } } ``` ### 5. 修改数据 修改数据涉及到更新表中已存在的记录，一般使用`UPDATE`语句来完成。同样地，`WHERE`子句用于指定要更新记录的条件。 ```csharp public void UpdateData(string tableName, Dictionary<string, object> data, string condition) { using (MySqlConnection conn = new MySqlConnection(connectionString)) { conn.Open(); using (MySqlCommand cmd = new MySqlCommand()) { StringBuilder sb = new StringBuilder("UPDATE ").Append(tableName).Append(" SET "); // 构建字段值对列表 int i = 0; foreach (var item in data) { sb.Append(item.Key).Append(" = @p").Append(i).Append(", "); i++; } sb.Length = sb.Length - 2; // 移除最后一个逗号 sb.Append(" WHERE ").Append(condition); cmd.CommandText = sb.ToString(); // 添加参数 i = 0; foreach (var item in data.Values) { cmd.Parameters.AddWithValue("@p" + i, item); i++; } cmd.ExecuteNonQuery(); // 执行UPDATE操作 } } } ``` ### 6. 查询数据 查询数据是数据库操作中最常用的功能，分为查询单条记录和查询多条记录。通常使用`SELECT`语句来实现。 ```csharp public DataTable SelectData(string query) { using (MySqlConnection conn = new MySqlConnection(connectionString)) { conn.Open(); using (MySqlCommand cmd = new MySqlCommand(query, conn)) { MySqlDataAdapter adapter = new MySqlDataAdapter(cmd); DataTable dt = new DataTable(); adapter.Fill(dt); // 填充DataTable return dt; } } } ``` ### 总结 本文所讨论的知识点涵盖了从C#连接和操作MySQL数据库的基本概念和方法。通过创建一个操作基类，可以将重复的数据库操作代码抽象出来，方便后续的代码复用和维护。在实际开发过程中，应确保数据库连接字符串的安全，以及在执行数据库操作时考虑异常处理和事务管理。此外，为了提高效率和安全性，应当对用户输入进行适当的验证和清理，防止SQL注入等安全威胁。