当前位置：首页 > 行业动态 > 正文

c#实现数据库增删查改

admin
行业动态
2025-01-31
4

### C#实现数据库增删查改：通过SqlConnection连接数据库，使用SqlCommand执行SQL语句，完成对数据库的增、删、改、查操作。

在C#中实现数据库的增删查改操作，通常使用ADO.NET技术，以下是详细步骤：

一、准备工作

1、引入命名空间：在使用ADO.NET之前，需要在代码中引入相关的命名空间，如System.Data和System.Data.SqlClient（对于SQL Server数据库）。

2、建立数据库连接：通过SqlConnection类建立与数据库的连接，需要提供数据库服务器地址、数据库名称、用户名和密码等信息。

string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword";
SqlConnection connection = new SqlConnection(connectionString);

二、查询操作（Select）

1、创建命令对象：使用SqlCommand类创建一个命令对象，并指定要执行的SQL查询语句，要查询所有用户的信息，可以使用以下SQL语句：

string sqlQuery = "SELECT * FROM Users";
SqlCommand command = new SqlCommand(sqlQuery, connection);

2、打开连接并执行查询：在执行查询之前，需要先打开数据库连接，然后调用命令对象的ExecuteReader方法来执行查询，并返回一个SqlDataReader对象，用于读取查询结果。

connection.Open();
SqlDataReader reader = command.ExecuteReader();

3、读取查询结果：使用SqlDataReader对象的Read方法遍历查询结果集，并通过索引或列名获取每一行的数据。

while (reader.Read())
{
    Console.WriteLine("UserID: " + reader["UserID"].ToString());
    Console.WriteLine("Username: " + reader["Username"].ToString());
    // 获取其他列的数据...
}

4、关闭连接和读者：在完成查询操作后，需要关闭SqlDataReader对象和数据库连接。

reader.Close();
connection.Close();

三、插入操作（Insert）

1、创建插入命令：使用SqlCommand类创建一个命令对象，并指定要执行的插入SQL语句，要向Users表中插入一条新记录，可以使用以下SQL语句：

string sqlInsert = "INSERT INTO Users (Username, Password, Email) VALUES (@username, @password, @email)";
SqlCommand insertCommand = new SqlCommand(sqlInsert, connection);

2、设置参数值：为了提高代码的安全性和可维护性，建议使用参数化查询，可以通过命令对象的Parameters属性设置参数的值。

insertCommand.Parameters.AddWithValue("@username", "newuser");
insertCommand.Parameters.AddWithValue("@password", "password123");
insertCommand.Parameters.AddWithValue("@email", "newuser@example.com");

3、打开连接并执行插入：在执行插入操作之前，需要先打开数据库连接，然后调用命令对象的ExecuteNonQuery方法来执行插入操作。

connection.Open();
int rowsAffected = insertCommand.ExecuteNonQuery();

4、关闭连接：在完成插入操作后，需要关闭数据库连接。

connection.Close();

四、更新操作（Update）

1、创建更新命令：使用SqlCommand类创建一个命令对象，并指定要执行的更新SQL语句，要更新Users表中某条记录的密码，可以使用以下SQL语句：

string sqlUpdate = "UPDATE Users SET Password = @newPassword WHERE UserID = @userID";
SqlCommand updateCommand = new SqlCommand(sqlUpdate, connection);

2、设置参数值：同样需要使用参数化查询来设置参数的值。

updateCommand.Parameters.AddWithValue("@newPassword", "newpassword456");
updateCommand.Parameters.AddWithValue("@userID", 1);

3、打开连接并执行更新：在执行更新操作之前，需要先打开数据库连接，然后调用命令对象的ExecuteNonQuery方法来执行更新操作。

connection.Open();
int rowsUpdated = updateCommand.ExecuteNonQuery();

4、关闭连接：在完成更新操作后，需要关闭数据库连接。

connection.Close();

五、删除操作（Delete）

1、创建删除命令：使用SqlCommand类创建一个命令对象，并指定要执行的删除SQL语句，要删除Users表中某条记录，可以使用以下SQL语句：

string sqlDelete = "DELETE FROM Users WHERE UserID = @userID";
SqlCommand deleteCommand = new SqlCommand(sqlDelete, connection);

2、设置参数值：使用参数化查询来设置参数的值。

deleteCommand.Parameters.AddWithValue("@userID", 1);

3、打开连接并执行删除：在执行删除操作之前，需要先打开数据库连接，然后调用命令对象的ExecuteNonQuery方法来执行删除操作。

connection.Open();
int rowsDeleted = deleteCommand.ExecuteNonQuery();

4、关闭连接：在完成删除操作后，需要关闭数据库连接。

connection.Close();

以下是一个完整的示例代码，演示了如何使用C#实现对数据库的增删查改操作：

|操作类型|代码示例|说明|

|—-|—-|—-|

|查询|“`csharp

string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword"; SqlConnection connection = new SqlConnection(connectionString); string sqlQuery = "SELECT * FROM Users"; SqlCommand command = new SqlCommand(sqlQuery, connection); connection.Open(); SqlDataReader reader = command.ExecuteReader(); while (reader.Read()) { Console.WriteLine("UserID: " + reader["UserID"].ToString()); Console.WriteLine("Username: " + reader["Username"].ToString()); // 获取其他列的数据… } reader.Close(); connection.Close(); “`|查询所有用户信息并输出到控制台|

|插入|“`csharp

string sqlInsert = "INSERT INTO Users (Username, Password, Email) VALUES (@username, @password, @email)"; SqlCommand insertCommand = new SqlCommand(sqlInsert, connection); insertCommand.Parameters.AddWithValue("@username", "newuser"); insertCommand.Parameters.AddWithValue("@password", "password123"); insertCommand.Parameters.AddWithValue("@email", "newuser@example.com"); connection.Open(); int rowsAffected = insertCommand.ExecuteNonQuery(); connection.Close(); “`|向Users表中插入一条新记录|

|更新|“`csharp

string sqlUpdate = "UPDATE Users SET Password = @newPassword WHERE UserID = @userID"; SqlCommand updateCommand = new SqlCommand(sqlUpdate, connection); updateCommand.Parameters.AddWithValue("@newPassword", "newpassword456"); updateCommand.Parameters.AddWithValue("@userID", 1); connection.Open(); int rowsUpdated = updateCommand.ExecuteNonQuery(); connection.Close(); “`|更新UserID为1的用户密码|

|删除|“`csharp

string sqlDelete = "DELETE FROM Users WHERE UserID = @userID"; SqlCommand deleteCommand = new SqlCommand(sqlDelete, connection); deleteCommand.Parameters.AddWithValue("@userID", 1); connection.Open(); int rowsDeleted = deleteCommand.ExecuteNonQuery(); connection.Close(); “`|删除UserID为1的用户记录|