怎么在Postgresql怎么實(shí)現(xiàn)一個(gè)事務(wù)的提交與回滾功能？針對(duì)這個(gè)問(wèn)題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問(wèn)題的小伙伴找到更簡(jiǎn)單易行的方法。
用過(guò)oracle或mysql的人都知道在sqlplus或mysql中，做一個(gè)dml語(yǔ)句，如果發(fā)現(xiàn)做錯(cuò)了，還可以rollback;掉，但在PostgreSQL的psql中，如果執(zhí)行一個(gè)dml，沒(méi)有先運(yùn)行begin;的話，一執(zhí)行完就馬上提交了，不能回滾，這樣容易導(dǎo)致誤操作的發(fā)生，有沒(méi)有什么辦法避免這個(gè)風(fēng)險(xiǎn)呢？
當(dāng)然有，在psql中默認(rèn)是打開(kāi)自動(dòng)提交的，我們可以關(guān)閉自動(dòng)提交，方法如下：
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事務(wù)一樣是可以回滾的，并沒(méi)有隱式提交的概念，這兒我們需要注意下
test=# \d List of relations Schema | Name | Type | Owner --------+------+-------+------- public | foo | table | kiwi public | test | table | kiwi (2 rows)
補(bǔ)充：PostgreSQL-事務(wù)與commit優(yōu)化
事務(wù) Transaction 是 數(shù)據(jù)庫(kù)管理系統(tǒng)DBMS 執(zhí)行過(guò)程中的一個(gè)邏輯單元，是一個(gè) sql命令組成的序列。
其特點(diǎn)在于，當(dāng)事務(wù)被提交DBMS后，DBMS需要確保所有的操作被完成；如果事務(wù)中有的操作沒(méi)有成功完成，那么所有操作都將回滾，回滾到事務(wù)提交之前的狀態(tài)
事務(wù)具有以下四個(gè)標(biāo)準(zhǔn)屬性
原子性：事務(wù)作為一個(gè)整體被執(zhí)行，相當(dāng)于一個(gè)原子
一致性：確保修改前后數(shù)據(jù)庫(kù)都滿足約束
隔離性：多個(gè)事務(wù)能并發(fā)執(zhí)行，互不影響
持久性：已被提交的事務(wù)對(duì)數(shù)據(jù)庫(kù)的修改應(yīng)該永久保存在數(shù)據(jù)庫(kù)中
某人在商店使用電子貨幣支付100元，包括以下兩個(gè)操作：
1. 消費(fèi)者賬戶減少100元
2. 商家賬戶增加100元
事務(wù)的作用就是保證這兩個(gè)操作要么都發(fā)生，要么都不發(fā)生，否則可能出現(xiàn)100元憑空消失。
使用如下命令控制事務(wù)
begin 或者 begin transaction：開(kāi)始一個(gè)事務(wù)
commit 或者 end transaction：提交事務(wù)，執(zhí)行一系列sql
rollback：事務(wù)回滾
在開(kāi)始一個(gè)事務(wù)后，除非遇到 commit 或者 rollback 命令，事務(wù)才會(huì)被執(zhí)行；
如果還沒(méi)遇到 commit 或者 rollback，數(shù)據(jù)庫(kù)發(fā)生異常，也會(huì)自動(dòng)回滾。
注意，事務(wù)命令只能用于 insert、delete、update 操作，而其他命令，比如建表、刪表，會(huì)被自動(dòng)提交。
總結(jié)一下：事務(wù)需要手動(dòng)開(kāi)啟，手動(dòng)提交；而且這種方式能提高操作效率。
假設(shè)有如下表
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：開(kāi)始事務(wù)，從表中刪除年齡為25的記錄，最后用rollback撤銷所有操作
runoobdb=# BEGIN; DELETE FROM COMPANY WHERE AGE = 25; ROLLBACK;
結(jié)果如下
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
我們發(fā)現(xiàn)原表沒(méi)有任何改變
操作2：開(kāi)始事務(wù)，從表中刪除年齡為25的記錄，最后用commit提交事務(wù)
runoobdb=# BEGIN; DELETE FROM COMPANY WHERE AGE = 25; COMMIT;
此時(shí)我們發(fā)現(xiàn)表中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") # 開(kāi)始事務(wù)
if __name__=='__main__':
for i in range(0,1000):
cur.execute('INSERT INTO test(a, b, c, d) VALUES (%d, %d, %d, %d);'%(i, i, i, i))
cur.execute('commit') # 提交事務(wù)
cur.close()
conn.close()
print(time.clock())執(zhí)行成功，耗時(shí)約 2s
上面手動(dòng)開(kāi)始了事務(wù)，后面我做了如下嘗試，發(fā)現(xiàn)耗時(shí)只有 1s 【commit 優(yōu)化】
time.clock()
conn = psycopg2.connect(host='172.16.89.80',user="postgres",password="postgres",database="postgres")
cur = conn.cursor()
if __name__=='__main__':
for i in range(0,1000):
cur.execute('INSERT INTO test(a, b, c, d) VALUES (%d, %d, %d, %d);'%(i, i, i, i))
conn.commit()
cur.close()
conn.close()
print(time.clock())執(zhí)行了一系列sql，最后來(lái)個(gè) commit，同樣執(zhí)行成功，且耗時(shí)更少，我猜測(cè)是python自動(dòng)開(kāi)始了事務(wù)，以 commit 命令提交，無(wú)需手動(dòng)開(kāi)始。
關(guān)于怎么在Postgresql怎么實(shí)現(xiàn)一個(gè)事務(wù)的提交與回滾功能問(wèn)題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒(méi)有解開(kāi)，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
