當(dāng)前位置 主頁 > 技術(shù)大全 >
在 C# 中連接 MySQL 數(shù)據(jù)庫是一項(xiàng)非常常見的任務(wù)。下面我將為您提供一個(gè)從基礎(chǔ)到進(jìn)階的完整指南，包括環(huán)境配置、代碼實(shí)現(xiàn)、最佳實(shí)踐和常見問題處理。
一、 選擇連接器（驅(qū)動(dòng)）
在 C# (.NET) 中連接 MySQL，官方推薦使用 **MySQL Connector/NET**，這是一個(gè)完全托管的 ADO.NET 驅(qū)動(dòng)程序�，F(xiàn)在它主要通過 **NuGet** 包進(jìn)行分發(fā)，包名稱為：
* **`MySql.Data`** (官方驅(qū)動(dòng))
#安裝 NuGet 包
在您的 C# 項(xiàng)目（如 Console App, ASP.NET Core 等）中，通過以下方式安裝：
1. **Visual Studio**：右鍵點(diǎn)擊項(xiàng)目 -> “管理 NuGet 程序包” -> 搜索 “`MySql.Data`” -> 安裝。
2. **.NET CLI**：在終端中運(yùn)行以下命令：
```bash
dotnet add package MySql.Data
```
二、 基礎(chǔ)連接代碼（ADO.NET 方式）
這是最直接、最可控的方式，類似于連接 SQL Server 的方式。
#1. 引入必要的命名空間
```csharp
using MySql.Data.MySqlClient; // 核心命名空間
using System.Data; // 可選，用于 DataTable 等類
```
#2. 構(gòu)建連接字符串（Connection String）
連接字符串包含連接到數(shù)據(jù)庫所需的所有信息。以下是關(guān)鍵參數(shù)：
| 參數(shù) | 描述 | 示例 |
| :--- | :--- | :--- |
| `Server` | MySQL 服務(wù)器地址 | `localhost`, `127.0.0.1`, `example.com` |
| `Port` | 端口號(hào)（可選，默認(rèn) 3306） | `3306` |
| `Database` | 要連接的數(shù)據(jù)庫名稱 | `mydatabase` |
| `Uid` | 用戶名 | `root` |
| `Pwd` | 密碼 | `your_password` |
| `Charset` | 字符集（**強(qiáng)烈建議設(shè)置**） | `utf8mb4` (支持表情符號(hào)) |
**示例連接字符串：**
```csharp
string connectionString = "Server=localhost;Port=3306;Database=mydatabase;Uid=root;Pwd=myPassword;Charset=utf8mb4;";
```
**重要提示：** 永遠(yuǎn)不要將連接字符串硬編碼在代碼中！應(yīng)將其存儲(chǔ)在配置文件中，如 `appsettings.json` (ASP.NET Core) 或 `App.config`/`Web.config` (傳統(tǒng) .NET Framework)。
#3. 完整的連接與查詢示例
以下是一個(gè)控制臺(tái)應(yīng)用程序的完整示例，演示了如何建立連接、執(zhí)行查詢并讀取數(shù)據(jù)。
```csharp
using System;
using MySql.Data.MySqlClient;
namespace MySqlConnectionExample
{
class Program
{
static void Main(string[] args)
{
// 1. 定義連接字符串
string connectionString = "server=localhost;user=root;password=123456;database=testdb;charset=utf8mb4;";
// 2. 創(chuàng)建 MySqlConnection 對(duì)象
using (MySqlConnection connection = new MySqlConnection(connectionString))
{
try
{
// 3. 打開數(shù)據(jù)庫連接
connection.Open();
Console.WriteLine("Connection opened successfully.");
// 4. 編寫 SQL 查詢
string sql = "SELECT id, name, email FROM users WHERE id > @id"; // 使用參數(shù)化查詢防止SQL注入
// 5. 創(chuàng)建 Command 對(duì)象
using (MySqlCommand command = new MySqlCommand(sql, connection))
{
// 6. 添加參數(shù)
command.Parameters.AddWithValue("@id", 0);
// 7. 執(zhí)行查詢，獲取 MySqlDataReader
using (MySqlDataReader reader = command.ExecuteReader())
{
// 8. 檢查是否有數(shù)據(jù)返回
if (reader.HasRows)
{
// 9. 循環(huán)讀取每一行數(shù)據(jù)
while (reader.Read())
{
// 10. 通過列名或索引獲取數(shù)據(jù)
int id = reader.GetInt32("id");
string name = reader.GetString("name");
string email = reader.IsDBNull(reader.GetOrdinal("email")) ? null : reader.GetString("email"); // 安全處理NULL值
Console.WriteLine($"ID: {id}, Name: {name}, Email: {email}");
}
}
else
{
Console.WriteLine("No records found.");
}
// 11. Reader 會(huì)在 using 塊結(jié)束時(shí)自動(dòng)關(guān)閉
}
}
}
catch (MySqlException ex)
{
// 處理 MySQL 特定的異常
Console.WriteLine($"MySQL Error {ex.Number}: {ex.Message}");
}
catch (Exception ex)
{
// 處理其他異常
Console.WriteLine($"General error: {ex.Message}");
}
// 12. Connection 會(huì)在 using 塊結(jié)束時(shí)自動(dòng)關(guān)閉和釋放
}
Console.ReadLine();
}
}
}
```
三、 在 ASP.NET Core 中的最佳實(shí)踐
在現(xiàn)代 ASP.NET Core 應(yīng)用程序中，我們使用依賴注入 (Dependency Injection) 來管理數(shù)據(jù)庫連接，這是更優(yōu)雅和高效的方式。
#1. 在 `appsettings.json` 中配置連接字符串
```json
{
"ConnectionStrings": {
"DefaultConnection": "server=localhost;port=3306;database=myappdb;user=myappuser;password=MyStrongPassword!;charset=utf8mb4;"
},
// ... other settings
}
```
#2. 在 `Program.cs` 中注冊(cè) MySQL 服務(wù)
```csharp
using MySql.Data.MySqlClient;
using System.Data;
var builder = WebApplication.CreateBuilder(args);
// 添加服務(wù)到容器
builder.Services.AddControllers();
// 注冊(cè) MySqlConnection，將其作為瞬態(tài)（Transient）服務(wù)
// 每次請(qǐng)求都會(huì)創(chuàng)建一個(gè)新的連接實(shí)例，ADO.NET 的連接池會(huì)管理底層連接的效率
builder.Services.AddTransient<IDbConnection>((sp) =>
{
var connectionString = builder.Configuration.GetConnectionString("DefaultConnection");
return new MySqlConnection(connectionString);
});
var app = builder.Build();
// ... 后續(xù)中間件配置
```
#3. 在控制器 (Controller) 或服務(wù)層中使用
```csharp
[ApiController]
[Route("api/[controller]")]
public class UsersController : ControllerBase
{
private readonly IDbConnection _db;
// 通過構(gòu)造函數(shù)注入 IDbConnection
public UsersController(IDbConnection db)
{
_db = db;
}
[HttpGet]
public async Task<IActionResult> GetUsers()
{
var users = new List<User>();
// 使用 Dapper 簡化數(shù)據(jù)操作（推薦）
// users = await _db.QueryAsync<User>("SELECT * FROM Users");
// 或者使用原生 ADO.NET
await _db.OpenAsync();
using (var command = new MySqlCommand("SELECT * FROM Users", (MySqlConnection)_db))
{
using (var reader = await command.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
{
users.Add(new User
{
Id = reader.GetInt32("Id"),
Name = reader.GetString("Name")
});
}
}
}
return Ok(users);
}
}
```
四、 關(guān)鍵注意事項(xiàng)與最佳實(shí)踐
1. **連接池 (Connection Pooling)**：
* `MySql.Data` 默認(rèn)啟用了連接池。這意味著當(dāng)你創(chuàng)建和關(guān)閉 `MySqlConnection` 對(duì)象時(shí)，底層物理連接并不會(huì)立即關(guān)閉，而是被放入池中備用，從而大幅提升性能。
* **務(wù)必使用 `using` 語句**或在 ASP.NET Core 中通過依賴注入來管理連接，以確保連接總是被正確關(guān)閉并返回到池中。避免手動(dòng)調(diào)用 `.Open()` 而不調(diào)用 `.Close()`。
2. **參數(shù)化查詢**：
* **永遠(yuǎn)不要**使用字符串拼接來構(gòu)造 SQL 查詢語句，這會(huì)導(dǎo)致嚴(yán)重的 **SQL 注入漏洞**。
* **始終**像示例中那樣使用 `MySqlParameter` 或 `Parameters.AddWithValue()`。
3. **異步編程**：
* 對(duì)于 Web 應(yīng)用程序，使用異步方法（`OpenAsync()`, `ExecuteReaderAsync()`, `ReadAsync()`）可以避免阻塞線程，提高應(yīng)用程序的并發(fā)能力和可擴(kuò)展性。
4. **錯(cuò)誤處理**：
* 使用 `try-catch` 塊來捕獲 `MySqlException`，它可以提供具體的錯(cuò)誤編號(hào)（`ex.Number`），便于排查身份驗(yàn)證、服務(wù)器連接等特定問題。
5. **使用 ORM（對(duì)象關(guān)系映射器）**：
* 對(duì)于復(fù)雜的應(yīng)用程序，考慮使用像 **Dapper**（輕量、高性能）或 **Entity Framework Core**（功能全面、官方支持）這樣的 ORM。它們可以簡化數(shù)據(jù)訪問代碼。
* EF Core 同樣可以通過 `Pomelo.EntityFrameworkCore.MySql` 提供程序來支持 MySQL。
總結(jié)
在 C# 中連接 MySQL 的步驟可以概括為：
1. **安裝** `MySql.Data` NuGet 包。
2. **配置**安全的連接字符串（存儲(chǔ)在配置文件中）。
3. **使用 `using` 語句**創(chuàng)建和銷毀 `MySqlConnection` 對(duì)象以利用連接池。
4. **使用 `MySqlCommand` 和 `MySqlParameter`** 執(zhí)行參數(shù)化查詢。
5. **在 ASP.NET Core 中**，通過依賴注入在 `Program.cs` 中注冊(cè) `IDbConnection`，并在控制器中獲取使用。
遵循這些步驟和最佳實(shí)踐，您就可以在 C# 應(yīng)用程序中高效、安全地與 MySQL 數(shù)據(jù)庫進(jìn)行交互。
另外搭配便捷的MYSQL備份工具，可定時(shí)備份、異地備份，MYSQL導(dǎo)出導(dǎo)入�？杀镜剡B接LINUX里的MYSQL，簡單便捷。可以大大地提高工作效率喔。
