當(dāng)前位置:首頁 >  站長 >  數(shù)據(jù)庫 >  正文

基于Postgresql 事務(wù)的提交與回滾解析

 2021-06-03 17:33  來源: 腳本之家   我來投稿 撤稿糾錯(cuò)

  域名預(yù)訂/競價(jià),好“米”不錯(cuò)過

用過oracle或mysql的人都知道在sqlplus或mysql中,做一個(gè)dml語句,如果發(fā)現(xiàn)做錯(cuò)了,還可以rollback;掉,但在PostgreSQL的psql中,如果執(zhí)行一個(gè)dml,沒有先運(yùn)行begin;的話,一執(zhí)行完就馬上提交了,不能回滾,這樣容易導(dǎo)致誤操作的發(fā)生,有沒有什么辦法避免這個(gè)風(fēng)險(xiǎn)呢?

當(dāng)然有,在psql中默認(rèn)是打開自動(dòng)提交的,我們可以關(guān)閉自動(dòng)提交,方法如下:

設(shè)置\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事務(wù)一樣是可以回滾的,并沒有隱式提交的概念,這兒我們需要注意下

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ù)庫管理系統(tǒng)DBMS 執(zhí)行過程中的一個(gè)邏輯單元,是一個(gè) sql命令組成的序列。

其特點(diǎn)在于,當(dāng)事務(wù)被提交DBMS后,DBMS需要確保所有的操作被完成;如果事務(wù)中有的操作沒有成功完成,那么所有操作都將回滾,回滾到事務(wù)提交之前的狀態(tài)

屬性

事務(wù)具有以下四個(gè)標(biāo)準(zhǔn)屬性

原子性:事務(wù)作為一個(gè)整體被執(zhí)行,相當(dāng)于一個(gè)原子

一致性:確保修改前后數(shù)據(jù)庫都滿足約束

隔離性:多個(gè)事務(wù)能并發(fā)執(zhí)行,互不影響

持久性:已被提交的事務(wù)對(duì)數(shù)據(jù)庫的修改應(yīng)該永久保存在數(shù)據(jù)庫中

適用場景

某人在商店使用電子貨幣支付100元,包括以下兩個(gè)操作:

1. 消費(fèi)者賬戶減少100元

2. 商家賬戶增加100元

事務(wù)的作用就是保證這兩個(gè)操作要么都發(fā)生,要么都不發(fā)生,否則可能出現(xiàn)100元憑空消失。

事務(wù)控制

使用如下命令控制事務(wù)

begin 或者 begin transaction:開始一個(gè)事務(wù)

commit 或者 end transaction:提交事務(wù),執(zhí)行一系列sql

rollback:事務(wù)回滾

在開始一個(gè)事務(wù)后,除非遇到 commit 或者 rollback 命令,事務(wù)才會(huì)被執(zhí)行;

如果還沒遇到 commit 或者 rollback,數(shù)據(jù)庫發(fā)生異常,也會(huì)自動(dòng)回滾。

注意,事務(wù)命令只能用于 insert、delete、update 操作,而其他命令,比如建表、刪表,會(huì)被自動(dòng)提交。

總結(jié)一下:事務(wù)需要手動(dòng)開啟,手動(dòng)提交;而且這種方式能提高操作效率。

實(shí)例

假設(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:開始事務(wù),從表中刪除年齡為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

 

我們發(fā)現(xiàn)原表沒有任何改變

操作2:開始事務(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")    # 開始事務(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

繼續(xù)嘗試

上面手動(dòng)開始了事務(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,最后來個(gè) commit,同樣執(zhí)行成功,且耗時(shí)更少,我猜測是python自動(dòng)開始了事務(wù),以 commit 命令提交,無需手動(dòng)開始?!竞罄m(xù)有空會(huì)驗(yàn)證下這個(gè)猜測】

文章來源:腳本之家

來源地址:https://www.jb51.net/article/204289.htm

申請(qǐng)創(chuàng)業(yè)報(bào)道,分享創(chuàng)業(yè)好點(diǎn)子。點(diǎn)擊此處,共同探討創(chuàng)業(yè)新機(jī)遇!

相關(guān)文章

熱門排行

信息推薦