在C#中,事务处理通常用于数据库操作。要使用事务处理,你需要使用SqlConnection和SqlTransaction类。以下是一个简单的示例,展示了如何在C#中使用事务处理:
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
// 连接字符串,根据实际情况进行修改
string connectionString = "your_connection_string_here";
// 创建一个SqlConnection对象
using (SqlConnection connection = new SqlConnection(connectionString))
{
// 打开连接
connection.Open();
// 开始事务
SqlTransaction transaction = connection.BeginTransaction();
try
{
// 创建一个SqlCommand对象
using (SqlCommand command = new SqlCommand("INSERT INTO Table1 (Column1) VALUES (@Value1)", connection, transaction))
{
// 添加参数
command.Parameters.AddWithValue("@Value1", "Value1");
// 执行命令
command.ExecuteNonQuery();
// 创建另一个SqlCommand对象
using (SqlCommand command2 = new SqlCommand("INSERT INTO Table2 (Column1) VALUES (@Value2)", connection, transaction))
{
// 添加参数
command2.Parameters.AddWithValue("@Value2", "Value2");
// 执行命令
command2.ExecuteNonQuery();
// 提交事务
transaction.Commit();
}
}
}
catch (Exception ex)
{
// 如果发生异常,回滚事务
Console.WriteLine("Error: " + ex.Message);
transaction.Rollback();
}
}
}
}
在这个示例中,我们首先创建了一个SqlConnection对象并打开连接。然后,我们使用BeginTransaction方法开始一个事务。接下来,我们创建两个SqlCommand对象,分别执行插入操作。如果所有操作都成功执行,我们使用Commit方法提交事务。如果在执行过程中发生异常,我们捕获异常并使用Rollback方法回滚事务。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。