C#和sqlserver 如何实现事务ACID和使用数据库锁,悲观锁乐观锁死锁

当前位置:

首页 > c#编程 >

C#和sqlserver 如何实现事务ACID和使用数据库锁,悲观锁乐观锁死锁

在C#中使用SQL Server实现事务的ACID（原子性、一致性、隔离性、持久性）属性和使用数据库锁（悲观锁和乐观锁）时，你可以通过ADO.NET的SqlConnection和SqlTransaction类来实现。下面是一些示例和概念说明。

实现ACID事务

ACID属性是事务处理的四个基本特征，它们确保事务在数据库中的正确性和可靠性。

using System;  
using System.Data;  
using System.Data.SqlClient;  
  
class Program  
{  
    static void Main()  
    {  
        string connectionString = "你的连接字符串";  
          
        using (SqlConnection connection = new SqlConnection(connectionString))  
        {  
            connection.Open();  
  
            // 开启事务  
            SqlTransaction transaction = connection.BeginTransaction();  
  
            try  
            {  
                using (SqlCommand command1 = new SqlCommand("UPDATE Account SET Balance = Balance - @Amount WHERE AccountNumber = @AccountNumber", connection, transaction))  
                {  
                    command1.Parameters.AddWithValue("@Amount", 100);  
                    command1.Parameters.AddWithValue("@AccountNumber", "12345");  
                    command1.ExecuteNonQuery();  
                }  
  
                using (SqlCommand command2 = new SqlCommand("UPDATE Account SET Balance = Balance + @Amount WHERE AccountNumber = @AccountNumber", connection, transaction))  
                {  
                    command2.Parameters.AddWithValue("@Amount", 100);  
                    command2.Parameters.AddWithValue("@AccountNumber", "67890");  
                    command2.ExecuteNonQuery();  
                }  
  
                // 提交事务  
                transaction.Commit();  
                Console.WriteLine("事务已提交");  
            }  
            catch (Exception ex)  
            {  
                // 回滚事务  
                transaction.Rollback();  
                Console.WriteLine("事务已回滚: " + ex.Message);  
            }  
        }  
    }  
}

在这个例子中，我们创建了一个事务，并在其中执行了两个更新操作。如果两个操作都成功，事务将被提交，否则事务将被回滚。

悲观锁

悲观锁通常是通过在SQL查询中使用SELECT ... FOR UPDATE语句实现的，它会在读取数据的同时锁定这些数据，以防止其他事务修改它们。

using (SqlCommand command = new SqlCommand("SELECT * FROM YourTable WHERE YourColumn = @YourValue FOR UPDATE", connection, transaction))  
{  
    command.Parameters.AddWithValue("@YourValue", "某个值");  
  
    using (SqlDataReader reader = command.ExecuteReader())  
    {  
        while (reader.Read())  
        {  
            // 在这里处理锁定的数据  
        }  
    }  
}