C#中如何使用数据库的本地事务？示例代码是什么？-C#.Net教程-PHP中文网

C#中如何使用数据库的本地事务？示例代码是什么？

畫卷琴夢

发布： 2025-10-30 19:05:12

原创

214人浏览过

使用C#通过IDbConnection和IDbTransaction实现数据库本地事务，以SqlConnection为例，先打开连接，调用BeginTransaction()开启事务，将事务对象传给SqlCommand执行操作，若全部成功则Commit提交，否则Rollback回滚；需确保命令关联事务、连接保持打开、妥善处理异常并及时释放资源；SQLite等其他数据库同理，仅类名不同。

c#中如何使用数据库的本地事务？示例代码是什么？

在C#中使用数据库本地事务，可以通过 ADO.NET 提供的 IDbConnection、IDbTransaction 接口来实现。以 SQL Server 为例，使用 SqlConnection 开启事务，通过 SqlTransaction 控制提交或回滚。

使用步骤说明

开启事务的基本流程如下：

创建数据库连接（SqlConnection）
调用 BeginTransaction() 方法启动事务
将事务对象传给 SqlCommand 使用
执行一个或多个数据库操作
如果全部成功，调用 Commit() 提交事务
如果有异常，调用 Rollback() 回滚事务

示例代码：SQL Server 本地事务

using System;
using System.Data.SqlClient;
<p>class Program
{
static void Main()
{
string connectionString = "Server=localhost;Database=TestDB;Integrated Security=true;";</p><pre class='brush:php;toolbar:false;'>    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();

        // 开始事务
        SqlTransaction transaction = connection.BeginTransaction();

        try
        {
            // 第一条命令：更新账户A余额
            SqlCommand cmd1 = new SqlCommand("UPDATE Accounts SET Balance = Balance - 100 WHERE Id = 1", connection, transaction);
            cmd1.ExecuteNonQuery();

            // 第二条命令：更新账户B余额
            SqlCommand cmd2 = new SqlCommand("UPDATE Accounts SET Balance = Balance + 100 WHERE Id = 2", connection, transaction);
            cmd2.ExecuteNonQuery();

            // 所有操作成功，提交事务
            transaction.Commit();
            Console.WriteLine("事务提交成功，转账完成。");
        }
        catch (Exception ex)
        {
            // 出现异常，回滚事务
            try
            {
                transaction.Rollback();
            }
            catch (Exception rollBackEx)
            {
                Console.WriteLine("事务回滚失败: " + rollBackEx.Message);
            }

            Console.WriteLine("事务执行失败: " + ex.Message);
        }
    }
}

登录后复制

}

关键点说明

以下是在使用本地事务时需要注意的地方：

阿里云-虚拟数字人

阿里云-虚拟数字人是什么？ ...

查看详情

SqlCommand 必须指定事务：每个参与事务的命令都要传入 transaction 对象，否则不会被包含在事务中
连接必须保持打开状态：事务期间数据库连接不能关闭
异常处理必不可少：确保出错时能正确回滚，避免数据不一致
及时释放资源：使用 using 或 try-finally 确保连接和事务被正确释放

其他数据库（如 SQLite）的类似用法

如果是 SQLite，原理相同，只是类名不同：

using (var connection = new SqliteConnection(connectionString))
{
    connection.Open();
    var transaction = connection.BeginTransaction();
<pre class='brush:php;toolbar:false;'>try
{
    using var cmd = new SqliteCommand("INSERT INTO Logs (Message) VALUES (@msg)", connection, transaction);
    cmd.Parameters.AddWithValue("@msg", "测试日志");
    cmd.ExecuteNonQuery();

    transaction.Commit();
}
catch
{
    transaction.Rollback();
    throw;
}

登录后复制

}

基本上就这些。本地事务适用于单一数据库内的操作，简单直接，是保证数据一致性的常用手段。

以上就是C#中如何使用数据库的本地事务？示例代码是什么？的详细内容，更多请关注php中文网其它相关文章！