在C#中，数据库操作是一项非常常见且重要的任务，无论是开发Web应用程序、桌面应用程序还是移动应用程序，都离不开与数据库的交互，下面将详细介绍C#中的数据库操作，包括连接数据库、执行SQL查询、读取数据等。
一、连接数据库
在C#中，连接数据库通常使用SqlConnection类（对于SQL Server数据库），以下是一个简单的示例，展示了如何连接到SQL Server数据库：
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
using (SqlConnection connection = new SqlConnection(connectionString))
{
try
{
connection.Open();
Console.WriteLine("Connection to Database successful!");
}
catch (Exception ex)
{
Console.WriteLine("Error: " + ex.Message);
}
}
}
}
在这个示例中，首先需要导入System.Data.SqlClient命名空间，创建一个SqlConnection对象，并传入连接字符串，连接字符串包含了服务器地址、数据库名称、用户名和密码等信息，使用Open方法打开连接，如果连接成功，则输出相应的消息；如果出现异常，则捕获并输出错误信息。
二、执行SQL查询
连接数据库后，就可以执行SQL查询了，在C#中，可以使用SqlCommand类来执行SQL查询，以下是一个示例，展示了如何执行一个简单的查询并获取结果：
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
string query = "SELECT * FROM myTable";
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand command = new SqlCommand(query, connection);
try
{
connection.Open();
SqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
Console.WriteLine(String.Format("{0}, {1}", reader[0], reader[1]));
}
reader.Close();
}
catch (Exception ex)
{
Console.WriteLine("Error: " + ex.Message);
}
}
}
}
在这个示例中，首先创建了一个SqlCommand对象，并传入要执行的SQL查询和连接对象，打开连接并执行查询，通过SqlDataReader对象读取查询结果，在读取过程中，可以使用reader[列索引]或reader["列名"]的方式获取每一行的数据，并将其输出到控制台，关闭SqlDataReader对象以释放资源。
三、参数化查询
为了避免SQL注入攻击，建议使用参数化查询，在C#中，可以通过在SQL查询中使用参数占位符，并在执行查询前为这些参数赋值来实现参数化查询，以下是一个示例：
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
string query = "SELECT * FROM myTable WHERE id = @id";
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand command = new SqlCommand(query, connection);
command.Parameters.AddWithValue("@id", 1);
try
{
connection.Open();
SqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
Console.WriteLine(String.Format("{0}, {1}", reader[0], reader[1]));
}
reader.Close();
}
catch (Exception ex)
{
Console.WriteLine("Error: " + ex.Message);
}
}
}
}
在这个示例中，在SQL查询中使用了@id作为参数占位符，然后在创建SqlCommand对象后，通过Parameters.AddWithValue方法为该参数赋值，这样可以避免直接将用户输入拼接到SQL查询中，从而提高安全性。
四、更新和删除数据
除了查询数据外，还可以使用C#对数据库中的数据进行更新和删除操作，以下分别展示了如何执行更新和删除操作的示例：
更新数据
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
string updateQuery = "UPDATE myTable SET column2 = @column2 WHERE id = @id";
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand command = new SqlCommand(updateQuery, connection);
command.Parameters.AddWithValue("@column2", "newValue");
command.Parameters.AddWithValue("@id", 1);
try
{
connection.Open();
int rowsAffected = command.ExecuteNonQuery();
Console.WriteLine(rowsAffected + " row(s) updated.");
}
catch (Exception ex)
{
Console.WriteLine("Error: " + ex.Message);
}
}
}
}
在这个示例中，创建了一个更新查询，并通过Parameters.AddWithValue方法为参数赋值，打开连接并执行更新操作，ExecuteNonQuery方法返回受影响的行数。
删除数据
using Systems;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
string deleteQuery = "DELETE FROM myTable WHERE id = @id";
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand command = new SqlCommand(deleteQuery, connection);
command.Parameters.AddWithValue("@id", 1);
try
{
connection.Open();
int rowsAffected = command.ExecuteNonQuery();
Console.WriteLine(rowsAffected + " row(s) deleted.");
}
catch (Exception ex)
{
Console.WriteLine("Error: " + ex.Message);
}
}
}
}
在这个示例中，创建了一个删除查询，并为参数赋值，打开连接并执行删除操作，同样使用ExecuteNonQuery方法返回受影响的行数。
五、使用Entity Framework进行数据库操作
Entity Framework是微软提供的一个ORM（对象关系映射）框架，它允许开发者使用面向对象的方式来操作数据库，以下是一个简单的示例，展示了如何使用Entity Framework进行数据库操作：
1、需要安装Entity Framework NuGet包，在Visual Studio中，可以通过“工具”->“NuGet包管理器”->“管理解决方案的NuGet包”来安装Entity Framework。
2、创建一个新的C#控制台应用程序项目，并在项目中添加一个实体类和一个上下文类。
using System;
using System.ComponentModel.DataAnnotations;
using System.Data.Entity;
public class MyContext : DbContext
{
public DbSet<MyEntity> MyEntities { get; set; }
}
public class MyEntity
{
[Key]
public int Id { get; set; }
public string Name { get; set; }
}
3、在Main方法中，使用Entity Framework进行数据库操作：
using System;
using System.Linq;
using System.Data.Entity;
class Program
{
static void Main()
{
using (var context = new MyContext())
{
// 添加一条记录
MyEntity entity = new MyEntity { Name = "Test" };
context.MyEntities.Add(entity);
context.SaveChanges();
Console.WriteLine("Record added successfully!");
// 查询所有记录并输出
var entities = context.MyEntities.ToList();
foreach (var e in entities)
{
Console.WriteLine(e.Id + ": " + e.Name);
}
}
}
}
在这个示例中，首先创建了一个上下文类MyContext，它继承自DbContext并包含一个DbSet<MyEntity>属性，创建了一个实体类MyEntity，它具有一个主键属性Id和一个普通属性Name，在Main方法中，使用上下文类添加了一条记录到数据库中，并保存更改，查询所有记录并输出到控制台。
在C#中进行数据库操作涉及到多个方面，包括连接数据库、执行SQL查询、更新和删除数据以及使用ORM框架等，通过合理地运用这些技术和工具，可以方便地实现与数据库的交互，满足各种业务需求，要注意代码的安全性和性能优化，以确保应用程序的稳定运行。
