ITPub博客

首页 > 数据库 > 数据库开发技术 > 《PostgreSQL 开发指南》第 23 篇 事务与并发控制

《PostgreSQL 开发指南》第 23 篇 事务与并发控制

原创 数据库开发技术 作者:BUAA_dxy 时间:2023-08-25 18:03:42 0 删除 编辑

本篇介绍 PostgreSQL 中的数据库事务概念和 ACID 属性,并发事务可能带来的问题以及 4 种隔离级别,演示了如何使用事务控制语句(TCL)对事务进行处理,包括BEGIN、COMMIT、ROLLBACK以及SAVEPOINT语句。

数据库事务

数据库事务是由一个或者多个操作组成的工作单元。一个经典事务示例就是银行账户之间的转账,它由发起方的扣款操作和接收方入账操作组成,两者必须都成功或者都失败。

数据库中的事务具有原子性(Atomicity)、一致性(Consistency)、隔离性(Isolation)以及持久性(Durability),也就是 ACID 属性:

  • 原子性保证事务中的操作要么全部成功,要么全部失败,不会只成功一部分。比如从 A 账户转出 1000 元到 B 账户,如果从 A 账户减去 1000 元成功执行,但是没有往 B 账户增加 1000 元,意味着客户将会损失 1000 元。用数据库中的术语来说,这种情况导致了数据库的不一致性。

  • 一致性确保了数据修改的有效性,并且遵循一定的业务规则;例如,上面的银行转账事务中如果一个账户扣款成功,但是另一个账户加钱失败,那么就会出现数据不一致(此时需要回滚已经执行的扣款操作)。另外,数据库还必须保证满足完整性约束,比如账户扣款之后不能出现余额为负数(可以在余额字段上添加检查约束)。

  • 隔离性决定了并发事务之间的可见性和相互影响程度。例如,账户 A 向账户 B 转账的过程中,账户 B 查询的余额应该是转账之前的数目;如果多人同时向账户 B 转账,结果也应该保持一致性,就像依次转账的结果一样。SQL 标准定义了 4 种不同的隔离级别,具体参考下文。

  • 持久性确保已经提交的事务必须永久生效,即使发生断电、系统崩溃等故障,数据库都不会丢失数据。对于 PostgreSQL 而言,使用的是预写式日志(WAL)的机制实现事务的持久性。

事务控制语句

我们先来介绍一下 PostgreSQL 提供的事务控制语句,执行以下命令创建示例表:

CREATE TABLE accounts(
id serial PRIMARY KEY,
user_name varchar(50),
balance numeric(10,4)
);

ALTER TABLE accounts ADD CONSTRAINT bal_check CHECK(balance >= 0);

accounts 是一个简化的账户表,主要包含用户名和余额信息。我们为该表插入一条记录:

insert into accounts(user_name, balance)
values ('UserA', 6000);

select * from accounts;
id|user_name|balance |
--|---------|---------|
1|UserA |6000.0000|

默认情况下,PostgreSQL 自动为以上INSERT语句开始一个事务,执行插入操作之后自动提交该事务。

不过,我们也可以手动控制事务的开始和提交。例如:

begin;

insert into accounts(user_name, balance)
values ('UserB', 0);

select * from accounts;
id|user_name|balance |
--|---------|---------|
1|UserA |6000.0000|
2|UserB | 0.0000|

其中,BEGIN用于开始一个新的事务,PostgreSQL 中也可以使用BEGIN WORK或者BEGIN TRANSACTION开始事务;然后插入一条记录,查询显示了两条记录。

如果此时打开另一个数据库连接,查询 accounts 表只能看到一条记录。因为上面的事务还没有提交,事务的隔离性使得我们无法看到其他事务未提交的修改。

我们将上面的事务进行提交:

commit;

COMMIT用于提交事务,也可以使用COMMIT WORK或者COMMIT TRANSACTION。此时,其他事务就能看到用户 UserB 的记录了。

事务除了可以提交之外,也可以被回滚。我们演示一下如何回滚事务:

begin;

insert into accounts(user_name, balance)
values ('UserC', 2000);

select * from accounts;
id|user_name|balance |
--|---------|---------|
1|UserA |6000.0000|
2|UserB | 0.0000|
3|UserC |2000.0000|

开始事务之后,我们又新增了一个账户没有提交;此时可以回滚该事务:

rollback;

select * from accounts;
id|user_name|balance |
--|---------|---------|
1|UserA |6000.0000|
2|UserB | 0.0000|

ROLLBACK用于回滚当前事务,也可以使用ROLLBACK WORK或者ROLLBACK TRANSACTION。回滚之后,事务中的数据修改都会被撤销,账户 UserC 并没有创建成功。

还有一个与事务控制相关的语句:SAVEPOINT,用于在事务中定义保存点。例如:

begin;

insert into accounts(user_name, balance)
values ('UserC', 2000);

savepoint sv1;

insert into accounts(user_name, balance)
values ('UserD', 0);

rollback to sv1;

commit;

select * from accounts;
id|user_name|balance |
--|---------|---------|
1|UserA |6000.0000|
2|UserB | 0.0000|
4|UserC |2000.0000|

开始一个事务之后,先插入账户 UserC,然后定义了保存点 sv1;接着插入账户 UserD,然后回滚到保存点 sv1;此时账户 UserD 被撤销,账户 UserC 仍然存在;最后提交事务。

并发与隔离

PostgreSQL 支持多用户并发访问,并且保证多个用户同时访问相同的数据时不会造成数据的不一致性。当多个用户同时访问相同的数据时,如果不进行任何隔离控制,可能导致以下问题:

  • 脏读(dirty read),一个事务能够读取其他事务未提交的修改。例如,B 的初始余额为 0;A 向 B 转账 1000 元但没有提交;此时 B 能够看到 A 转过来的 1000 元,并且成功取款 1000 元;然后 A 取消了转账;银行损失了 1000 元。

  • 不可重复读(nonrepeatable read),一个事务读取某个记录后,再次读取该记录时数据发生了改变(被其他事务修改并提交)。例如,B 查询初始余额为 1000,取款 1000;同时 A 向 B 转账 1000 元并且提交;B 再次查询发现余额还是 1000 元,以为取款机出错了(当然,通过查询流水记录可以发现真相;数据库的状态仍然是一致的)。

  • 幻读(phantom read),一个事务按照某个条件查询一些数据后,再次执行相同查询时结果的数量发生了变化(另一个事务增加或者删除了某些数据并且完成提交)。幻读和非重复读有点类似,都是由于其他事务修改数据导致的结果变化。

  • 更新丢失(lost update),第一类:当两个事务更新相同的数据时,第一个事务被提交,然后第二个事务被撤销;那么第一个事务的更新也会被撤销(所有隔离级别都不允许发生这种情况)。第二类:当两个事务同时读取某一记录,然后分别进行修改提交;就会造成先提交的事务的修改丢失。

为了解决并发问题,SQL 标准定义了 4 种不同的事务隔离级别(从低到高):
隔离级别 脏读 不可重复读 幻读 更新丢失
Read Uncommitted 可能 可能 可能 可能
Read Committed 不可能 可能 可能 可能
Repeatable Read 不可能 不可能 可能 不可能
Serializable 不可能 不可能 不可能 不可能

事务的隔离级别从低到高依次为:

  • Read Uncommitted(读未提交):最低的隔离级别,实际上就是不隔离,任何事务都可以看到其他事务未提交的修改;该级别可能产生各种并发异常。不过,PostgreSQL 消除了 Read Uncommitted 级别时的脏读,因为它的实现等同于 Read Committed。

  • Read Committed(读已提交):一个事务只能看到其他事务已经提交的数据,解决了脏读问题,但是存在不可重复读、幻读和第二类更新丢失问题。这是 PostgreSQL 的默认隔离级别。

  • Repeated Read(可重复读):一个事务对于同某个数据的读取结果不变,即使其他事务对该数据进行了修改并提交;不过如果其他事务删除了该记录,则无法再查询到数据(幻读)。SQL 标准中的可重复读可能出现幻读,但是 PostgreSQL 在可重复读级别消除了幻读。

  • Serializable(可串行化):最高的隔离级别,事务串行化执行,没有并发。

只有 Serializable 真正实现了事务的完全隔离,但是不支持并发的数据库系统应用场景非常有限。因此,需要对并发性能和隔离性进行平衡,大多数数据库(包括 PostgreSQL)的默认隔离级别为 Read Committed;此时,可以避免脏读,同时拥有不错的并发性能。

下面我们来演示一下 Read Committed 隔离级别下的并发事务处理,使用SHOW命令可以查看当前的隔离级别:

show transaction_isolation;
transaction_isolation|
---------------------|
read committed |

如果需要修改当前事务的隔离级别,可以在事务的最开始执行SET TRANSACTION命令:

begin;
SET TRANSACTION ISOLATION LEVEL { SERIALIZABLE | REPEATABLE READ | READ COMMITTED | READ UNCOMMITTED };
...

下表演示了 PostgreSQL 默认级别(READ COMMITTED)时不会发生脏读,但是存在不可重复读、幻读和更新丢失问题:

事务 1 事务 2
begin;
select balance
from accounts
where id = 1; -- 返回 6000


begin;
update accounts set balance = balance + 1000 where id = 1;
select balance
from accounts
where id = 1; -- 返回 7000
select balance
from accounts
where id = 1; -- 仍然返回 6000,没有脏读


commit; – 提交事务
select balance
from accounts
where id = 1; -- 此时返回 7000,出现不可重复读



select * from accounts where id=4; -- 返回 UserC begin;
delete from accounts where id = 4;
commit; -- 删除 UserC 并提交事务
select * from accounts where id=4; -- 没有结果,出现幻读


select balance
from accounts
where id = 1; -- 此时返回 7000


begin;
select balance
from accounts
where id = 1; -- 此时返回 7000
update accounts set balance = 6000 where id = 1; -- 更新为 6000

update accounts set balance = 8000 where id = 1; -- 等待事务 1 提交
commit;

commt;
select balance
from accounts
where id = 1; -- 返回 8000,而不是自己修改成的 6000,更新丢失

在以上过程中,PostgreSQL 使用了锁加 MVCC(Multiversion Concurrency Control)技术来实现数据的隔离和一致性。MVCC 简单来说,就是保留每次数据修改之前的旧版本,根据隔离级别决定读取哪个版本的数据。这种实现的最大好处就是读操作永远不会阻塞写操作、写操作永远不会阻塞读操作。

如果一个事务已经修改某个数据而且未提交,则另一个事务不允许同时修改该数据(必须等待),写操作一定是相互阻塞的,需要按照顺序执行。

对于业务开发人员来说,我们一般使用 PostgreSQL 的默认隔离级别,因为它的 MVCC 实现消除了大部分的锁等待问题。虽然此时可能产生不可重复读、幻读和更新丢失,但是并不会导致数据的不一致性,因为这些都是其他事务的正常操作。

原文作者:SQL编程思想;如有侵权,请联系管理员删除。

请登录后发表评论 登录
全部评论
《SQL编程思想》作者,专注于数据库领域知识的分享。

注册时间:2021-08-26

  • 博文量
    443
  • 访问量
    546942