1. 程式人生 > >Mysql事物與二階段提交

Mysql事物與二階段提交

 1.事務的四種特性(ACID)

事務可以是一個非常簡單的SQL構成,也可以是一組複雜的SQL語句構成。事務是訪問並且更新資料庫中資料的一個單元,在事務中的操作,要麼都修改,要麼都不做修改,這就是事務的目的,也是事務模型區別於其他模型的重要特徵之一。

事務的原子性:原子是不可分割的,事務不可分割(沒有commit資料不能被讀到).

事務的永續性:commit之後,不能丟資料.(就是在提交後,資料必須落盤redo落盤).

事務的隔離性:在資料庫裡面,各個事務之間不能互相影響.

事務的一致性:事務前後,不能違反mysql的約束.

 1.原子性(Atomicity)

原子性是指是事務是不可分割的一部分,一個事務內的任務要麼全部執行成功,要麼全部不執行,不存在執行一部分的情況。

可以將整個取款流程當做原子操作,要麼取款成功,要麼取款失敗。

1. 我們可以使用取錢的例子,來講解這一特性

2. 登入ATM機器

3. 從遠端銀行的資料庫中,獲取賬戶的資訊

4. 使用者在ATM上輸入欲取出的金額

5. 從遠端銀行的資料庫中,更新賬戶資訊

6. ATM機器出款

7. 使用者取錢

整個取錢操作,應該視為原子操作,要麼都做,要麼都不做,不能使用者錢還沒出來,但是銀行卡的錢已經被扣除了。使用事務模型可以保證該操作的一致性

 

 2.一致性(Consistency)

是指事務的完整性約束沒有被破壞,如果遇到了違反約束的情況,資料庫會被自動回滾。一致性是指資料庫從一種狀態轉變為另一種狀態。在開始事務和結束事務後,資料庫的約束性沒有被破壞。例如,資料庫表中的使用者ID列為唯一性約束,即在表中姓名不能重複.

 

 3.隔離性(isolation)

事物的隔離性要求每個事務的操作,不會受到另一個事務的影響。隔離狀態執行事務,使他們好像是系統在給定時間內執行的唯一操作
.這種屬性有時稱為序列化.

 4.永續性(Durability)

 事務一旦提交,那麼結果就是永續性的,不會被回滾。即使發生宕機,資料庫也可以做資料恢復。

說明:隔離性通過鎖實現,原子性、一致性、永續性通過資料庫的redoundo來完成

支援事務的資料庫:InnoDBNDBClusterTokuDB

不支援事務的資料庫:MyISAMMEMORY

 5.事物的實現

重做日誌(redo用來實現事務的永續性,有兩部分組成,一是記憶體中的重做日誌,一個是硬碟上的重做日誌檔案。innodb是支援事務的儲存引擎,通過日誌先行WAL,來實現資料庫的事務的特性,在一個事務提交的時候,並不是直接對記憶體的髒資料進行落盤,而是先把重做日誌緩衝中的日誌寫入檔案,然後再提交成功。這樣保證了即使在斷電的情況下,依然可以依靠redo log進行資料的恢復與重做。只要是提交的事務,在redo中就會有記錄,資料庫斷電後重啟,資料庫會對提交的事務,但是沒有寫入硬碟的髒資料,利用redo來進行重做。
還要一個保證事務的是undoundo有兩個作用:

1.實現事務的回滾

2.實現mvcc的快照讀取

redo是物理邏輯日誌,計算頁的物理修改操作.

undo是邏輯記錄,記錄了行的操作內容.

兩階段提交:先寫redo -buffer再寫binlog 並落盤最後落盤redo.


  6.lsn號

 LSNlog sequence number日誌序列號

檢視LSN資訊:  show engine innodb status\G;

LSN實際上對應日誌檔案的偏移量,新的LSN=舊的LSN + 寫入的日誌大小.

日誌檔案重新整理後,LSN不會進行重置

Log sequence number:當前系統LSN最大值,新的事務日誌LSN將在此基礎上生成(LSN1+新日誌的大小)

Log flushed up to:當前已經寫入日誌檔案的LSN

Pages flushed up to:當前最舊的髒頁資料對應的LSN,Checkpoint的時候直接將此LSN寫入到日誌檔案

Last checkpoint at:當前已經寫入CheckpointLSN


 7.redo作用總結
 redo作用

Redo介紹:

1. DML操作導致的頁面變化,均需要記錄Redo日誌(物理日誌)

2. 在頁面修改完成之後,在髒頁刷出磁碟之前,寫入Redo日誌;

3. 日誌先行(WAL),日誌一定比資料頁先寫回磁碟;

4. 聚簇索引/二級索引/Undo頁面修改,均需要記錄Redo日誌;

為了管理髒頁,在 Buffer Pool 的每個instance上都維持了一個flush listflush list 上的 page 按照修改這些page LSN號進行排序。因此定期做redo checkpoint點時,選擇的 LSN 總是所有 bp instance  flush list 上最老的那個page(擁有最小的LSN)。由於採用WAL

策略,每次事務提交時需要持久化 redo log 才能保證事務不丟。而延遲刷髒頁則起到了合併多次修改的效果,避免頻繁寫資料檔案造成的效能問題。

REDO的作用:提高效能和做crash recovery

提高效能:

1. 日誌用來記錄buffer pool中頁的page修改的,每次資料提交只要寫redo日誌就可以,不需要每次都寫髒頁。

2. 通常一個數據頁是16KB,如果不寫日誌,每次的寫入還是16kb,即使修改很少資料,仍然要全部落盤,效能影響非常嚴重。

3. 如果沒有日誌,每次都會刷髒頁,髒頁的位置導致的IO是隨機IO,而redo的資料頁的大小是512位元組,這樣非常契合硬碟的塊大小,可以進行順序IO,這樣可以保證順序IO,同時可以大大提高IOPS

crash recovery:

1. 資料庫重啟後,利用redo log進行資料庫恢復工作,比對redolog LSN和資料頁的LSN,如果資料頁LSN低於REDO LOG LSN就會進行資料頁例項恢復

  8.undo 作用
1. 用於回滾事務

2. 保證mvcc多版本高併發控制

innodbundo分為兩類

1. 新增undo

2. 修改undo

分類依據就是是否需要做purge操作.

insert在事務執行完成後,回滾記錄就可以丟掉了。但是對於更新和刪除操作而言,在完成事務後,還需要為MVCC提供服務,這些日誌就被放到一個history list,用於MVCC以及等待purge

undo日誌的正確性是通過redo來保證的,所以在資料庫恢復的時候,需要先恢復redo,在所有資料塊都保證一致性的情況下,在進行undo的邏輯操作。

9.檢查點(checkpoint)

檢查點就是落髒頁的點,本質是一個特殊的lsn.

檢查點解決的問題:

1. 縮短資料庫恢復時間

2. 緩衝池不夠用的時候,重新整理髒頁到磁碟

3. 重做日誌不夠用的時候,重新整理髒頁

當資料庫發生宕機的時候,資料庫不需要恢復所有的頁面,因為檢查點之前的頁面都已經重新整理回磁碟了。故資料庫只需要對檢查點以後的日誌進行恢復,這就大大減少了恢復時間。

檢查點的型別:

檢查點分為兩種型別,一種是sharp檢查點,一種是fuzzy檢查點

sharp checkpoint落盤條件:

1. 關閉資料庫的時候設定 innodb_fast_shutdown=1,在關閉資料庫的時候,會重新整理所有髒頁到資料庫內。

fuzzy checkpoint在資料庫執行的時候,進行頁面的落盤操作,不過這種模式下,不是全部落盤,而是落盤一部分資料。

Fuzzy落盤的條件:

1. master thread checkpoint: master每一秒或者十秒落盤

2. sync check point: redo 不可用的時候,這時候重新整理到磁碟是從髒頁連結串列中重新整理的。

3. Flush_lru_list check point : 重新整理flush list的時候

落盤的操作是非同步的,因此不會阻塞其他事務執行。

檢查點的作用:

縮短資料庫的恢復時間

緩衝池不夠用的時候,將髒頁重新整理到磁碟

重做日誌不可用的時候,重新整理髒頁(迴圈使用redo檔案,當舊的redo要被覆蓋的時候,需要重新整理髒頁,造成檢查點)

10.兩階段提交

 MySQL二階段提交流程:

事務的提交主要分三個主要步驟:

1.Storage EngineInnoDB transaction prepare階段:儲存引擎的準備階段,redo-buffer

此時SQL已經成功執行,並生成xid資訊及redoundo的記憶體日誌。

2.Binary log日誌提交:寫binlog並落盤.

write()binary log記憶體日誌資料寫入檔案系統快取。

fsync()binary log檔案系統快取日誌資料永久寫入磁碟。

3.Storage EngineInnoDB)內部提交:落盤redo日誌.

修改記憶體中事務對應的資訊,並且將日誌寫入重做日誌緩衝。

呼叫fsync將確保日誌都從重做日誌緩衝寫入磁碟。

一旦步驟2中的操作完成,就確保了事務的提交,即使在執行步驟3時資料庫傳送了宕機。

binlog落盤成功,就算redo未落盤成功,那麼事務也算是提交成功了.

binlog落盤條件:引數sync_binlog: 0每秒落盤,1每次commit落盤  n 每n個事物落盤

此外需要注意的是,每個步驟都需要進行一次fsync操作才能保證上下兩層資料的一致性。步驟2fsync引數由sync_binlog控制,步驟2fsync由引數innodb_flush_log_at_trx_commit控制。(1配置)

兩階段提交:先寫redo -buffer再寫binlog 並落盤最後落盤redo-buffer.

最終:mysql在落盤日誌的時候,先落盤binlog,再落盤redo.

  11.Rollback過程
當事務在binlog階段crash,此時日誌還沒有成功寫入到磁碟中,啟動時會rollback此事務。

當事務在binlog日誌已經fsync()到磁碟後crash,但是InnoDB沒有來得及commit,此時MySQL資料庫recovery的時候將會從二進位制日誌的XidMySQL資料庫內部分散式事務XA)中獲取提交的資訊重新將該事務重做並commit使儲存引擎和二進位制日誌始終保持一致。

總結起來說就是如果一個事物在prepare log階段中落盤成功,並在MySQL Server層中的binlog也寫入成功,那這個事務必定commit成功。

12.事物隔離級別

       隔離級別                        事物                問題         縮寫
READ UNCOMMITED        未提交讀           髒讀          RU
READ COMMITED              提交讀             幻讀           RC
REPEATEABLE READ          可重複讀                            RR
SERIALIZABLE                    序列化

使用RR級別的話,可以保證資料庫沒有幻讀,但是在該模式下,會增加鎖競爭,造成資料庫併發能力的下降。在RC模式下,沒有next_lock的存在,即使在沒有索引的情況下,也很難造成大規模的鎖表而導致的死鎖問題。

13.自動提交引數設定

Mysql自動提交 (mysqlmysql客戶端是自動提交,但是java python裡面不自動提交)

取消自動提交set autocommit=off;   

14.檢視mysql隔離級別

  show variables like '%iso%';

 

15.修改事物隔離級別

設定全域性引數:

set global transaction isolation level read uncommitted;

Set global transaction isolation level read committed;

Set global transaction isolation level repeatable read;

設定會話級別引數:

set session transaction isolation level read uncommitted;

Set session transaction isolation level read committed;

Set session transaction isolation level repeatable read;

檢視全域性的MySQL GLOBAL的配置的隔離級別。

global引數設定後,需要新開啟session才能生效.

 4.事務隔離級別對應問題:(髒讀,幻讀,不可重複讀)

RU                             ---------     產生髒讀問題                

RC         ----------  解決髒讀問題,但產生幻讀和不可重複讀問題.

RR           ---------  避免幻讀和不可重複讀問題.,待容易鎖等待.

SERIALIZABLE     -----------序列化,序列讀寫.

 REPEATEABLE READ下,其他事務對於資料的修改(updatedelete)不會影響本事務對於資料的讀取,會避免幻讀的產生,幻讀就是在一個事務內,讀取到了不同的資料行數結果。

資料越安全,相對來說,資料庫的併發能力越弱(並不代表總體效能越弱)。

髒讀(Drity Read):事務T1修改了一行資料,事務T2在事務T1提交之前讀到了該行資料。

不可重複讀(Non-repeatable read): 事務T1讀取了一行資料。 事務T2接著修改或者刪除了該行資料,當T1再次讀取同一行資料的時候,讀到的資料時修改之後的或者發現已經被刪除。(針對update/delete操作).

READ COMMITED下,未被提交的事務不會被讀到,只有被提交的事務的資料,才會被讀取到。(執行兩次相同的SQL得到了不同的結果。),這就造成了幻讀和不可重複讀問題.

幻讀(Phantom Read): 事務T1讀取了滿足某條件的一個數據集,事務T2插入了一行或者多行資料滿足了T1的選擇條件,導致事務T1再次使用同樣的選擇條件讀取的時候,得到了比第一次讀取更多的資料集。(針對insert操作).

幻讀和可重複讀的區別:

幻讀更多的是針對於insert來說,即在一個事務之中,先後的兩次select查詢到了新的資料,新的資料來自於另一個事務的insert,一般稱之為幻讀,通過gap_lock(間隙鎖)來防止產生幻讀(雖然record可以避免資料行被修改,但是卻無法阻止insertgap_lock鎖定索引間隙,防止了在事務查詢的範圍內的insert情況)

ru隔離級別下造成髒讀,rc隔離級別下造成幻讀和不可重複讀.

可重複讀:一般是針對於updatedelete來說,可重複讀採用了mvcc多版本控制來實現資料查詢結果本身的不變。

 5.事物隔離級別示例

 

 1.ru(READ-UNCOMMITED 未提交讀)

 Ru級別造成了髒讀:  session2可以讀取到session1的沒有提交的事務的資料(記憶體中沒有提交的髒頁).

髒讀的發生至少在RU下,而目前幾乎所有的資料庫幾乎都在RC級以上的隔離界別上。

髒讀例項:

兩個session修改隔離級別:  set session transaction isolation level read uncommitted;

session1                         session2

begin;                           begin;

insert into t1 values(null,'testru')

                          select * from test1.t1;#查詢到了testru資料,造成了髒讀

commit;                                          commit;

########################################################

 2.rc(read committed 已提交讀)

Rc級別解決了髒讀.但會造成不可重複讀和幻讀.兩者發生方式一樣,但由於解決方法不同而區分.

解決了髒讀例項:(針對select.)

修改隔離級別:   Set session transaction isolation level read committed;

session1                                     session2

begin;                                        begin;

insert into test1.t1 values(null,'testrc');   

                                  select * from test1.t1;#沒有查到

commit;

                                 select * from test1.t1; 查詢到了

                                           commit;

################################################################

不可重複讀:針對於update/delete來說.

幻讀:針對於insert來說的.

 幻讀例項:  Set session transaction isolation level read committed;                              

#####################################################

session1                         session2

begin;                           begin;

                               select * from test1.t1;--7

insert into t1 values()

commit;        

                               select * from test1.t1 --8

                                commit;

#####################################################

不可重複讀例項:  Set session transaction isolation level read committed;  

session1                         session2

begin;                           begin;

                           select * from test1.t1 where name=’aa’;--找到1

Update t1 set name=’bb’ where name=’aa’;

commit;        

                             select * from test1.t1 where name=’aa’ --沒有找到.

                               commit;

###################################################################

加鎖例項1:(加鎖只針對指定的行,不影響update/insert操作)

Set session transaction isolation level read committed;

session1                               session2

begin;                                 begin;

                                    update  test1.t1 set name='bbb' ;

insert into test1.t1 values(null,'test_rr') 加了鎖,但插入成功.

commit;        

                                 select * from test1.t1  1000w+1   

                                      Commit;                                            

#############################################################################

 3.rr(repeatable read 可重複讀)

RR隔離級別:可重複讀 .repeatable read

RR模式下GAP_LOCK是預設開啟的.

避免幻讀例項:(insert)

set session transaction isolation level repeatable read;

session1                           session2

begin;                             begin;

                                select * from test1.t1;

insert into t1 values(null,'testrr');

commit;

                            select * from test1.t1;查詢不到testrr

                                  commit;

                             select * from test1.t1;查詢到testrr

####################################################

避免不可重複讀例項:(update /delete)

set session transaction isolation level repeatable read;

session1                          session2

begin;                             begin;

                               select * from test1.t1;

update test1.t1 set name='testrr_upd' where name='testrr'

commit;

                           select * from test1.t1;查詢不到testrr_upd

 

                                 commit;

                           select * from test1.t1;查詢到testrr_upd

###################################################################

鎖等待例項:(一定會鎖,update,除了select,其他操作如insert/update都會被鎖.)

set session transaction isolation level repeatable read;

session1                                   session2

begin;                                     begin;

                                     update  test1.t1 set name='ccc';

insert into test1.t1 values(null,'test_rr')插入被阻塞,進入鎖等待狀態

                                         commit;        

 commit;  

                                  select * from test1.t1  1000w+1                                          

###################################################################

 

 5.MVCC的簡單實現

MVCCMySQLInnoDB中的實現原理基於UNDO的多版本快照日誌

MySQL InnoDB儲存引擎,實現的是基於多版本的併發控制協議——MVCC (Multi-Version Concurrency Control)

(注:與MVCC相對的,是基於鎖的併發控制,Lock-Based Concurrency Control)

 1.MVCC的好處:讀不加鎖,讀寫不衝突.

讀不加鎖,讀寫不衝突。在讀多寫少的OLTP應用中,讀寫不衝突是非常重要的,極大的增加了系統的併發效能,這也是為什麼現階段,幾乎所有的RDBMS,都支援了MVCC

 2.讀的型別:快照讀和當前讀.

MVCC併發控制中,讀操作可以分成兩類:快照讀 (snapshot read)與當前讀 (current read)

快照讀: 讀取的是記錄的可見版本 (有可能是歷史版本),不用加鎖。例如 select 就為快照讀.

當前讀:讀取的是記錄的最新版本,並且,當前讀返回的記錄,都會加上鎖,保證其他事務不會再併發修改這條記錄。例如刪除/更新/刪除操作。

過程MVCC讀取資料的過程中,會先對目前的事務和資料行的事務號進行對比,如果發現事務行的事務版本號,已經增長,則說明該行資料已經被其他事務修改,那麼就需要根據undo,讀取undo內的歷史版本的相關邏輯操作資訊,然後根據邏輯操作資訊構建符合當前查詢的資料版本,然後返回結果集(在RCRR模式下,對於UNDO構建資料塊的版本選擇不同)

通過MVCC雖然每行記錄都需要額外的儲存空間,更多的行檢查工作以及一些額外的維護工作,但可以減少鎖的使用,大多數讀操作都不用加鎖,讀資料操作很簡單,效能很好,並且也能保證只會讀取到符合標準的行,也只鎖住必要行。

 3.一致性非鎖定讀

一致性的非鎖定讀就是INNODB儲存引擎通過行多版本控制的方式來讀取當前執行時間資料庫中的資料。如果讀取的行正在執行DELETE或者UPDATE,這個時候讀取操作不會等待所在行的鎖的釋放。INNODB這個時候會讀取一個快照資料。(若讀的資料加鎖了,則讀取其前一個版本的undo日誌。)

一致性非鎖定讀取的原理是這樣的:

Innodb通過隱藏的回滾指標儲存前一個版本的undo日誌,通過當前記錄加上undo日誌可以構造出記錄的前一個版本,從而實現同一記錄的多個版本。

快照資料就是當前資料行的歷史版本,每個行記錄可能有多個版本

RC模式下,MVCC會一直讀取最新的快照資料。

RR模式下,MVCC會讀取本事務開始時候的快照資料。

對於一致性非鎖定讀取,即使被讀取的行已經SELECT ⋯ FOR UPDATE,也是可以進行讀取的。

 

  4.一致性鎖定讀取

有些使用者需要採用鎖定讀取的方式來進行讀取保證資料的一致性。

手動在查詢中新增鎖

查詢中使用S:

select * from test1.t1 where id=1 lock in share mode;

查詢中新增X:

select * from test1.t1 where id=1 for update;

關於鎖等待的引數:引數支援範圍為SessionGlobal,並且支援動態修改

事務等待獲取資源等待的最長時間,超過這個時間還未分配到資源則會返回應用失敗。

設定鎖等待時間引數: innodb_lock_wait_timeout 30  --單位秒.

  鎖

Mysql鎖加在索引上.

鎖的作用:將並行的事務變成序列的.

從鎖的顆粒度來說,鎖分:表鎖頁鎖,  行鎖。

MySQL中鎖的概念可以等同於:併發控制,序列化,隔離性.

這種用隔離性來描述鎖,就是因為是事務ACID特性中的I,而鎖就是用來實現事務一致性和隔離性的一種常用技術。

當資料庫事務併發各自執行的時候,每個事務的執行不受到其他事務的影響。

簡單的加鎖技術就是對物件加上一個鎖,若訪問該事務的時候,發現已經有鎖,則等待該事務鎖的釋放。

通過多粒度鎖定,保證了資料庫中事務的併發性。

 1.意向鎖

意向鎖:打算向這個表裡的資料加鎖,會提前在表級別加一個意向鎖,加在聚簇索引的根節點.

1. 揭示下一層級請求的鎖的型別

2. IS:事物想要獲得一張表中某幾行的共享鎖

3. IX:事物想要獲得一張表中某幾行的排他鎖

4. InnoDB儲存引擎中意向鎖都是表鎖

假如此時有 事物tx1 需要在 記錄上進行加 X鎖 :

1. 在該記錄所在的資料庫上加一把意向鎖IX 2. 在該記錄所在的表上加一把意向鎖IX

3. 在該記錄所在的頁上加一把意向鎖IX

4. 最後在該記錄A上加上一把X

假如此時有 事物tx2 需要對 記錄B (假設和記錄A在同一個頁中)加 S鎖 :

1. 在該記錄所在的資料庫上加一把意向鎖IS 2. 在該記錄所在的表上加一把意向鎖IS

3. 在該記錄所在的頁上加一把意向鎖IS

4. 最後在該記錄B上加上一把S

加鎖是從上往下,一層一層 進行加的.

意向鎖存在意義:

· 意向鎖是為了實現多粒度的鎖,表示在資料庫中不但能實現行級別的鎖,還可以實現頁級別的鎖,表級別的鎖以及資料庫級別的鎖

· 如果沒有意向鎖,當你去鎖一張表的時候,你就需要對錶下的所有記錄都進行加鎖操作,且對其他事物剛剛插入的記錄(遊標已經掃過的範圍)就沒法在上面加鎖了,此時就沒有實現鎖表的功能。

IXIS是表級鎖,不會和行級的XS鎖發生衝突。只會和表級的XS發生衝突,行級別的XS按照普通的共享、排他規則即可。所以只要寫操作不是同一行,就不會發生衝突。

InnoDB 沒有資料庫級別的鎖,也沒有頁級別的鎖(InnoDB只能在表和記錄上加鎖),所以InnoDB的意向鎖只能加在表上,即InnoDB儲存引擎中意向鎖都是表鎖.

 2.行鎖(X和S鎖)

對於行鎖,根據其作用型別,可以分為兩類:

共享鎖(S lock) ,允許讀取一個數據,同時允許其他事務對該事務進行更改。

排他鎖(X lock),允許刪除或者更新一條資料,同時不允許其他事務對該事務進行操作。

鎖相容:當一行獲取S鎖的時候,也可以獲取另一個事務的S鎖,這稱之為鎖相容.