SqlServer事務回滾(2)

SQL Server 2008中SQL應用系列--目錄索引

SQL事務
 
1、事務概念
    事務是一種機制、是一種操做序列，它包含了一組數據庫操做命令，這組命令要麼所有執行，要麼所有不執行。所以事務是一個不可分割的工做邏輯單元。在數據庫系統上執行併發操做時事務是做爲最小的控制單元來使用的。這特別適用於多用戶同時操做的數據通訊系統。例如：訂票、銀行、保險公司以及證券交易系統等。
 
2、事務屬性
事務4大屬性：
1   原子性(Atomicity):事務是一個完整的操做。
2   一致性（Consistency）：當事務完成時，數據必須處於一致狀態。
3   隔離性(Isolation):對數據進行修改的全部併發事務是彼此隔離的。
4   持久性(Durability):事務完成後，它對於系統的影響是永久性的。
 
3、建立事務
T-SQL中管理事務的語句：
1 開始事務: begin transaction
2 提交事務：commit transaction
3 回滾事務: rollback transaction
 
事務分類:
1 顯式事務:用begin transaction明確指定事務的開始。
2 隱性事務：打開隱性事務：set implicit_transactions on，當以隱性事務模式操做時，SQL Servler將在提交或回滾事務後自動啓動新事務。沒法描述事務的開始，只須要提交或回滾事務。
3 自動提交事務：SQL Server的默認模式，它將每條單獨的T-SQL語句視爲一個事務。若是成功執行，則自動提交，不然回滾。

　　在SQL Server 2000中，咱們通常使用RaiseError（http://msdn.microsoft.com/zh-cn/library/ms177497.aspx）來拋出錯誤交給應用程序來處理。看MSDN示例（http://msdn.microsoft.com/zh-cn/library/aa238452%28v=sql.80%29.aspx），自從SQL Server 2005集成Try…Catch功能之後，咱們使用時更加靈活，到了SQL Server 2012，更推出了強大的THROW，處理錯誤顯得更爲精簡。本文對此做一個小小的展現。

　　首先，咱們假定兩個基本表以下：

--建立兩個測試表

IF NOT OBJECT_ID('Score') IS NULL
DROP TABLE [Score]
GO
IF NOT OBJECT_ID('Student') IS NULL
DROP TABLE [Student]
GO

CREATE TABLE Student
(stuid int NOT NULL PRIMARY KEY,
stuName Nvarchar(20)
)
CREATE TABLE Score
(stuid int NOT NULL REFERENCES Student(stuid),--外鍵
scoreValue int
)
GO

INSERT INTO Student VALUES (101,'胡一刀')
INSERT INTO Student VALUES (102,'袁承志')
INSERT INTO Student VALUES (103,'陳家洛')
INSERT INTO student VALUES (104,'張三丰')
GO

SELECT * FROM Student

/*
stuid stuName
101 胡一刀
102 袁承志
103 陳家洛
104 張三丰
*/

　　咱們從一個最簡單的例子入手：

例一：

 

/********* 調用運行時錯誤 ***************/
/********* 3w@live.cn 邀月***************/
SET XACT_ABORT OFF
BEGIN TRAN
INSERT INTO Score VALUES (101,80)
INSERT INTO Score VALUES (102,87)
INSERT INTO Score VALUES (107, 59) /* 外鍵錯誤 */
-----SELECT 1/0 /* 除數爲0錯誤 */
INSERT INTO Score VALUES (103,100)
INSERT INTO Score VALUES (104,99)
COMMIT TRAN
GO

 

　　先不看結果，我想問一下，該語句執行完畢後，Score表會插入幾條記錄？估計可能有人說是2條，有人說0條，也可能有人說4條。

　　實際上，我但願是0條，但結果是4條！　

 

/*
(1 row(s) affected)
(1 row(s) affected)
Msg 547, Level 16, State 0, Line 5
The INSERT statement conflicted with the FOREIGN KEY constraint "FK__Score__stuid__01D345B0". The conflict occurred in database "testDb2", table "dbo.Student", column 'stuid'.
The statement has been terminated.
(1 row(s) affected)
(1 row(s) affected)
*/

SELECT * from Score
/*
stuid scoreValue
101 80
102 87
103 100
104 99
*/

　　我對這個結果也有點驚訝，我但願它出錯回滾，因而修改：

例二：

/********* 調用運行時錯誤 ***************/
/********* 3w@live.cn 邀月***************/

TRUNCATE table Score
GO


SET XACT_ABORT OFF
BEGIN TRAN
INSERT INTO Score VALUES (101,80)
INSERT INTO Score VALUES (102,87)
INSERT INTO Score VALUES (107, 59) /* 外鍵錯誤 */
----SELECT 1/0
--INSERT INTO Score VALUES (103,100)
--INSERT INTO Score VALUES (104,99)

PRINT '@@ERROR是:'+cast(@@ERROR as nvarchar(10))
IF @@ERROR<>0
ROLLBACK TRAN
ELSE
COMMIT TRAN
GO

　　我先提示一下你們，這個語句中的@@ERROR值是547，那麼此時，Score表中有幾條記錄?

　　答案是2條！

　　可能有人開始搖頭了，那麼問題的關鍵在哪兒呢?對，就是這個「XACT_ABORT 」開關，查MSDN（http://msdn.microsoft.com/zh-cn/library/ms188792.aspx），

官方解釋：它用於指定當 Transact-SQL 語句出現運行時錯誤時，SQL Server 是否自動回滾到當前事務。當 SET XACT_ABORT 爲 ON 時，若是執行 Transact-SQL 語句產生運行時錯誤，則整個事務將終止並回滾。當 SET XACT_ABORT 爲 OFF 時，有時只回滾產生錯誤的 Transact-SQL 語句，而事務將繼續進行處理。 若是錯誤很嚴重，那麼即便 SET XACT_ABORT 爲 OFF，也可能回滾整個事務。 OFF 是默認設置。編譯錯誤（如語法錯誤）不受 SET XACT_ABORT 的影響。對於大多數 OLE DB 訪問接口（包括 SQL Server），必須將隱式或顯示事務中的數據修改語句中的 XACT_ABORT 設置爲 ON。 惟一不須要該選項的狀況是在提供程序支持嵌套事務時。

　　這裏，紅色的一句話是關鍵，那麼「有時」到底是指何時呢？查資料知：（http://msdn.microsoft.com/zh-cn/library/ms164086.aspx）

　　大體分爲如下四個級別：

　　　　當等級SEVERITY爲0-10時，爲「信息性消息」，最輕。

　　　　當等級爲11-16時，爲「用戶能夠糾正的數據庫引擎錯誤」。如除數爲零，等級爲16

　　　　當等級爲17-19時，爲「須要DBA注意的錯誤」。如內存不足、數據庫引擎已到極限等。

　　　　當等級爲20-25時，爲「致命錯誤或系統問題」。如硬件或軟件損壞、完整性問題、媒體故障等。

　　用戶也能夠自定義錯誤級別和類型。

　　根據以上解釋，咱們最保險的方式是：Set XACT_ABORT ON。

　　固然，使用Try…Catch在Set XACT_ABORT OFF時也能按照咱們的意願回滾。

例三：

/********* 使用Try Catch 構造一個錯誤記錄 ***************/
/********* 3w@live.cn 邀月 ***************/
SET XACT_ABORT OFF
BEGIN TRY
BEGIN TRAN
INSERT INTO Score VALUES (101,80)
INSERT INTO Score VALUES (102,87)
INSERT INTO Score VALUES (107, 59) /* 外鍵錯誤 */
INSERT INTO Score VALUES (103,100)
INSERT INTO Score VALUES (104,99)
COMMIT TRAN
PRINT '事務提交'
END TRY
BEGIN CATCH
ROLLBACK
PRINT '事務回滾' --構造一個錯誤信息記錄

SELECT ERROR_NUMBER() AS 錯誤號,
ERROR_SEVERITY() AS 錯誤等級,
ERROR_STATE() as 錯誤狀態,
DB_ID() as 數據庫ID,
DB_NAME() as 數據庫名稱,
ERROR_MESSAGE() as 錯誤信息;
END CATCH
GO

　　這個返回結果比較另類，它實際上是一條拼湊起來的記錄。

　　記錄並無新增，由於Catch到錯誤而事務回滾了。

　　使用RaiseError也能夠把出錯的信息拋給應用程序來處理。

例四：

/********* 使用RaiseError 提交一個錯誤信息***************/
/********* 3w@live.cn 邀月 ***************/
SET XACT_ABORT OFF
BEGIN TRY
BEGIN TRAN
INSERT INTO Score VALUES (101,80)
INSERT INTO Score VALUES (102,87)
INSERT INTO Score VALUES (107, 59) /* 外鍵錯誤 */
INSERT INTO Score VALUES (103,100)
INSERT INTO Score VALUES (104,99)
COMMIT TRAN
PRINT '事務提交'
END TRY
BEGIN CATCH
ROLLBACK
PRINT '事務回滾';--構造一個錯誤信息記錄

DECLARE @ErrorMessage NVARCHAR(4000);
DECLARE @ErrorSeverity INT;
DECLARE @ErrorState INT;

SELECT @ErrorMessage = ERROR_MESSAGE(),
@ErrorSeverity = ERROR_SEVERITY(),
@ErrorState = ERROR_STATE();

RAISERROR (@ErrorMessage, -- Message text.
@ErrorSeverity, -- Severity.
@ErrorState -- State.
);
END CATCH
GO

　　或者直接使用Throw也能達到RaiseError一樣的效果，並且這是微軟推崇的方式：其官方解釋爲「THROW 語句支持 SET XACT_ABORT，但 RAISERROR 不支持。 新應用程序應該改用 THROW，而不使用 RAISERROR。」其實，多是微軟在忽悠，由於，其實RaiseError也支持Set XACT_ABORT。

例五：

 

/********* SQL 2012新增的Throw ***************/
/********* 3w@live.cn 邀月***************/
SET XACT_ABORT OFF
BEGIN TRY
BEGIN TRAN
INSERT INTO score VALUES (101,80)
INSERT INTO score VALUES (102,87)
INSERT INTO score VALUES (107, 59) /* 外鍵錯誤 */
INSERT INTO score VALUES (103,100)
INSERT INTO score VALUES (104,99)
COMMIT TRAN
PRINT '事務提交'
END TRY
BEGIN CATCH
ROLLBACK;
PRINT '事務回滾';
Throw;
END CATCH
GO

　　不過，說實話，Throw好像很簡練。

　　說到這裏，我有一個疑問：例四和例五的查詢結果相同：

/*
(1 row(s) affected)
(1 row(s) affected)
(0 row(s) affected)
事務回滾
Msg 547, Level 16, State 0, Line 13
The INSERT statement conflicted with the FOREIGN KEY constraint "FK__Score__stuid__18B6AB08". The conflict occurred in database "testDb2", table "dbo.Student", column 'stuid'.
*/

　　雖然由於回滾而沒有插入數據，可是兩個「(1 row(s) affected) 」仍是讓我吃了一驚，哪位高手能告訴我一下，這影響的兩行SQL Server到底是怎麼處理的？先謝過了。

　　既然，錯誤已經被捕獲，那麼有兩種處理方式，一是直接在數據庫中記錄到表中。好比：咱們能夠創建一個數據庫DBErrorLogs,

/*********　生成錯誤日誌記錄表　******/

/********* 3w@live.cn 邀月***************/
CREATE database DBErrorLogs
GO

USE DBErrorLogs
GO

CREATE TABLE [dbo].[ErrorLog](
[nId] [bigint] IDENTITY(101,1) NOT NULL PRIMARY KEY,
[dtDate] [datetime] NOT NULL,
[sThread] [varchar](100) NOT NULL,
[sLevel] [varchar](200) NOT NULL,
[sLogger] [varchar](500) NOT NULL,
[sMessage] [varchar](3000) NOT NULL,
[sException] [varchar](4000) NULL
)
GO

ALTER TABLE [dbo].[ErrorLog] ADD DEFAULT (getdate()) FOR [dtDate]
GO

　　在出錯時直接插入相應信息到該表中便可。另一種思路是交給應用程序來處理，好比下例中，咱們用C#捕獲錯誤，並用log4net記錄回數據庫中。C#中有相應的SQLException類，封裝了相應的Error的等級、編號、出錯信息等，真心方便。

using System;
using System.Text;
using System.Data.SqlClient;
using System.Data;

namespace RaiseErrorDemo_Csharp
{
public class Program
{
#region Define Members
private static log4net.ILog myLogger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
static string conn = "Data Source=AP4\\Net2012;Initial Catalog=Testdb2;Integrated Security=True";
static string sql_RaiseError = @"
/********* 使用RaiseError 提交一個錯誤信息***************/
/********* 3w@live.cn 邀月 ***************/
SET XACT_ABORT OFF
BEGIN TRY
BEGIN TRAN
INSERT INTO Score VALUES (101,80)
INSERT INTO Score VALUES (102,87)
INSERT INTO Score VALUES (107, 59) /* 外鍵錯誤 */
INSERT INTO Score VALUES (103,100)
INSERT INTO Score VALUES (104,99)
COMMIT TRAN
PRINT '事務提交'
END TRY
BEGIN CATCH
ROLLBACK
PRINT '事務回滾';--構造一個錯誤信息記錄
DECLARE @ErrorMessage NVARCHAR(4000);
DECLARE @ErrorSeverity INT;
DECLARE @ErrorState INT;

SELECT @ErrorMessage = ERROR_MESSAGE(),
@ErrorSeverity = ERROR_SEVERITY(),
@ErrorState = ERROR_STATE();

RAISERROR (@ErrorMessage, -- Message text.
@ErrorSeverity, -- Severity.
@ErrorState -- State.
);
END CATCH
";
static string sql_Throw = @"
SET XACT_ABORT OFF
BEGIN TRY
BEGIN TRAN
INSERT INTO score VALUES (101,80)
INSERT INTO score VALUES (102,87)
INSERT INTO score VALUES (107, 59) /* 外鍵錯誤 */
INSERT INTO score VALUES (103,100)
INSERT INTO score VALUES (104,99)
COMMIT TRAN
PRINT '事務提交'
END TRY
BEGIN CATCH
ROLLBACK;
PRINT '事務回滾';
Throw;
END CATCH
";
#endregion

#region Methods

/// <summary>
/// 主函數
/// </summary>
/// <param name="args"></param>
static void Main(string[] args)
{
CatchSQLError(sql_RaiseError);
Console.WriteLine("-----------------------------------------------");
CatchSQLError(sql_Throw);
Console.ReadKey();
}

/// <summary>
/// 捕獲錯誤信息
/// </summary>
/// <param name="strSQL"></param>

public static void CatchSQLError(string strSQL)
{
string connectionString = conn;
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand cmd2 = new SqlCommand(strSQL, connection);
cmd2.CommandType = CommandType.Text;
try
{
connection.Open();
cmd2.ExecuteNonQuery();
}
catch (SqlException err)
{
string strErr = GetPreError(err.Class);
//顯示出錯信息
Console.WriteLine("錯誤等級:" + err.Class + Environment.NewLine + strErr + err.Message);
//記錄錯誤到數據庫中
myLogger.Error(strErr, err);
}
finally
{
connection.Close();
}
}
/// <summary>
/// 輔助函數
/// </summary>
/// <param name="b"></param>
/// <returns></returns>
public static string GetPreError(byte b)
{
string strErr = string.Empty;
if (b >= 0 && b <= 10)
{
strErr = "信息性信息:";
}
else if (b >= 11 && b <= 16)
{
strErr = "用戶能夠糾正的數據庫引擎錯誤:";
}
else if (b >= 17 && b <= 19)
{
strErr = "須要DBA注意的錯誤:";
}
else if (b >= 20 && b <= 25)
{
strErr = "致命錯誤或系統問題:";
}
else
{
strErr = "地球要毀滅了，快跑啊:";
}
return strErr;
}

#endregion

}
}

文後附有C#源碼。執行效果：

 

小結：

一、SQL Server處理錯誤時有一個重要的開關XACT_ABORT，沒事的時候，記得把它打開。

二、SQL Server提供的錯誤信息很豐富，請區分等級採起相應的對策，固然，還能夠本身增長更爲實用貼切的自定義錯誤類型。

 

下載源碼