在数据库中如何高效的实现订座功能

前言

本文主要给大家介绍了关于在数据库中如何高效的实现订座功能的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍吧

第一部分：skip locked/nowait订座功能实现

订座在现实生活中是一种很常见的场景，比较常见的有火车票席位选择，电影院席位选择等等。那么如何实现订座功能呢？应用程序可能有很多种不同的实现方式，当然，肯定离不开数据库。这里将介绍一种纯数据库的实现方式。

设想我们有一张座位表如下：

create table seats (
 seat_no int primary key,
 booked enum('yes', 'no') default 'no') engine=innodb;

表中有100个席位，从0到99。例如我们要预定席位2，3，我们可以先开启事务，锁定席位：

start transaction;select * from seats where seat_no in (2,3) and booked = 'no' for update;

select… for update语句返回结果有如下三种情况：

1.返回成功，并且结果集包含2和3，那么说明锁定成功。我们可以之行下一步操作，等待支付完成，并更新席位状态并提交事务，订座完成。 update seats set booked = 'yes' where seat_no in (2,3) commit;

2.返回成功，但结果集为空，或者只包含2或者3，那么说明锁定失败。

3.很长时间不返回直到返回超时。比如席位2或者3已经被另一事务锁定，并且在等待支付完成或者发生其他情况，导致该事务一直未提交(commit)或者回滚(rollback)。返回超时默认需要等待50秒，我们可以通过修改innodb_lock_wait_timeout参数来配置合理的等待时间。超时之后返回的错误如下： error 1205 (hy000): lock wait timeout exceeded; try restarting transaction

情况3对用户来说，意味着卡死，完全不能接受。为什么会发生等待？在innodb的锁系统(lock system)中，席位2如果被一个事务上了x（写锁）锁或者ix锁(意向更新锁)，那么下一个事务要对席位2上x锁或者ix锁的事务，就要等待。这是由事务本身的特性(acid)决定的。

那么是否有一种方法避免等待以及后续可能发生的超时呢？mysql 8.0 提供的新功能skip locked/nowait就可以。 skip locked的意思是跳过那些已经被其他事务锁定了的席位。使用如下skip locked语句进行席位锁定，那么返回的结果集可能为空，2或3，2和3。当结果集不为空时，返回的席位即被锁定成功。

select * from seats where seat_no in (2,3) and booked = 'no'for update skip locked;

nowait的意思是如果碰到被其他事务锁定的席位，不等待并直接返回错误。使用如下nowait语句进行席位锁定，那么返回结果集2和3，要么返回错误。

select * from seats where seat_no in (2,3) and booked = 'no'for update nowait;

如果返回错误，如下：

error 3572 (hy000): do not wait for lock.

如果成功锁定两个席位，通过如下语句查询锁系统的状态：

select thread_id, object_name, lock_type, lock_mode, lock_data, lock_status from performance_schema.data_locks;+-----------+-------------+-----------+-----------+-----------+-------------+| thread_id | object_name | lock_type | lock_mode | lock_data | lock_status |
+-----------+-------------+-----------+-----------+-----------+-------------+|  43 | seats  | table  | ix  | null  | granted  |
|  43 | seats  | record | x   | 2   | waiting  |
|  42 | seats  | table  | ix  | null  | granted  |
|  42 | seats  | record | x   | 2   | granted  |
|  42 | seats  | record | x   | 3   | granted  |
+-----------+-------------+-----------+-----------+-----------+-------------+

skip locked还可以很方便的用来进行随机分配席位。例如我们只需要锁定两个空的席位就可以通过如下语句实现。

select * from seats where booked = 'no' limit 2 for update skip locked;

skip locked/nowait功能只针对行锁(record lock)，不包括表锁(table lock)，元数据锁(metadata lock/mdl)。因此，带有skip locked/nowait的查询语句依然可能会因为表锁或元数据库锁而阻塞。元数据锁是mysql server层用来保护数据库对象的并发访问的一致性而创建的，数据库对象不仅包括表，同时包括库，函数，存储过程，触发器，事件等等。表和行锁是innodb存储引擎内部为了保证事务的一致性而创建的不同粒度的锁。

另外，skip locked/nowait还可以配合for share使用，并且可以与单表绑定。例如：

select seat_nofrom seats join seat_rows using ( row_no )where seat_no in (2,3) and seat_rows.row_no in (12)and booked = 'no'for update of seats skip lockedfor share of seat_rows nowait;

第二部分：skip locked/nowait在innodb中的代码实现

在innodb中，实现skip locked/nowait具体实现如下：

1.增加新的查询模式 enum select_mode { select_ordinary = 0, /* default behaviour / select_skip_locked, / skip the row if row is locked / select_no_wait / return immediately if row is locked */ };

2.在查询开始前，设置查询模式 ha_innobase::store_lock(): /* set select mode for skip locked / no_wait */ switch (lock_type) { case tl_read_shared_skip_locked: case tl_write_skip_locked: m_prebuilt->select_mode = select_skip_locked; break; case tl_read_shared_no_wait: case tl_write_no_wait: m_prebuilt->select_mode = select_no_wait; break; default: m_prebuilt->select_mode = select_ordinary; break; }


3.上锁函数中，如果记录已被锁定，针对对不同查询模式进行相应处理： lock_rec_lock_slow(): if (wait_for != null) { switch (sel_mode) { case select_skip_locked: err = db_skip_locked; break; case select_no_wait: err = db_lock_nowait; break;

4.查询中对上锁结果进行处理： row_search_mvcc(): case db_skip_locked: goto next_rec; 对db_lock_nowait的处理则是回滚当前语句（statement），见函数row_mysql_handle_errors（）。

5.二级索引(secondary index)的处理 在innodb中，对表中记录的锁定分两种情况。第一种是查询使用是聚集索引（cluster index），那么直接对聚集索引的记录上锁；第二中是查询使用的是二级索引，那么首先对二级索引的记录上锁，然后根据二级索引的记录，找到对应的聚集索引记录进行上锁。 所以，对于第一部分订座的席位表中，如果存在二级索引，对于锁定表中一条记录而言，最终锁定成功与否，还是以锁定聚集索引记录为准。

skip locked/nowait可以非常高效地实现订座这个场景，作为innodb部分（wl#8919: innodb: implement nowait and skip locked）的原作者，我也期待着大家来分享该功能更多的使用场景。

参考链接：

1.mysql 8.0.1: using skip locked and nowait to handle hot rows

2.wl#3597: implement nowait and skip locked

3.wl#8919: innodb: implement nowait and skip locked

4.wl#6657: performance_schema, data locks

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对的支持。