openGauss每日一练第16天|事务控制与回滚

事务（transaction）是一个完整的由若干个statements组成的一个块，一个transaction可以commit，意味着被执行，也可以rollback，意味着在事务里执行，但在结束事务后返回定义事务前的开始的样子。
事务还支持定义savepoint（大概是存档点的意思）的回滚操作，不过跟git的reset有点区别。

课程学习

1.事务控制

• 通过START TRANSACTION和BEGIN语法启动事务

• 以默认方式启动事务

START TRANSACTION;
select * from pg_class limit 1;
END;

跑完这个transaction，执行到end之后会rollback，里面的修改不会导致外界真的修改。

• 开启一个事务，设置事务的隔离级别为READ COMMITTED，访问模式为READ ONLY

BEGIN;
SET LOCAL TRANSACTION ISOLATION LEVEL READ COMMITTED READ ONLY;
show transaction_read_only;
select * from pg_class limit 1;
create schema tpcds10;
commit;

这种情况会在create schema的时候报错，因为不能在read-only transaction中去创建一个schema。

• 以隔离级别为repeatable read，读/写方式启动事务

show transaction_isolation;
START TRANSACTION ISOLATION LEVEL repeatable read READ WRITE;
show transaction_isolation;
show transaction_read_only;
select * from pg_class limit 1;
create schema tpcds10;
rollback;

• 事务回滚，schema没有创建成功

\dn+ tpcds10;

2.savepoint

• 保存点是事务中的一个特殊记号，它允许将那些在它建立后执行的命令全部回滚，把事务的状态恢复到保存点所在的时刻

CREATE TABLE table1(a int);
START TRANSACTION;
INSERT INTO table1 VALUES (1);

• 建立保存点

SAVEPOINT my_savepoint;
INSERT INTO table1 VALUES (2);

• 回滚保存点

ROLLBACK TO SAVEPOINT my_savepoint;

这个时候就回到了savepoint的状态：

select * from table1;
 a 
---
 1
(1 row)

• 删除保存点

RELEASE SAVEPOINT my_savepoint;
INSERT INTO table1 VALUES (3);
COMMIT;

• 查询表的内容，会同时看到1和3,不能看到2，因为2被回滚

SELECT * FROM table1;

 a 
---
 1
 3
(2 rows)

课程作业

1.以默认方式启动事务1，修改事务隔离级别，查看transaction_isolation

START TRANSACTION;
SET LOCAL TRANSACTION ISOLATION LEVEL READ COMMITTED READ ONLY;
show transaction_isolation;

transaction_isolation 
-----------------------
 read committed
(1 row)


END;

2.以读写方式启动事务2，创建新表，修改事务为只读事务，查看transaction_read_only，并向表中插入记录

START TRANSACTION ISOLATION LEVEL repeatable read READ WRITE;
create table example_table1(a int, b int);
commit;

begin;
SET LOCAL TRANSACTION ISOLATION LEVEL READ COMMITTED READ ONLY;
show transaction_read_only;
insert into example_table1 values (1, 2);

rollback;

这里想插入记录显然是插入不了的，会报错。

3.启动事务3，对表进行增删改查，并用到创建savepoint，回滚savepoint和删除savepoint

START TRANSACTION ISOLATION LEVEL repeatable read READ WRITE;
create table example_table2(a int, b int, c int);
insert into example_table2 values (1, 2, 3);
savepoint my_first_savepoint;
insert into example_table2 values (4, 5, 6);
savepoint my_second_savepoint;
insert into example_table2 values (7, 8, 9);
rollback to savepoint my_second_savepoint;
select * from example_table2;
rollback to savepoint my_first_savepoint;
select * from example_table2;

release savepoint my_first_savepoint;
release savepoint my_second_savepoint;
commit;

在这里回滚savepoint的时候，应该是不允许回滚到未来，具体来说就是滚到my_first_savepoint之后就没法滚到my_second_savepoint了。这点不像git，可以按照之前记得的hex log去回滚后还能回去。

所以其实在执行到最后的时候，my_second_savepoint是已经不存在的了，也自然不需要去release。

4.清理数据

drop table if exists example_table1;
drop table if exists example_table2;