C#连接MySQL数据库并进行简单操作涉及以下几个基础概念:
以下是一个简单的C#程序,演示如何连接到MySQL数据库并执行基本的CRUD操作:
using System;
using MySql.Data.MySqlClient;
class Program
{
static void Main()
{
string connectionString = "server=localhost;port=3306;database=testdb;user=root;password=yourpassword;";
try
{
using (MySqlConnection connection = new MySqlConnection(connectionString))
{
connection.Open();
// 插入数据
string insertQuery = "INSERT INTO users (name, email) VALUES (@name, @email)";
MySqlCommand insertCommand = new MySqlCommand(insertQuery, connection);
insertCommand.Parameters.AddWithValue("@name", "John Doe");
insertCommand.Parameters.AddWithValue("@email", "john.doe@example.com");
insertCommand.ExecuteNonQuery();
// 查询数据
string selectQuery = "SELECT * FROM users";
MySqlCommand selectCommand = new MySqlCommand(selectQuery, connection);
MySqlDataReader reader = selectCommand.ExecuteReader();
while (reader.Read())
{
Console.WriteLine($"ID: {reader["id"]}, Name: {reader["name"]}, Email: {reader["email"]}");
}
reader.Close();
// 更新数据
string updateQuery = "UPDATE users SET email = @newEmail WHERE id = @id";
MySqlCommand updateCommand = new MySqlCommand(updateQuery, connection);
updateCommand.Parameters.AddWithValue("@newEmail", "john.doe.new@example.com");
updateCommand.Parameters.AddWithValue("@id", 1);
updateCommand.ExecuteNonQuery();
// 删除数据
string deleteQuery = "DELETE FROM users WHERE id = @id";
MySqlCommand deleteCommand = new MySqlCommand(deleteQuery, connection);
deleteCommand.Parameters.AddWithValue("@id", 1);
deleteCommand.ExecuteNonQuery();
}
}
catch (Exception ex)
{
Console.WriteLine("Error: " + ex.Message);
}
}
}
通过以上步骤和示例代码,你应该能够在C#中成功连接到MySQL数据库并进行基本的操作。如果遇到具体问题,可以根据错误信息进行排查和解决。
领取专属 10元无门槛券
手把手带您无忧上云