MySQL 是一款流行的开源关系型数据库管理系统,而 .NET 是一个强大的开发平台,广泛应用于 Windows 应用程序的开发。本文将带您入门,通过实战代码解析,学习在 .NET 环境下如何进行 MySQL 数据库的操作。
1. 准备工作
在开始之前,请确保以下准备工作已完成:
- 安装 .NET 开发环境。
- 安装 MySQL 数据库并创建数据库和表。
- 安装 MySQL .NET Connector(MySQL 的 .NET 数据库驱动)。
2. 连接 MySQL 数据库
首先,我们需要创建一个 SqlConnection 对象来连接 MySQL 数据库。
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
using (SqlConnection connection = new SqlConnection(connectionString))
{
try
{
connection.Open();
Console.WriteLine("数据库连接成功!");
}
catch (Exception ex)
{
Console.WriteLine("数据库连接失败:" + ex.Message);
}
}
}
}
在上面的代码中,我们使用 SqlConnection 类创建了一个连接字符串,其中包含了服务器地址、数据库名、用户名和密码。然后,我们尝试打开连接,如果成功,则输出“数据库连接成功!”,否则输出错误信息。
3. 查询数据
查询数据是数据库操作中最常见的一种。以下是一个查询示例:
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
string query = "SELECT * FROM yourTable";
SqlCommand command = new SqlCommand(query, connection);
SqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
Console.WriteLine(reader["column1"].ToString() + " " + reader["column2"].ToString());
}
reader.Close();
}
}
}
在上面的代码中,我们首先创建了一个 SqlCommand 对象,并指定了要执行的 SQL 查询语句。然后,我们使用 ExecuteReader 方法执行查询,并通过 SqlDataReader 对象遍历结果集,输出查询到的数据。
4. 插入数据
以下是一个插入数据的示例:
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
string query = "INSERT INTO yourTable (column1, column2) VALUES (@value1, @value2)";
SqlCommand command = new SqlCommand(query, connection);
command.Parameters.AddWithValue("@value1", "value1");
command.Parameters.AddWithValue("@value2", "value2");
int result = command.ExecuteNonQuery();
if (result > 0)
{
Console.WriteLine("数据插入成功!");
}
else
{
Console.WriteLine("数据插入失败!");
}
}
}
}
在上面的代码中,我们创建了一个 SqlCommand 对象,并指定了要执行的 SQL 插入语句。然后,我们使用 Parameters.AddWithValue 方法为查询参数赋值,并使用 ExecuteNonQuery 方法执行插入操作。如果插入成功,则输出“数据插入成功!”,否则输出“数据插入失败!”。
5. 更新数据
以下是一个更新数据的示例:
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
string query = "UPDATE yourTable SET column1 = @value1 WHERE column2 = @value2";
SqlCommand command = new SqlCommand(query, connection);
command.Parameters.AddWithValue("@value1", "newValue1");
command.Parameters.AddWithValue("@value2", "value2");
int result = command.ExecuteNonQuery();
if (result > 0)
{
Console.WriteLine("数据更新成功!");
}
else
{
Console.WriteLine("数据更新失败!");
}
}
}
}
在上面的代码中,我们创建了一个 SqlCommand 对象,并指定了要执行的 SQL 更新语句。然后,我们使用 Parameters.AddWithValue 方法为查询参数赋值,并使用 ExecuteNonQuery 方法执行更新操作。如果更新成功,则输出“数据更新成功!”,否则输出“数据更新失败!”。
6. 删除数据
以下是一个删除数据的示例:
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "server=localhost;database=yourDatabase;uid=yourUsername;pwd=yourPassword;";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
string query = "DELETE FROM yourTable WHERE column2 = @value2";
SqlCommand command = new SqlCommand(query, connection);
command.Parameters.AddWithValue("@value2", "value2");
int result = command.ExecuteNonQuery();
if (result > 0)
{
Console.WriteLine("数据删除成功!");
}
else
{
Console.WriteLine("数据删除失败!");
}
}
}
}
在上面的代码中,我们创建了一个 SqlCommand 对象,并指定了要执行的 SQL 删除语句。然后,我们使用 Parameters.AddWithValue 方法为查询参数赋值,并使用 ExecuteNonQuery 方法执行删除操作。如果删除成功,则输出“数据删除成功!”,否则输出“数据删除失败!”。