c#中SqlTransaction——事務(wù)詳解
事務(wù)處理基本原理
事務(wù)是將一系列操作作為一個(gè)單元執(zhí)行，要么成功，要么失敗，回滾到最初狀態(tài)。在事務(wù)處理術(shù)語(yǔ)中，事務(wù)要么提交，要么中止。若要提交事務(wù)，所有參與者都必須保證對(duì)數(shù)據(jù)的任何更改是永久的。不論系統(tǒng)崩潰或是發(fā)生其他無(wú)法預(yù)料的事件，更改都須是持久的。只要有一個(gè)參與者無(wú)法做出此保證，整個(gè)事務(wù)就會(huì)失敗。事務(wù)范圍內(nèi)的所有數(shù)據(jù)更改將回滾到特定設(shè)置點(diǎn)。
事務(wù)將多個(gè)操作緊密聯(lián)系到一起，這樣就能保證有聯(lián)系的兩種操作的一致性、以及數(shù)據(jù)的完整性。舉個(gè)簡(jiǎn)單例子：公司的員工信息管理系統(tǒng)，現(xiàn)在要錄入數(shù)據(jù),員工信息系統(tǒng)假設(shè)只有部門、員工信息兩張表，其中員工信息表中有標(biāo)識(shí)部門的字段。在你錄入信息的時(shí)候首先你得錄入部門信息，再錄入員工信息。具體實(shí)現(xiàn)代碼：
private static void ExecuteSqlTransaction(string connectionString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
SqlCommand command = connection.CreateCommand();
SqlTransaction transaction;
transaction = connection.BeginTransaction("SampleTransaction");
command.Connection = connection;
command.Transaction = transaction;
try
{
command.CommandText =
"Insert into Department (ID, Name) VALUES (1, '工程部')";
command.ExecuteNonQuery();
command.CommandText =
"Insert into Users(ID, Name,DepartmentID) VALUES (1, 'xyz',1)";
command.ExecuteNonQuery();
transaction.Commit();
}
catch (Exception ex)
{
transaction.Rollback();
}
}
}
事務(wù)的誤區(qū)
事務(wù)有很多優(yōu)點(diǎn)【原理中已經(jīng)闡述】，由于它的要求比較高，所以注意事務(wù)不能濫用，如果用不好就會(huì)造成很大的麻煩。
事務(wù)有一個(gè)開頭和一個(gè)結(jié)尾，它們指定了事務(wù)的邊界，事務(wù)在其邊界之內(nèi)可以跨越進(jìn)程和計(jì)算機(jī)。事務(wù)邊界內(nèi)的所有資源都參與同一個(gè)事務(wù)。要維護(hù)事務(wù)邊界內(nèi)資源間的一致性，事務(wù)必須具備 ACID 屬性，即原子性、一致性、隔離性和持續(xù)性。這是MSDN的權(quán)威說(shuō)明。
也許針對(duì)一般的小邏輯、小數(shù)據(jù)事務(wù)應(yīng)用非常的高效、可靠。但如果數(shù)據(jù)量很大，在單個(gè)事務(wù)中集合的操作繁多而且復(fù)雜，事務(wù)的致命傷就會(huì)暴露出來(lái)。一個(gè)事務(wù)進(jìn)行時(shí)，必須保證邊界資源的原子性、一致性、隔離性和持續(xù)性。
我曾經(jīng)設(shè)計(jì)了一個(gè)測(cè)試用例，測(cè)試事務(wù)在執(zhí)行時(shí)對(duì)資源的利用情況。測(cè)試結(jié)果很令人驚訝：在事務(wù)執(zhí)行時(shí)，獨(dú)占事務(wù)涉及到的數(shù)據(jù)表,造成其它操作詞表的功能，因等待時(shí)間過(guò)長(zhǎng)，而暴跳“獲得數(shù)據(jù)連接超時(shí)”的警告。
具體的測(cè)試用例：
Transaction
public class TestTransaction
{
/// <summary>
/// 插入新用戶
/// </summary>
/// <param name="tran"></param>
/// <returns></returns>
private static bool InsertIntoUser(SqlTransaction tran)
{
string strSql = @"INSERT INTO [T_User]
([F_Name])
VALUES
(@F_Name)";
SqlParameter[] Params ={ new SqlParameter("@F_Name", SqlDbType.VarChar, 20) };
Params[0].Value="Test1001";
int count= SqlHelper.ExecuteNonQuery(strSql,Params,tran);
if (count > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 插入title
/// </summary>
/// <returns></returns>
private static bool InsertIntoTitle(SqlTransaction tran)
{
string strSql = @"INSERT INTO [T_User_Title]
([F_TitleName],
[F_Remark],
[F_Status],
[F_EditTime])
VALUES
(@F_TitleName,
@F_Remark,
@F_Status,
@F_EditTime)";
SqlParameter[] Params = {
new SqlParameter("@F_TitleName",SqlDbType.VarChar, 50),
new SqlParameter("@F_Remark", SqlDbType.VarChar, 200),
new SqlParameter("@F_Status", SqlDbType.Int, 1),
new SqlParameter("@F_EditTime", SqlDbType.DateTime, 8) };
Params[0].Value = "TestUser1001";
Params[1].Value = "這是第一次測(cè)試";
Params[2].Value = 1;
Params[3].Value = DateTime.Now;
int count = SqlHelper.ExecuteNonQuery(strSql,Params,tran);
if (count > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 檢測(cè)Transaction
/// </summary>
/// <returns></returns>
public static bool InsertWithTran()
{
bool success = false;
string connectionString=System.Configuration.ConfigurationSettings.AppSettings["SqlConStr"].ToString();
using (SqlConnection con = new SqlConnection(connectionString))
{
con.Open();
SqlTransaction tran = con.BeginTransaction();
try
{
if (tran == null)
{
throw new Exception("Transaction is null");
}
if (InsertIntoUser(tran))
{
if (InsertIntoTitle(tran))
{
tran.Commit();
success = true;
}
}
}
catch
{
tran.Rollback();
success = false;
}
finally
{
tran.Dispose();
con.Close();
}
}
return success;
}
}
Button
protected void Button1_Click(object sender, EventArgs e)
{
bool success = TestTransaction.InsertWithTran();
if (success)
{
Bmc.CLUtility.ShowMessage(this.Page, "插入成功");
}
else
{
Bmc.CLUtility.ShowMessage(this.Page, "插入失敗");
}
}
測(cè)試步驟
<1>運(yùn)行程序
<2>將運(yùn)行的地址，發(fā)給在同一個(gè)網(wǎng)段的同事，通過(guò)適當(dāng)修改也能夠看到你運(yùn)行的程序
<3>兩人都點(diǎn)擊按鈕，并查詢數(shù)據(jù)庫(kù)，看事務(wù)是否正確執(zhí)行
<4>在事務(wù)中間創(chuàng)建斷點(diǎn)，主機(jī)點(diǎn)擊按鈕，并在斷點(diǎn)處中斷執(zhí)行一段時(shí)間
<5>然后你們連接到數(shù)據(jù)庫(kù)，分別查詢表的數(shù)據(jù)，發(fā)現(xiàn)不能執(zhí)行查詢操作。
<6>在同事機(jī)器點(diǎn)擊按鈕，查詢windows日志，發(fā)現(xiàn)了一些警告。這就證明了，事務(wù)在執(zhí)行過(guò)程中，獨(dú)占資源
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了C#實(shí)現(xiàn)自定義雙擊事件,需要的朋友可以參考下2014-08-08
C#實(shí)現(xiàn)判斷文件夾存在與否并創(chuàng)建文件夾的方法
這篇文章主要介紹了C#實(shí)現(xiàn)判斷文件夾存在與否并創(chuàng)建文件夾的方法,涉及C#針對(duì)文件及目錄的判斷與創(chuàng)建操作相關(guān)技巧,需要的朋友可以參考下2017-02-02
在當(dāng)今的數(shù)字化辦公環(huán)境中,PDF文檔已經(jīng)成為信息交換和存檔的標(biāo)準(zhǔn)格式,然而,在許多業(yè)務(wù)場(chǎng)景中,開發(fā)者會(huì)面臨一個(gè)共同的需求：將多個(gè)PDF文檔合并為一個(gè),本文將深入探討如何利用Spire.PDF for .NET 這一強(qiáng)大的工具,幫助C#開發(fā)者輕松實(shí)現(xiàn)PDF文檔的合并,需要的朋友可以參考下2025-09-09
.NET使用C#實(shí)現(xiàn)將Word文檔轉(zhuǎn)換為HTML格式
這篇文章主要為大家詳細(xì)介紹了如何在.NET平臺(tái)使用C#將Word文檔轉(zhuǎn)換為HTML文件,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2025-01-01
這篇文章主要介紹了C#中分部方法和分部類基本用法,并且較為詳細(xì)的分析了分部方法和分部類使用時(shí)的注意事項(xiàng),需要的朋友可以參考下2014-11-11
序列化是將對(duì)象狀態(tài)轉(zhuǎn)換為可保持或傳輸?shù)母袷降倪^(guò)程。與序列化相對(duì)的是反序列化，它將流轉(zhuǎn)換為對(duì)象。這兩個(gè)過(guò)程結(jié)合起來(lái)，可以輕松地存儲(chǔ)和傳輸數(shù)據(jù)2014-02-02
Unity UI或3D場(chǎng)景實(shí)現(xiàn)跟隨手機(jī)陀螺儀的晃動(dòng)效果
這篇文章主要介紹了Unity UI或3D場(chǎng)景實(shí)現(xiàn)跟隨手機(jī)陀螺儀的晃動(dòng)效果，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-11-11
解析使用C# lock同時(shí)訪問(wèn)共享數(shù)據(jù)
本篇文章是對(duì)使用C# lock同時(shí)訪問(wèn)共享數(shù)據(jù)進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-06-06
基于WebClient實(shí)現(xiàn)Http協(xié)議的Post與Get對(duì)網(wǎng)站進(jìn)行模擬登陸和瀏覽實(shí)例
這篇文章主要介紹了基于WebClient實(shí)現(xiàn)Http協(xié)議的Post與Get對(duì)網(wǎng)站進(jìn)行模擬登陸和瀏覽的方法,以實(shí)例形式詳細(xì)分析了WebClient模擬POST與GET登陸與瀏覽的過(guò)程,對(duì)于C#項(xiàng)目開發(fā)來(lái)說(shuō)具有不錯(cuò)的參考借鑒價(jià)值,需要的朋友可以參考下2014-11-11
這篇文章主要為大家詳細(xì)介紹了C#求點(diǎn)集的最小包圍矩形，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2020-09-09