MSSQLSERVER數據庫- 使用C#來操作事務

 就在不久前，我在博客園看到一個名為英雄默問出處的博客。他里面有兩篇是介紹用C#來操作事務的。用C#來操作事務和用SQL語句來操作事務原理是一模一樣的。總結起來有三個步驟：

1.開啟事務

2.判斷執行的SQL語句有沒有出錯，如果沒有就將執行完SQL語句后提交事務

3.如果有錯，那么就回滾事務

 

　　在操作事務上還分為本地事務和分布式事務。我從網上百度下來他們的定義，如下：
　　本地事務：將多項任務綁定在一起，使其作為單個工作單元來執行。
　　分布式事務：分布式事務是指事務的參與者、支持事務的服務器、資源服務器以及事務管理器分別位於不同的分布式系統的不同節點之上。

　　上面的定義沒看懂也沒關系，其實我看這些定義也挺煩的。記得有一回考操作系統，當時老師在課堂上說了一句可能會考定義，例如操作系統是什么，結果呢？操作系統是什么這句我背了好幾遍。臨到考前的早上還起來再讀一次。考后就忘記了。這樣的考試也夠折騰人的了。
　　我們可以通俗的理解成，本地事務就是操作單個數據庫的。而分布式事務就是操作多個數據庫的。

 　　

　　下面用三個小例子來說明一下C#怎么操作事務。

• 　　第一個小例子結合存儲過程和事務來操作。
• 　　第二個小例子使用ADO.NET里面的一個類SqlTransaction來操作本地事務。
• 　　第三個小例子使用TransactionScope類操作，使用TransactionScope時需添加引用命名空間，再using System.Transactions。

 

在看這三個小例子前先看一下數據庫用的表，為了測試，一切都非常簡單

 

test數據庫的bank表有哪些字段的數據

bid balance
001  400.00
002  2100.00

 

testLog數據庫里的bankLo有哪些字段的數據

id bid oldBalance newBalance logtime
1 002  2100.00 1100.00 2010-09-01 00:00:00.000
2 002  2100.00 1100.00 2010-09-01 00:00:00.000

 

第一小例子

先在數據庫里他建存儲過程，里面寫上事務的SQL語句

USE [test]
GO
/****** Object:  StoredProcedure [dbo].[proc_bankTransaction]    Script Date: 08/19/2012 10:42:05 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
ALTER procedure [dbo].[proc_bankTransaction]
(
    @result int output --0表示提交事務失敗，表示提交事務成功
)
AS
BEGIN
    declare @sumError int
    set @sumError=0
    BEGIN TRANSACTION  --開啟事務
    update bank set balance=balance-100 where bid='001';
    set @sumError = @sumError +@@Error
    update bank set balance=balance+1000 where bid='002';
    set @sumError = @sumError +@@Error
     
        IF(@sumError = 0)
            BEGIN
                set @result=1 --提交事務，表示提交事物成功
                COMMIT TRANSACTION
            END
        ELSE
            BEGIN
                set @result=0 --回滾事務，表示回滾事務
                ROLLBACK TRANSACTION
            END
END

C#操作的語句代碼：

 

        static void Main(string[] args)
        {

            using (SqlConnection conn = new SqlConnection("server=.;database=test;uid=sa;pwd=123456"))
            {
                conn.Open();
                using (SqlCommand cmd = new SqlCommand("proc_bankTransaction", conn))
                {
                    cmd.CommandType = CommandType.StoredProcedure;
                    SqlParameter[] paras ={
                        new SqlParameter("@result",SqlDbType.Int)
                    };
                    paras[0].Direction = ParameterDirection.Output;
                    try
                    {
                        cmd.Parameters.AddRange(paras);
                        cmd.ExecuteNonQuery();
                        Console.Write(paras[0].Value);//輸出1表示成功，輸出0表示失敗
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }

            }
            Console.ReadLine();

        }

 

第二個小例子：使用ADO.NET里面的一個類SqlTransaction來操作本地事務

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {

            using (SqlConnection conn = new SqlConnection("server=.;database=test;uid=sa;pwd=123456"))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    SqlTransaction transaction = conn.BeginTransaction();//開始事物
                    cmd.Transaction = transaction;
                    try
                    {
                        cmd.Connection = conn;
                        cmd.CommandText = "update bank set balance='500' where bid='001'";
                        cmd.ExecuteNonQuery();

                        cmd.CommandText = "update bank set balance='2100' where bid='002'";
                        cmd.ExecuteNonQuery();

                        transaction.Commit();//如果都成功那么提交事物
                    }
                    catch (Exception ex)
                    {
                        Console.Write(ex.Message);
                        transaction.Rollback();//出現錯誤，進行回滾
                    }
                }
            }

            Console.ReadLine();


        }
    }
}

第三個小例子：使用TransactionScope類操作，使用TransactionScope時需添加引用命名空間，再using System.Transactions。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Transactions;
namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {

            string bankStr = "server=.;database=test;uid=sa;pwd=123456";
            string bankLogStr = "server=.;database=testLog;uid=sa;pwd=123456";

            //為了簡化操作步驟，假設我們已經知道是原來的balance的值為2100，更改后的值為1100
            using (TransactionScope scope = new TransactionScope())
            {
                try
                {
                    using (SqlConnection conn = new SqlConnection(bankStr))
                    {
                        conn.Open();
                        using (SqlCommand cmd = conn.CreateCommand())
                        {
                            cmd.CommandText = "update bank set balance='1100' where bid='002'";
                            cmd.ExecuteNonQuery();
                        }
                    }

                    using (SqlConnection connBankLog = new SqlConnection(bankLogStr))
                    {
                        connBankLog.Open();
                        using (SqlCommand cmd = connBankLog.CreateCommand())
                        {
                            cmd.CommandText = "insert into bankLog(bid,oldBalance,newBalance,logtime) values('002','2100','1100','2010-09-01');";

                            cmd.ExecuteNonQuery();
                        }
                    }
                    scope.Complete();
                }
                catch (Exception ex)
                {
                    Console.Write(ex.Message);
                }
            }
            Console.ReadLine();

        }
    }
}