使用Sqlcommand执行SQL语句

在.NET框架中，`SqlCommand`类是用于执行SQL命令的核心组件，它允许开发人员与SQL Server数据库进行交互。本文将详细讲解如何使用`SqlCommand`执行SQL语句，包括基本用法、参数化查询、事务处理以及错误处理。 一、SqlCommand的基本使用 `SqlCommand`对象是`SqlConnection`的实例成员，它负责执行SQL命令。我们需要创建一个`SqlConnection`对象，连接到数据库，然后创建`SqlCommand`对象并设置其`CommandText`属性为要执行的SQL语句。下面是一个简单的示例： ```csharp using System; using System.Data.SqlClient; public class SqlCommandDemo { public static void Main() { string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;"; using (SqlConnection connection = new SqlConnection(connectionString)) { connection.Open(); SqlCommand command = new SqlCommand("SELECT * FROM TableName", connection); SqlDataReader reader = command.ExecuteReader(); while (reader.Read()) { // 处理读取的数据 } reader.Close(); } } } ``` 二、参数化查询 为了防止SQL注入攻击和提高代码可维护性，应使用参数化查询。`SqlParameter`类用于创建参数，可以将它们添加到`SqlCommand`的`Parameters`集合中。例如： ```csharp string searchKey = "keyword"; SqlCommand command = new SqlCommand("SELECT * FROM TableName WHERE ColumnName = @searchKey", connection); command.Parameters.Add(new SqlParameter("@searchKey", SqlDbType.NVarChar) { Value = searchKey }); ``` 三、执行不同类型的SQL命令 除了执行查询，`SqlCommand`还可以用于执行DML（数据操纵语言）命令，如INSERT、UPDATE、DELETE，以及存储过程。例如，执行一个INSERT语句： ```csharp SqlCommand insertCommand = new SqlCommand("INSERT INTO TableName (Column1, Column2) VALUES (@value1, @value2)", connection); insertCommand.Parameters.AddWithValue("@value1", value1); insertCommand.Parameters.AddWithValue("@value2", value2); int rowsAffected = insertCommand.ExecuteNonQuery(); ``` 四、事务处理 在执行一系列相互依赖的操作时，使用事务可以确保数据的一致性。在`SqlConnection`上打开事务，然后在事务范围内执行SQL命令： ```csharp connection.Open(); SqlTransaction transaction = connection.BeginTransaction(); try { SqlCommand command1 = new SqlCommand("UPDATE Table SET Column = @newValue1", connection, transaction); command1.Parameters.AddWithValue("@newValue1", newValue1); command1.ExecuteNonQuery(); SqlCommand command2 = new SqlCommand("INSERT INTO AnotherTable (Col) VALUES (@newValue2)", connection, transaction); command2.Parameters.AddWithValue("@newValue2", newValue2); command2.ExecuteNonQuery(); transaction.Commit(); } catch { transaction.Rollback(); throw; } finally { connection.Close(); } ``` 五、错误处理 在执行SQL命令时，可能会遇到各种错误，如网络问题、语法错误或权限问题。使用`SqlCommand`的`ExecuteNonQuery`、`ExecuteReader`或`ExecuteScalar`方法时，这些方法会抛出异常。通过捕获和处理这些异常，可以确保程序的健壮性： ```csharp try { SqlCommand command = new SqlCommand("Invalid SQL Statement", connection); command.ExecuteNonQuery(); } catch (SqlException ex) { Console.WriteLine($"SQL 错误: {ex.Number} - {ex.Message}"); } catch (Exception ex) { Console.WriteLine($"通用错误: {ex.Message}"); } ``` 总结，`SqlCommand`是.NET中执行SQL语句的关键工具，它支持参数化查询、事务处理和错误处理，确保了与SQL Server的高效且安全的通信。理解和熟练使用`SqlCommand`对于任何.NET数据库开发者来说都至关重要。