在C#中,可以使用以下步骤来使用SqlTransaction:
- 创建SqlConnection对象并打开数据库连接。
SqlConnection connection = new SqlConnection(connectionString); connection.Open();
- 创建SqlTransaction对象,并将其与SqlConnection对象关联。
SqlTransaction transaction = connection.BeginTransaction();
- 创建SqlCommand对象,并将其与SqlConnection和SqlTransaction对象关联。
SqlCommand command = new SqlCommand(sqlQuery, connection, transaction);
- 执行SQL命令。
command.ExecuteNonQuery();
- 根据需要提交或回滚事务。
transaction.Commit(); 或 transaction.Rollback();
- 关闭数据库连接。
connection.Close();
以下是一个完整的示例代码:
using (SqlConnection connection = new SqlConnection(connectionString)) { connection.Open(); using (SqlTransaction transaction = connection.BeginTransaction()) { try { SqlCommand command = new SqlCommand(sqlQuery, connection, transaction); command.ExecuteNonQuery(); // 根据需要提交或回滚事务 transaction.Commit(); } catch (Exception ex) { // 发生异常时回滚事务 transaction.Rollback(); Console.WriteLine(ex.Message); } } }
请注意,SqlTransaction应始终与SqlConnection对象一起使用,并且事务完成后应将其释放。