亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

SQL點滴9—SQL Server中的事務處理以及SSIS中的

系統 1806 0
原文: SQL點滴9—SQL Server中的事務處理以及SSIS中的內建事務

我們可以把SSIS中的整個package包含在一個事務中,但是如果在package的執行過程中有一個表需要鎖定應該怎么處理呢?SSIS內建的事務處理可以解決這個問題。在此之前首先來熟悉一下SQL Server中的事務的概念。

?

事務

SQL Server中的事務是單個的工作單元。如果某一事務成功,則在該事務中進行的所有數據修改均會提交,成為數據庫中永久的組成部分。如果事務遇到錯誤且必須取消或回滾,則所有的數據修改均被清除。

在SQL Server中使用事務有可能會造成一些預想不到的結果,具體來說有臟讀,不可重復讀和幻讀三種結果。

  • 臟讀 :臟讀是指當一個事務正在訪問數據庫,并且對數據進行修改,而這種修改還沒有提交到數據庫中,另外一個事務也在訪問這個數據,然后使用了這個數據。
  • 不可重復讀 :在一個事物內多次讀同一數據。在這個事務還沒有結束時,另外一個事物也在訪問該同一數據,那么在第一個事務兩次讀取之間,由于第二個事務的修改,第一個事務兩次讀取到的數據可能不一樣。這樣就發生了在一個事務內兩次讀取到的數據不一樣,因此稱為不可重復讀。
  • 幻讀 :幻讀是指當事務不是獨立執行時發生的一種現象,例如第一個事務對一個表中的數據進行修改,這種修改設計到表中的全部數據行。同時第二個事務也修改這個表中的數據,這個修改時向同一個表中插入一行新數據,這樣第一個事務的用戶發現還有一條數據沒有修改,像發生了幻覺一樣,因此稱為幻讀

在SQL Server中給事務指定一個隔離級別,這個隔離級別定義該事務與其他事務進行資源或數據更改相隔離的級別。事務隔離級別決定了是否鎖定SQL Server對象,下面是SQL Server中的事務隔離級別。

  • Rdad Uncommitted : 讀取數據不需要等待解鎖,這種方式會讀到臟數據,因為讀取的數據有可能是還沒有更新的數據。這種隔離級別最低,會造成臟讀,不可重復讀和幻讀的結果,并發性最高。
  • Read Committed : 讀取數據需要等待解鎖,這樣會讀取到最新的被更新的數據。Read Committed不會造成臟讀的問題,但是會造成不可重復的和幻讀的問題。Read Committed是SQL Server的默認設置。
  • Repeatable Read : 與Read Committed類似,它會鎖定所讀取的所有行,但是沒有其他的連接可以更新或插入數據,這樣如果select語句可能選擇到這條新跟新或插入的數據,這條數據記錄是不會出現在select結果中的。同時被選擇出的數據也不能被其他連接更改,直到讀取動作執行結束或者回滾結束。這種隔離級別不會造成臟讀和不可重復讀,但是會造成幻讀。
  • Serializable :和Repeatable Read類似,不過沒有其他的連接可以插入或更新數據,同時如果在下次查詢中任然使用這種事務隔離級別,你會得到相同的查詢結果,就是說更新或新插入的數據任然不會出現在查詢結果中。這種隔離級別不會造成臟讀,不可重復讀或幻讀。

還有兩種是SQL Server 2005中新添加的事務隔離級別

  • 一種Read Committed級別的變異,當你把數據庫的隔離級別設置成READ_COMMITTED_SNAPHOT,任何使用Read Committed級別的的事務不再需要鎖定數據對象。執行語句時會得到select語句開始執行之時會得到所有最新的結果。
  • SNAPSHOT :一種全新的級別SNAPSHOT,當你在任何數據庫對象中設置事務的隔離級別為ALLOW_SNAPSHOT_ISOLATION時,其他事務都不會遇到共享鎖,查詢結果會得到所有更新之后的行。這種隔離級別不會造成臟讀,不可更新讀和幻讀的結果

?所有上述的事務處理都在tempdb數據庫中一個類似版本庫的數據對象中自動進行,當遇到更新未被提交的情況,數據引擎會檢索這個版本庫得到合適的提交結果。維護這個版本庫的工作由SQL Server自動進行,不需要人為干預。

??

SSIS中的事務處理

SSIS中的包,容器(例如Loop,Foreach Loop,Sequence)或者一個單獨的任務中都可以設置事務處理選項。事務處理選項有下面一些值??????         

  • Required-如有事務則添加,否則新添加一個
  • Supported-如有有事務添加一個,沒有則不添加,這是默認選項+
  • NotSupported-不添加事務處理

內建的事務處理要使用Distributed Transaction Coordinator(MSDTC)服務,這個服務必須開啟。MSDTC允許使用分布式事務處理,例如在一個事務中同時處理SQL Server數據庫和Oracle數據庫。如果沒有開啟這個服務會得到下面的錯誤提示.

Error: 0xC001401A at Transaction: The SSIS Runtime has failed to start the distributed transaction due to error 0x8004D01B "The Transaction Manager is not available.". The DTC transaction failed to start. This could occur because the MSDTC Service is not running.

注意SSIS中包中的元素的事務隔離級別是Serializable,這種級別會影響鎖的持續時間。下面我們來用一個例子說明在如何package中鎖定一個表

  1. 新建一個SequenceContainer,命名為Test Initialization。
  2. 這個SequenceContainer主要用來創建測試的環境,創建連個表TranQueue,TranQueueHistory,向第一個表中添加一條記錄,這樣模擬一個事物處理  過程。我們只是使用這個SequenceContainer來創建測試環境,所以設置它的TransactionOption選項為NotSupported在這個SequenceContainer中依次添加三個Execute SQL,依次他們的設置如下?
              
    1 /* 命名 */
    2 Create TranQueue Table
    3 /* SQLstatement設置 */
    4 IF NOT EXISTS ( SELECT * FROM sys.objects WHERE object_id =
    5
    6 OBJECT_ID (N ' dbo.TranQueue ' ) AND type in (N ' U ' ) )
    7 BEGIN
    8 execute ( ' CREATE TABLE dbo.TranQueue(message nvarchar(256)) ' )
    9 END
    10 /* 命名 */
    11 Populate TranQueue
    12 /* SQLstatement設置 */
    13 INSERT INTO dbo.TranQueue VALUES ( ' Test Message ' + CONVERT
    14
    15 ( NVARCHAR ( 23 ), GETDATE (), 121 ))
    16 /* 命名 */
    17 Create TranQueueHistory table
    18 /* SQLstatement設置 */
    19 IF NOT EXISTS ( SELECT * FROM sys.objects WHERE object_id =
    20
    21 OBJECT_ID (N ' dbo.TranQueueHistory ' ) AND type in (N ' U ' ) )
    22 BEGIN
    23 execute ( ' CREATE TABLE dbo.TranQueueHistory(message nvarchar(256)) ' )
    24 END
  3. 創建第二個SequenceContainer,命名為Process,TransactionOption屬性設置為Supported,這樣就會添加事務處理。??
  4. 在這個SequenceContainer中添加一個Execute SQL,命名為ProcessTranQueue,它的SQLStatement設置為下面的語句。這個語句的作用,模擬事務處理,刪除TranQueue表中前10條數據;OUTPUT字句將刪除的數據插入到TranQueueHistory表中,模擬處理結束,更新歷史記錄
              
    1 DELETE TOP ( 10 ) dbo.TranQueue
    2 OUTPUT DELETED. *
    3 INTO dbo.TranQueueHistory
    4 FROM dbo.TranQueue WITH (TABLOCKX)
  5. 添加一個Execute SQL,命名為Placeholder for Breakpoint。這個任務不進行任何操作,只是為了在這設置一個斷點然后在這里停下來讓我們有時間驗證是否會鎖定表。
  6. 右擊Control Flow界面添加一個變量v_SimulateFailure,類型為Int32,值為1。
  7. 添加一個Execute SQL命名為Simulate Failure。用它來模擬錯誤,設置SQLStatement為select 1/0,當pacakage執行到這里的時候會造成錯誤進而回滾。
  8. 右擊Placeholder for Breakpoint和Simulate Failure之間的連線,點擊Edit,設置Evaluation operation為Expression and Constraint,設置Expression為@[User::v_SimulateFailure] == 1,其他保持默認。這樣之后這個自定義變量的值為1的時候才會繼續往下執行。
  9. 執行package,會得到如圖1的結果,package在斷點處終止。

? SQL點滴9—SQL Server中的事務處理以及SSIS中的內建事務 ?圖1???????????????

10.打開SQL Server Management Studion,選擇對應的數據庫,新建一個Query,執行下面的語句,NOLOCK選項忽略鎖,這個語句查詢得到一條記錄 Message2011-04-10 14:22:31.043,但是這條記錄并沒有提交

      
        1
      
      
        SELECT
      
      
      
      
        *
      
      
      
      
        FROM
      
      
         dbo.TranQueueHistory 
      
      
        WITH
      
      
         (NOLOCK)
      
    

11.執行下面的語句

      
1 SELECT * FROM dbo.TranQueue

語句將阻塞在這里,語句一直停留在執行狀態,不會結束。因為在Process TranQueue任務中我們使用TABLOCKX,在這里將等待任務回滾或者提交。或者可以寫成這樣,它任然會阻塞

      
1 DELETE TOP ( 10 ) dbo.TranQueue
2 ? INSERT INTO dbo.TranQueueHistory VALUES ( ' Test Message ' + CONVERT ( NVARCHAR ( 23 ), GETDATE (), 121 ))

12.?點擊Continue按鈕或者Debuge按鈕,會看到package執行失敗,執行SELECT * FROM dbo.TranQueueHistory

?????? WITH (NOLOCK);因為執行了回滾,不會得到任何結果。SELECT * FROM dbo.TranQueue,任然有一條記錄。?

      
        SELECT
      
      
      
      
        *
      
      
      
      
        FROM
      
      
         dbo.TranQueueHistory 
      
      
        WITH
      
      
         (NOLOCK)
      
    

   NOLOCK提示忽略鎖,這個語句查詢得到一條記錄 Message2011-04-10 14:22:31.043,但是這條記錄并沒有提交

13.? 執行下面的語句,

      
        SELECT
      
      
      
      
        *
      
      
      
      
        FROM
      
      
         dbo.TranQueue
      
    

sql語句將阻塞在這里,語句一直執行。因為在Process TranQueue任務中我們使用TABLOCKX,在這里將等待任務回滾或者提交。或者可以寫成這樣

DELETE TOP(10) dbo.TranQueue;INSERT INTO dbo.TranQueueHistory VALUES ('Test Message' + CONVERT(NVARCHAR(23), GETDATE(), 121)),它任然會阻塞??????

14.??點擊Continue按鈕或者Debuge按鈕,會看到package執行失敗,執行SELECT * FROM dbo.TranQueueHistory?WITH (NOLOCK);因為執行了回滾,不會得到任何結果。執行SELECT * FROM dbo.TranQueue,任然有一條記錄。

?????

如果設置變量User::v_SimulateFailure的值為0,不會執行Simulate Failure任務,就不會回滾,TranQueue中的記錄會被寫入到TranQueueHistory中。這里有一個很有意思的語句:

DELETE TOP(10) dbo.TranQueue
OUTPUT DELETED.*
INTO dbo.TranQueueHistory
FROM dbo.TranQueue WITH (TABLOCKX)

如果兩個表的結構有一部分是是一樣的,現在想把一個表的數據導入到另外一個表中,可以使用DELETE SourceTable?OUTPUT DELETE.*/DELETE.Column1,DELETE.Column2... INTO DestinationTable FROM SourceTable,這樣第一個表中的數據會被“剪切”到第二個表中。

SQL點滴9—SQL Server中的事務處理以及SSIS中的內建事務


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 亚洲综合一区二区精品久久 | 四虎澳门永久8848在线影院 | 四虎论坛 | 亚洲精品第四页中文字幕 | 亚洲天天网综合自拍图片专区 | 四虎永久在线精品 | 天天射天天干天天操 | 日本一级毛片一级裸片 | 亚洲国产欧美日韩一区二区三区 | 国产精品视频福利 | 国产91一区二这在线播放 | 亚洲精品国产福利片 | 毛片女人毛片一级毛片毛片 | 国产一区二区三区免费 | 模特视频一二三区 | 992人人草| 精品一久久香蕉国产线看播放 | 国产在视频线精品视频2021 | 2018一级毛片免费观看 | 综合黄色 | 国产成人亚洲精品 | 国产精自产拍久久久久久蜜 | 天堂国产 | 久久―日本道色综合久久 | 又粗又大的机巴好爽视频视频 | 亚洲欧美中文日韩综合 | 久久一区精品 | 一级肉体毛片视频免费看看 | 国产精品久久久久久久久齐齐 | 偷偷操网站 | 伊人久久丁香色婷婷啪啪 | 国产成人精品三级91在线影院 | 欧美一区二区在线观看视频 | 最新四虎4hu影库地址在线 | 亚洲国产综合久久精品 | 国产一区二区三区在线观看视频 | 丁香六月色婷婷 | 俺去也理论网站 | 亚洲香蕉在线观看 | 日本不卡三区 | 奇米在线观看视频 |