c#中SqlTransaction——事務(wù)詳解
事務(wù)處理基本原理
事務(wù)是將一系列操作作為一個(gè)單元執(zhí)行，要么成功，要么失敗，回滾到最初狀態(tài)。在事務(wù)處理術(shù)語中，事務(wù)要么提交，要么中止。若要提交事務(wù)，所有參與者都必須保證對(duì)數(shù)據(jù)的任何更改是永久的。不論系統(tǒng)崩潰或是發(fā)生其他無法預(yù)料的事件，更改都須是持久的。只要有一個(gè)參與者無法做出此保證，整個(gè)事務(wù)就會(huì)失敗。事務(wù)范圍內(nèi)的所有數(shù)據(jù)更改將回滾到特定設(shè)置點(diǎn)。
事務(wù)將多個(gè)操作緊密聯(lián)系到一起，這樣就能保證有聯(lián)系的兩種操作的一致性、以及數(shù)據(jù)的完整性。舉個(gè)簡單例子：公司的員工信息管理系統(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)威說明。
也許針對(duì)一般的小邏輯、小數(shù)據(jù)事務(wù)應(yīng)用非常的高效、可靠。但如果數(shù)據(jù)量很大，在單個(gè)事務(wù)中集合的操作繁多而且復(fù)雜，事務(wù)的致命傷就會(huì)暴露出來。一個(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í)間過長，而暴跳“獲得數(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)段的同事，通過適當(dāng)修改也能夠看到你運(yùn)行的程序
<3>兩人都點(diǎn)擊按鈕，并查詢數(shù)據(jù)庫，看事務(wù)是否正確執(zhí)行
<4>在事務(wù)中間創(chuàng)建斷點(diǎn)，主機(jī)點(diǎn)擊按鈕，并在斷點(diǎn)處中斷執(zhí)行一段時(shí)間
<5>然后你們連接到數(shù)據(jù)庫，分別查詢表的數(shù)據(jù)，發(fā)現(xiàn)不能執(zhí)行查詢操作。
<6>在同事機(jī)器點(diǎn)擊按鈕，查詢windows日志，發(fā)現(xiàn)了一些警告。這就證明了，事務(wù)在執(zhí)行過程中，獨(dú)占資源
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
unity3d?對(duì)接?workerman?實(shí)現(xiàn)聯(lián)機(jī)游戲功能
workerman?是一款開源高性能?PHP?應(yīng)用容器，他除了用于互聯(lián)網(wǎng)、即時(shí)通訊、APP?開發(fā)、硬件通訊、智能家居、物聯(lián)網(wǎng)等領(lǐng)域的開發(fā)外，這篇文章主要介紹了unity3d?對(duì)接?workerman?實(shí)現(xiàn)聯(lián)機(jī)游戲,需要的朋友可以參考下2022-10-10
這篇文章主要介紹了C# Datagridview綁定List方法代碼,在進(jìn)行C#數(shù)據(jù)庫程序設(shè)計(jì)時(shí)非常具有實(shí)用價(jià)值,需要的朋友可以參考下2014-10-10
本篇文章是對(duì)Silverlight跨線程的使用進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-05-05
這篇文章主要介紹了如何保存Unity中的Log日志的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2021-04-04
這篇文章主要介紹了C#中的基本循環(huán)：while循環(huán)、for循環(huán)和foreach循環(huán)，大家都知道循環(huán)結(jié)構(gòu)可以簡化程序編碼，更好地實(shí)現(xiàn)理想的效果,并結(jié)合案例給大家講解，需要的朋友可以參考下2015-07-07
C# 實(shí)現(xiàn)Trim方法去除字符串前后的所有空格
這篇文章主要介紹了C# 實(shí)現(xiàn)Trim方法去除字符串前后的所有空格，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-12-12
這篇文章主要介紹了C#多線程基礎(chǔ)知識(shí)的相關(guān)資料，文中示例代碼非常詳細(xì)，幫助大家更好的理解和學(xué)習(xí)，感興趣的朋友可以了解下2020-07-07
這篇文章主要給大家介紹了關(guān)于WPF通過線程使用ProcessBar的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用WPF具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
這篇文章主要介紹了C#操作注冊(cè)表的方法,結(jié)合實(shí)例形式較為詳細(xì)的分析了C#針對(duì)注冊(cè)表的創(chuàng)建、打開、讀取、寫入、修改、刪除等技巧,需要的朋友可以參考下2015-12-12
下面小編就為大家分享一篇C# 解壓gizp文件(.tgz)的實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2017-12-12