基於Postgresql 事務的提交與回滾解析
用過oracle或mysql的人都知道在sqlplus或mysql中,做一個dml語句,如果發現做錯了,還可以rollback;掉,但在PostgreSQL的psql中,如果執行一個dml,沒有先執行begin;的話,一執行完就馬上提交了,不能回滾,這樣容易導致誤操作的發生,有沒有什麼辦法避免這個風險呢?
當然有,在psql中預設是開啟自動提交的,我們可以關閉自動提交,方法如下:
設定\set AUTOCOMMIT off
test=# create table test1 (x int); CREATE TABLE Time: 0.593 ms test=# select * from test1; x --- (0 rows) Time: 0.309 ms test=# rollback; ROLLBACK Time: 1.501 ms test=# select * from test1; ERROR: relation "test1" does not exist LINE 1: select * from test1; ^ Time: 0.376 ms
這兒我們需要注意的是,不同步Oracle,PG的DDL事務一樣是可以回滾的,並沒有隱式提交的概念,這兒我們需要注意下
test=# \d List of relations Schema | Name | Type | Owner --------+------+-------+------- public | foo | table | kiwi public | test | table | kiwi (2 rows)
補充:PostgreSQL-事務與commit優化
基本概念
事務 Transaction 是 資料庫管理系統DBMS 執行過程中的一個邏輯單元,是一個 sql命令組成的序列。
其特點在於,當事務被提交DBMS後,DBMS需要確保所有的操作被完成;如果事務中有的操作沒有成功完成,那麼所有操作都將回滾,回滾到事務提交之前的狀態
屬性
事務具有以下四個標準屬性
原子性:事務作為一個整體被執行,相當於一個原子
一致性:確保修改前後資料庫都滿足約束
隔離性:多個事務能併發執行,互不影響
永續性:已被提交的事務對資料庫的修改應該永久儲存在資料庫中
適用場景
某人在商店使用電子貨幣支付100元,包括以下兩個操作:
1. 消費者賬戶減少100元
2. 商家賬戶增加100元
事務的作用就是保證這兩個操作要麼都發生,要麼都不發生,否則可能出現100元憑空消失。
事務控制
使用如下命令控制事務
begin 或者 begin transaction:開始一個事務
commit 或者 end transaction:提交事務,執行一系列sql
rollback:事務回滾
在開始一個事務後,除非遇到 commit 或者 rollback 命令,事務才會被執行;
如果還沒遇到 commit 或者 rollback,資料庫發生異常,也會自動回滾。
注意,事務命令只能用於 insert、delete、update 操作,而其他命令,比如建表、刪表,會被自動提交。
總結一下:事務需要手動開啟,手動提交;而且這種方式能提高操作效率。
例項
假設有如下表
id | name | age | address | salary ----+-------+-----+-----------+-------- 1 | Paul | 32 | California| 20000 2 | Allen | 25 | Texas | 15000 3 | Teddy | 23 | Norway | 20000 4 | Mark | 25 | Rich-Mond | 65000 5 | David | 27 | Texas | 85000 6 | Kim | 22 | South-Hall| 45000 7 | James | 24 | Houston | 10000
操作1:開始事務,從表中刪除年齡為25的記錄,最後用rollback撤銷所有操作
runoobdb=# BEGIN; DELETE FROM COMPANY WHERE AGE = 25; ROLLBACK;
結果如下
id | name | age | address | salary ----+-------+-----+-----------+-------- 1 | Paul | 32 | California| 20000 2 | Allen | 25 | Texas | 15000 3 | Teddy | 23 | Norway | 20000 4 | Mark | 25 | Rich-Mond | 65000 5 | David | 27 | Texas | 85000 6 | Kim | 22 | South-Hall| 45000 7 | James | 24 | Houston | 10000
我們發現原表沒有任何改變
操作2:開始事務,從表中刪除年齡為25的記錄,最後用commit提交事務
runoobdb=# BEGIN; DELETE FROM COMPANY WHERE AGE = 25; COMMIT;
此時我們發現表中age為25的已刪除。
Python 示例
time.clock() conn = psycopg2.connect(host='172.16.89.80',user="postgres",password="postgres",database="postgres") cur = conn.cursor() cur.execute("BEGIN TRANSACTION") # 開始事務 if __name__=='__main__': for i in range(0,1000): cur.execute('INSERT INTO test(a,b,c,d) VALUES (%d,%d,%d);'%(i,i,i)) cur.execute('commit') # 提交事務 cur.close() conn.close() print(time.clock())
執行成功,耗時約 2s
繼續嘗試
上面手動開始了事務,後面我做了如下嘗試,發現耗時只有 1s 【commit 優化】
time.clock() conn = psycopg2.connect(host='172.16.89.80',database="postgres") cur = conn.cursor() if __name__=='__main__': for i in range(0,i)) conn.commit() cur.close() conn.close() print(time.clock())
執行了一系列sql,最後來個 commit,同樣執行成功,且耗時更少,我猜測是python自動開始了事務,以 commit 命令提交,無需手動開始。【後續有空會驗證下這個猜測】
以上為個人經驗,希望能給大家一個參考,也希望大家多多支援我們。如有錯誤或未考慮完全的地方,望不吝賜教。