【我和openGauss的故事】 openGauss 5.0.0 事务相关语法

2023/08/03 16:48
阅读数 93

众所周知, openGauss 是一款开源关系型数据库管理系统,采用木兰宽松许可证v2发行,是 PostgreSQL 9.2.4 版本的硬分叉,经历 HUAWEI 多年的孵化,并已历经了两个 LTS 版本。

现在的 openGauss 5.0.0 正是第三个 LTS 版本,发行于 3 月 31 日,版本生命周期为三年。

openGauss 5.0.0 是流行的开源关系型数据库管理系统,它支持事务处理,下面我们来看看。

事务隔离级别

在 openGauss 5.0.0 中,支持 READ COMMITTED (读已提交)和 REPEATABLE READ (可重复读) 两种事务隔离级别。默认隔离级别是 READ COMMITTED (读已提交),保证不会读到脏数据。当事务使用此隔离级别时,SELECT查询(没有FOR UPDATE/SHARE子句)只能看到在查询开始之前提交的数据;它不会看到未提交的数据,也不会看到并发事务在查询执行期间提交的更改。事务可重复读隔离级别,事务只能读到事务开始之前已提交的数据,不能读到未提交的数据以及事务执行期间其它并发事务提交的修改(但是,查询能查看到自身所在事务中先前更新的执行结果,即使先前更新尚未提交)。这个级别和读已提交是不一样的,因为可重复读事务中的查询看到的是事务开始时的快照,不是该事务内部当前查询开始时的快照,就是说,单个事务内部的select命令总是查看到同样的数据,查看不到自身事务开始之后其他并发事务修改后提交的数据。使用该级别的应用必须准备好重试事务,因为可能会发生串行化失败。
在 openGauss 中,目前功能上不支持 SERIALIZABLE 隔离级别,等价于REPEATABLE READ。

此外,在 openGauss 5.0.0 中,使用 全局事务管理器(Global Transaction Manager, GTM)来管理事务,GTM 负责全局事务号的分发,事务提交时间戳的分发以及全局事务运行状态的登记。

事务管理命令

在 openGauss 5.0.0 中,可以使用以下命令来启动和提交事务:

使用 BEGIN 语句

openGauss 的语法为:

BEGIN [ WORK | TRANSACTION ] [ { ISOLATION LEVEL { READ COMMITTED | SERIALIZABLE | REPEATABLE READ } | { READ WRITE | READ ONLY } } [, ...] ];

演示实例:

begin work isolation level repeatable read read only;

使用 START 语句

openGauss 的语法为:

START TRANSACTION [ { ISOLATION LEVEL { READ COMMITTED | SERIALIZABLE | REPEATABLE READ } | { READ WRITE | READ ONLY } } [, ...] ];

演示实例:

START TRANSACTION isolation level repeatable read read WRITE;

使用 SET 在事务中改变事务隔离级别

openGauss 的语法为:

{ SET [ LOCAL ] TRANSACTION|SET SESSION CHARACTERISTICS AS TRANSACTION } { ISOLATION LEVEL { READ COMMITTED | SERIALIZABLE | REPEATABLE READ } | { READ WRITE | READ ONLY } } [, ...];

演示实例:

SET LOCAL TRANSACTION ISOLATION LEVEL REPEATABLE READ;

提交事务

openGauss 的语法为:

{ COMMIT | END } [ WORK | TRANSACTION ] ;

回滚事务

当事务无法继续进行时,系统执行回滚,取消与该事务相关的所有已完成的数据库操作。

openGauss 的语法为:

ROLLBACK [ WORK | TRANSACTION ];

openGauss 事务验证实践

隐式提交案例一则

开启一个会话,尝试在事务显示开启时退出客户端,再次登入后查看数据是否插入成功,答案是否。

`openGauss=# begin;BEGINopenGauss=# insert into t select 2;INSERT 0 1openGauss=# select * from t;id12(2 rows)
$ gsqlgsql ((openGauss 5.0.0 build a07d57c3) compiled at 2023-03-29 03:07:56 commit 0 last mr )Non-SSL connection (SSL connection is recommended when requiring high-security)Type “help” for help.
openGauss=# select * from t;id1(1 row)`

说明在事务中退出客户端,当前事务并不会隐式提交。

默认事务隔离级别 RC

openGauss 中默认事务提交级别 RC,下面做一个实验加以验证。

开启两个会话,Session A 和 Session B:

`-- Session A:openGauss=# begin;BEGINopenGauss=# insert into t select 3;INSERT 0 1openGauss=# select * from t;id13(2 rows)
– Session B:openGauss=# begin;BEGINopenGauss=# select * from t;id1(1 row)`

当前会话只能看到事务开始之前的 t 表数据。并且,Session B 无法读到未提交的数据,不存在脏读现象。

DDL 可回滚 – create table

在 openGauss 中,显式开启一个事务,然后执行 DDL 语句,那么这个 DDL 语句可以进行回滚,确认语句没有问题后,再进行显式提交。例如,在 Session A 中开启显式事务,并创建表 tr。

`-- Session A:openGauss=# begin;BEGINopenGauss=# create table tr (id int);CREATE TABLEopenGauss=# \dtList of relationsSchema | Name | Type | Owner | Storage--------±-----±------±------±---------------------------------public | t | table | omm | {orientation=row,compression=no}public | tr | table | omm | {orientation=row,compression=no}(2 rows)
– Session B:openGauss=# \dList of relationsSchema | Name | Type | Owner | Storage--------±-----±------±------±---------------------------------public | t | table | omm | {orientation=row,compression=no}(1 row)
– Session A:openGauss=# rollback;ROLLBACKopenGauss=# \dtList of relationsSchema | Name | Type | Owner | Storage--------±-----±------±------±---------------------------------public | t | table | omm | {orientation=row,compression=no}(1 row)
– Session B:openGauss=# \dList of relationsSchema | Name | Type | Owner | Storage--------±-----±------±------±---------------------------------public | t | table | omm | {orientation=row,compression=no}(1 row)`

DDL 可回滚 – truncate table

同样地,在 openGauss 中,truncate table 也可以回滚。例如,清空表 t 的数据:

`-- Session A:openGauss=# select * from t;id1(1 row)
openGauss=# begin;BEGINopenGauss=# truncate table t;TRUNCATE TABLEopenGauss=# select * from t;id(0 rows)
– Session B:$ gsqlgsql ((openGauss 5.0.0 build a07d57c3) compiled at 2023-03-29 03:07:56 commit 0 last mr )Non-SSL connection (SSL connection is recommended when requiring high-security)Type “help” for help.
openGauss=# select * from t;id1(1 row)
openGauss=# select * from t;`

此时, Session A 中的 truncate 操作已经执行完成,可以看到事务中表中无数据,但是,Session B 再次去查询表 t 的数据时,事务会进入等待状态,直到 Session A 发出 commit/rollback 指令。

`-- Session A:openGauss=# rollback;ROLLBACK
openGauss=# select * from t;id1(1 row)
Session B:openGauss=# select * from t;id1(1 row)`

此外,由于 openGauss 引入了分布式事务,所以对于事务的处理复杂的多。

The End

彩蛋,这里并没有提及 openGauss 的 MOT 特性,对此特性相关事务处理的内容将另行成文。

本文分享自微信公众号 - openGauss(openGauss)。
如有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。

展开阅读全文
加载中
点击引领话题📣 发布并加入讨论🔥
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部