在操作數(shù)據(jù)庫(kù)的過程中，為了數(shù)據(jù)的一致性，我們可以使用Transaction，要么成功的時(shí)候全部提交，要么有任何一個(gè)操作失敗立即全部回滾。不僅僅是在數(shù)據(jù)庫(kù)方面，有時(shí)候操作其他的內(nèi)容，比如說對(duì)于系統(tǒng)文件的操作，也需要把一些操作組合看做是一個(gè)事務(wù)。

?

現(xiàn)在我們看這樣一個(gè)例子。現(xiàn)在我們需要在計(jì)算機(jī)的硬盤上創(chuàng)建3個(gè)目錄A，B，C，要求要么3個(gè)全部創(chuàng)建成功，要么一個(gè)也不要?jiǎng)?chuàng)建。我們可以把這個(gè)看成是一個(gè)事務(wù)。如果我們自己寫代碼來操作，可以這樣寫。

?

[csharp]?view plaincopy

bool?createA?=?false;??

bool?createB?=?false;??

bool?createC?=?false;??

??

try??

{??

????//這里的操作是創(chuàng)建3個(gè)目錄??

????Directory.CreateDirectory("\\A");??

????createA?=?true;??

????Directory.CreateDirectory("\\B");??

????createB?=?true;??

????Directory.CreateDirectory("\\C");??

????createC?=?true;??

}??

catch?(System.Exception?ex)??

{??

????//這里在捕捉到異常時(shí)，根據(jù)運(yùn)行的結(jié)果進(jìn)行回滾??

????if?(createB)??

????{??

????????Directory.Delete("\\B");??

????????Directory.Delete("\\A");??

????}??

????if?(!createB?&&?createA)??

????{??

????????Directory.Delete("\\A");??

????}??

}??

?

但是這里我們是把這3個(gè)操作當(dāng)成一個(gè)整體來回滾，及時(shí)是簡(jiǎn)單的創(chuàng)建刪除文件夾，我們可以看到catch中的回滾邏輯已經(jīng)很復(fù)雜了。可以想象，如果A，B，C這3步不僅僅是創(chuàng)建目錄，還有一些其他的操作，那么回滾的邏輯就非常復(fù)雜，此時(shí)，我們可以考慮把這一個(gè)分成幾個(gè)小事務(wù)，分開回滾。代碼可以這樣寫，這里我們使用了Framework提供的Transactin以及TransactioScope類。

?

[csharp]?view plaincopy

class?Program??

????{??

????????static?void?Main(string[]?args)??

????????{??

????????????//這里就不需要了try?catch,因?yàn)閟cope就已經(jīng)完成了這個(gè)功能，??

????????????//即當(dāng)有異常發(fā)生向外拋的時(shí)候，會(huì)嘗試跳出這個(gè)using代碼塊，??

????????????//CLR會(huì)在向代碼塊外邊跑異常之前，分別取調(diào)用每個(gè)transaction的??

????????????//roolback方法，只要rollback中你定義的邏輯沒有問題，那么所有??

????????????//的已發(fā)生的操作就會(huì)安全的回滾。??

????????????using?(var?scope?=?new?TransactionScope())??

????????????{??

????????????????var?A?=?new?OperationA();??

????????????????Transaction.Current.EnlistVolatile(A,?EnlistmentOptions.None);??

????????????????A.DoWork();??

??

????????????????OperationB?B?=?new?OperationB();??

????????????????Transaction.Current.EnlistVolatile(B,?EnlistmentOptions.None);??

????????????????B.DoWork();??

????????????????scope.Complete();??

????????????}??

????????}??

??

??

????}??

}??

??

class?OperationA?:?IEnlistmentNotification??

{??

????private?bool?_isCommitSucceed?=?false;??

??

????public?void?Commit(Enlistment?enlistment)??

????{??

????????enlistment.Done();??

????}??

??

????public?void?DoWork()//這是自定義的方法，不是繼承IEnlistmentNotification??

????{??

????????Directory.CreateDirectory("\\A");??

????????//這里還有一些其他的關(guān)于A的復(fù)雜操作??

????????_isCommitSucceed?=?true;??

????}??

??

????public?void?InDoubt(Enlistment?enlistment)??

????{??

????????enlistment.Done();??

????}??

????public?void?Prepare(PreparingEnlistment?preparingEnlistment)??

????{??

????????preparingEnlistment.Prepared();??

????}??

????public?void?Rollback(Enlistment?enlistment)??

????{??

????????//這里回滾A的一些操作，當(dāng)然這里的操作邏輯需要你自己來寫。??

????????//比如說查看是否創(chuàng)建成功，或者有一些其他的信號(hào)標(biāo)記，通過這些??

????????//標(biāo)記你來決定是刪除目錄還是其他的什么回滾操作。??

????????if?(_isCommitSucceed)??

????????????Directory.Delete("\\A");??

????????enlistment.Done();??

????}??

}??

??

class?OperationB?:?IEnlistmentNotification??

{??

????private?bool?_isCommitSucceed?=?false;??

??

????public?void?Commit(Enlistment?enlistment)??

????{??

????????enlistment.Done();??

????}??

??

????public?void?DoWork()??

????{??

????????//這里是關(guān)于B的一些復(fù)雜操作??

????????throw?new?Exception("test");??

????????//這里依然有一些操作代碼，但是我們模擬的是B操作途中拋出異常，所以這里的代碼不會(huì)執(zhí)行??

????}??

??

????public?void?InDoubt(Enlistment?enlistment)??

????{??

????????enlistment.Done();??

????}??

????public?void?Prepare(PreparingEnlistment?preparingEnlistment)??

????{??

????????preparingEnlistment.Prepared();??

????}??

????public?void?Rollback(Enlistment?enlistment)??

????{??

????????if?(_isCommitSucceed)??

????????{??

????????????//這里回滾B的一些已經(jīng)存在的操作。??

????????}??

????????enlistment.Done();??

????}??

這里的機(jī)制是這樣的，可能是scope.Complete()方法中有某種特別的操作，去告訴CLR這次所有的操作都順利完成了，在跳出這個(gè)scope的時(shí)候就不用調(diào)用那些transaction的rollback方法了。如果沒有執(zhí)行到scope.Complete()方法，那么就會(huì)在跳出這個(gè)scope代碼塊的時(shí)候調(diào)用rollback方法。一般造成這個(gè)的原因是在某個(gè)transaction的邏輯操作中出現(xiàn)異常，造成從此次直接拋出異常跳出這個(gè)代碼塊，沒有機(jī)會(huì)執(zhí)行下邊的代碼。可以看出這里的重點(diǎn)也是寫rollback的邏輯，但是相對(duì)于原來的catch中的邏輯，這里分開為多個(gè)小的邏輯，相對(duì)來說容易了很多。

這只是個(gè)人寫的一種使用回滾的邏輯。在使用IEnlistmentNotification的時(shí)候，也有人把業(yè)務(wù)邏輯寫入到Commit中。如果想真正理解transaction回滾的機(jī)制，建議深入理解一下TransactionScope與Transactiond的實(shí)現(xiàn)機(jī)制。

轉(zhuǎn)載于:https://www.cnblogs.com/sky6699/p/4535760.html

總結(jié)

以上是生活随笔為你收集整理的关于使用Transaction对于非数据库事务的操作的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。