C# 连接mysql增删改查
时间: 2024-09-06 19:01:58 浏览: 54
在C#中连接MySQL数据库并进行增删改查的操作通常需要借助ADO.NET库,特别是MySql.Data.MySqlClient或Entity Framework这样的ORM工具。以下是一个简单的步骤说明:
1. **安装驱动**:
首先,你需要在项目中添加对MySql.Data.MySqlClient的引用,如果使用NuGet包管理器,可以输入`Install-Package MySql.Data`。
2. **创建连接**:
使用` MySqlConnection`类建立到数据库的连接,需要提供服务器地址、数据库名、用户名和密码:
```csharp
string connectionString = "server=localhost;database=mydb;uid=root;password=mypassword;";
MySqlConnection connection = new MySqlConnection(connectionString);
```
3. **打开连接**:
打开数据库连接:
```csharp
connection.Open();
```
4. **执行SQL操作**:
- **插入(Insert)**:
```csharp
MySqlCommand command = new MySqlCommand("INSERT INTO table_name (column1, column2) VALUES (@value1, @value2)", connection);
command.Parameters.AddWithValue("@value1", value1);
command.ExecuteNonQuery();
```
- **删除(Delete)**:
```csharp
MySqlCommand deleteCommand = new MySqlCommand("DELETE FROM table_name WHERE id = @id", connection);
deleteCommand.Parameters.AddWithValue("@id", id);
int rowsAffected = deleteCommand.ExecuteNonQuery();
```
- **更新(Update)**:
类似于插入,只是修改已有行的数据:
```csharp
MySqlCommand updateCommand = new MySqlCommand("UPDATE table_name SET column1 = @value1 WHERE id = @id", connection);
updateCommand.Parameters.AddWithValue("@value1", newValue);
updateCommand.ExecuteNonQuery();
```
- **查询(Select)**:
```csharp
MySqlCommand selectCommand = new MySqlCommand("SELECT * FROM table_name", connection);
MySqlDataReader reader = selectCommand.ExecuteReader();
while (reader.Read())
{
Console.WriteLine(reader["column_name"]);
}
```
5. **关闭连接**:
当完成所有操作后,记得关闭连接:
```csharp
connection.Close();
```
注意:在实际应用中,为了提高代码的可读性和安全性,建议使用using语句自动处理资源释放:
```csharp
using (MySqlConnection connection = new MySqlConnection(connectionString))
{
// ... 执行SQL操作 ...
}
```
阅读全文