经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » 编程经验 » 查看文章
实现并发新高度：23ai的无锁列值保留
来源：cnblogs　　作者：AlfredZhao　　时间：2024/6/13 11:31:31　　对本文有异议

Oracle Database 23ai支持Lock-Free Reservation，中文通常译为“无锁列值保留”。

本文将通过3个部分来阐述Lock-Free Reservation的这个特性：

  • 1.应用场景
  • 2.实现原理
  • 3.使用限制

1.应用场景

Lock-Free Reservation这项特性可用于实现更细粒度的并发控制。
它的本质是相对于传统的行锁，能以更细的粒度（即列值级别）进行锁定，从而减少锁争用，提高并发性能。

例如，当库存充足时，数据仅在提交时锁定，并有可能改善最终用户体验以及事务的吞吐量。

为了避免重复造轮子，本文演示的测试用例部分，直接参考了官方博客中给出的测试用例，原文链接为：

下面我们就依据此测试用例来测试并理解下Lock-Free Reservation的具体功效吧。

1.1 创建测试表

首先，创建测试表inventory：

  1. create table inventory
  2. ( item_id            NUMBER          CONSTRAINT inv_pk PRIMARY KEY,
  3.   item_display_name  VARCHAR2(100)   NOT NULL,
  4.   item_desc          VARCHAR2(2000),
  5.   qty_on_hand        NUMBER          RESERVABLE CONSTRAINT qty_ck CHECK (qty_on_hand >= 0) NOT NULL,
  6.   shelf_capacity     NUMBER          NOT NULL,
  7.     CONSTRAINT shelf_ck CHECK (qty_on_hand <= shelf_capacity)
  8. );

在开始下一步前，我们先解读下这张测试表的创建语句，以便后面测试能更好的理解：

  • CHECK (qty_on_hand >= 0) 这个约束确保了库存数量不能为负数。
  • shelf_capacity，这是货架容量，表示每种物品在货架上的最大存放量。
  • CONSTRAINT shelf_ck CHECK (qty_on_hand <= shelf_capacity)，这个约束确保 qty_on_hand（当前库存数量）不能超过 shelf_capacity（货架容量）。

1.2 查看测试表信息

这里测试表的RESERVABLE属性列，还可以通过如下SQL来查看，确认表中是否存在RESERVABLE属性的列，以及确定具体是哪一列：

  1. col table_name format a30
  2. col has_reservable_column format a30
  3. col reservable_column format a30
  5. select table_name, has_reservable_column
  6. from user_tables
  7. where table_name = 'INVENTORY';
  9. select column_name, reservable_column
  10. from user_tab_cols
  11. where table_name = 'INVENTORY' and reservable_column = 'YES';

查看表中约束信息：

  1. col search_condition format a40
  2. col constraint_name format a20
  3. select constraint_name, search_condition
  4. from user_constraints 
  5. where table_name='INVENTORY';

上面查询结果就是我们创建的表的基础信息:

  1. 07:35:47 PRIMARY @ORCL -> JINGYU @PDB1>
  2. TABLE_NAME		       HAS_RESERVABLE_COLUMN
  3. ------------------------------ ------------------------------
  4. INVENTORY		       YES
  6. COLUMN_NAME		       RESERVABLE_COLUMN
  7. ------------------------------ ------------------------------
  8. QTY_ON_HAND		       YES
  10. CONSTRAINT_NAME      SEARCH_CONDITION
  11. -------------------- ----------------------------------------
  12. SYS_C008423	     "ITEM_DISPLAY_NAME" IS NOT NULL
  13. SYS_C008424	     "QTY_ON_HAND" IS NOT NULL
  14. SYS_C008425	     "SHELF_CAPACITY" IS NOT NULL
  15. QTY_CK		     qty_on_hand >= 0
  16. SHELF_CK	     qty_on_hand <= shelf_capacity
  17. INV_PK

1.3 插入测试数据

在测试表中插入3条测试数据，并提交更改：

  1. insert into inventory values (123, 'Milk', 'Lowfat 2%', 100, 120);
  2. insert into inventory values (456, 'Bread', 'Multigrain', 50, 100);
  3. insert into inventory values (789, 'Eggs', 'Organic', 50, 75);
  4. commit;

2.实现原理

首先设计测试场景，然后从测试表现理解实现原理。

2.1 测试无锁列值保留

目前测试表中数据：

  1. 07:37:39 PRIMARY @ORCL -> JINGYU @PDB1> select ITEM_ID, QTY_ON_HAND, SHELF_CAPACITY from inventory;
  3.    ITEM_ID QTY_ON_HAND SHELF_CAPACITY
  4. ---------- ----------- --------------
  5.        123	   100		  120
  6.        456	    50		  100
  7.        789	    50		   75
  9. Elapsed: 00:00:00.00
  1. --更新item_id=123的qty_on_hand列，原值减10 @session1：
  2. update inventory
  3.      set qty_on_hand = qty_on_hand - 10
  4.      where item_id = 123;
  5.      
  6. --更新item_id=123的qty_on_hand列，原值减2 @session2：
  7. update inventory
  8.      set qty_on_hand = qty_on_hand - 2
  9.      where item_id = 123;
  11. --更新item_id=123的qty_on_hand列，原值减9 @session3：     
  12. update inventory
  13.      set qty_on_hand = qty_on_hand - 9
  14.      where item_id = 123;
  15.    
  16. --更新item_id=123的qty_on_hand列，原值加20 @session4：  
  17. update inventory
  18.      set qty_on_hand = qty_on_hand + 20
  19.      where item_id = 123;

传统情况下，不同会话同时更新表的同一行数据，会阻塞，但这里上面4个会话都可以正常执行成功。
结果如下：

  1. --@session1:
  2. 07:38:03 PRIMARY @ORCL -> JINGYU @PDB1> update inventory
  3.      set qty_on_hand = qty_on_hand - 10
  4.      where item_id = 123;
  5. 07:39:13   2  07:39:13   3
  6. 1 row updated.
  8. Elapsed: 00:00:00.01
  9. 07:39:13 PRIMARY @ORCL -> JINGYU @PDB1>
  11. --@session2:
  12. 07:39:01 PRIMARY @ORCL -> JINGYU @PDB1> update inventory
  13.      set qty_on_hand = qty_on_hand - 2
  14.      where item_id = 123;
  15. 07:39:29   2  07:39:29   3
  16. 1 row updated.
  18. Elapsed: 00:00:00.01
  19. 07:39:29 PRIMARY @ORCL -> JINGYU @PDB1>
  21. --@session3:
  22. 07:39:03 PRIMARY @ORCL -> JINGYU @PDB1> update inventory
  23.      set qty_on_hand = qty_on_hand - 9
  24.      where item_id = 123;07:39:38   2  07:39:38   3
  26. 1 row updated.
  28. Elapsed: 00:00:00.01
  30. --@session4:
  31. 07:39:07 PRIMARY @ORCL -> JINGYU @PDB1> update inventory
  32.      set qty_on_hand = qty_on_hand + 20
  33.      where item_id = 123;07:39:45   2  07:39:45   3
  35. 1 row updated.
  37. Elapsed: 00:00:00.01

4个会话更新同一行数据，完全不受影响，实现了并发的新高度，即比行锁更细的颗粒度。

2.2 查看journal table

查看journal table，这个是核心，也是Lock-Free Reservation的底层实现机制：

  1. select object_name, object_type, created
  2.      from user_objects order by 3 desc;

结果如下：

  1. OBJECT_NAME		       OBJECT_TYPE	       CREATED
  2. ------------------------------ ----------------------- ---------
  3. INV_PK			       INDEX		       12-JUN-24
  4. SYS_RESERVJRNL_76171	       TABLE		       12-JUN-24
  5. INVENTORY		       TABLE		       12-JUN-24

查看这个journal table的表结构：

  1. 07:42:53 PRIMARY @ORCL -> JINGYU @PDB1> desc SYS_RESERVJRNL_76171
  2.  Name												       Null?	Type
  3.  ----------------------------------------------------------------------------------------------------- -------- --------------------------------------------------------------------
  4.  ORA_SAGA_ID$													RAW(16)
  5.  ORA_TXN_ID$													RAW(8)
  6.  ORA_STATUS$													VARCHAR2(11)
  7.  ORA_STMT_TYPE$ 												VARCHAR2(6)
  8.  ITEM_ID											       NOT NULL NUMBER
  9.  QTY_ON_HAND_OP 												VARCHAR2(1)
  10.  QTY_ON_HAND_RESERVED												NUMBER
  12. 07:42:58 PRIMARY @ORCL -> JINGYU @PDB1>

select * from SYS_RESERVJRNL_76171;

分别在上面4个会话查询，结果如下：

  1. --@session1:
  2. 07:42:58 PRIMARY @ORCL -> JINGYU @PDB1> select * from SYS_RESERVJRNL_76171;
  4. ORA_SAGA_ID$			 ORA_TXN_ID$	  ORA_STATUS$ ORA_ST	ITEM_ID Q QTY_ON_HAND_RESERVED
  5. -------------------------------- ---------------- ----------- ------ ---------- - --------------------
  6. 				 05001B0068040000 ACTIVE      UPDATE	    123 -		    10
  8. Elapsed: 00:00:00.00
  10. --@session2:
  11. 07:39:30 PRIMARY @ORCL -> JINGYU @PDB1> select * from SYS_RESERVJRNL_76171;
  13. ORA_SAGA_ID$			 ORA_TXN_ID$	  ORA_STATUS$ ORA_ST	ITEM_ID Q QTY_ON_HAND_RESERVED
  14. -------------------------------- ---------------- ----------- ------ ---------- - --------------------
  15. 				 02000B0050040000 ACTIVE      UPDATE	    123 -		     2
  17. Elapsed: 00:00:00.00
  19. --@session3:
  20. 07:39:39 PRIMARY @ORCL -> JINGYU @PDB1> select * from SYS_RESERVJRNL_76171;
  22. ORA_SAGA_ID$			 ORA_TXN_ID$	  ORA_STATUS$ ORA_ST	ITEM_ID Q QTY_ON_HAND_RESERVED
  23. -------------------------------- ---------------- ----------- ------ ---------- - --------------------
  24. 				 0A000A00B3030000 ACTIVE      UPDATE	    123 -		     9
  26. Elapsed: 00:00:00.00
  28. --@session4:
  29. 07:39:46 PRIMARY @ORCL -> JINGYU @PDB1> select * from SYS_RESERVJRNL_76171;
  31. ORA_SAGA_ID$			 ORA_TXN_ID$	  ORA_STATUS$ ORA_ST	ITEM_ID Q QTY_ON_HAND_RESERVED
  32. -------------------------------- ---------------- ----------- ------ ---------- - --------------------
  33. 				 04000E00B2030000 ACTIVE      UPDATE	    123 +		    20
  35. Elapsed: 00:00:00.00

可以看到这个journal table的表SYS_RESERVJRNL_76171详细记录了每个会话对这列的操作。
一旦提交，这个记录就会被清空。有点儿像Oracle的临时表？顺手获取下这个表的创建语句：

select dbms_metadata.get_ddl('TABLE','SYS_RESERVJRNL_76171','JINGYU') from dual;

  1. 07:48:49 PRIMARY @ORCL -> JINGYU @PDB1> select dbms_metadata.get_ddl('TABLE','SYS_RESERVJRNL_76171','JINGYU') from dual;
  3. DBMS_METADATA.GET_DDL('TABLE','SYS_RESERVJRNL_76171','JINGYU')
  4. --------------------------------------------------------------------------------
  6.   CREATE TABLE "JINGYU"."SYS_RESERVJRNL_76171"
  7.    (	"ORA_SAGA_ID$" RAW(16),
  8. 	"ORA_TXN_ID$" RAW(8),
  9. 	"ORA_STATUS$" VARCHAR2(11),
  10. 	"ORA_STMT_TYPE$" VARCHAR2(6),
  11. 	"ITEM_ID" NUMBER NOT NULL ENABLE,
  12. 	"QTY_ON_HAND_OP" VARCHAR2(1),
  13. 	"QTY_ON_HAND_RESERVED" NUMBER
  14.    ) SEGMENT CREATION IMMEDIATE
  15.   PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255
  16.  NOCOMPRESS LOGGING
  17.   STORAGE(INITIAL 16384 NEXT 16384 MINEXTENTS 1 MAXEXTENTS 2147483645
  18.   PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
  19.   BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
  20.   TABLESPACE "USERS"

从创建语句来看倒没有指定临时表创建语句，但感觉上实现机制上有些类似，以后空了再研究，不是很重要。
总之这个日志表是建立无锁列值保留时，Oracle自动创建的，当然也由Oracle自己维护，用户肯定不能对其直接进行操作，否则会报错：

  1. ORA-55727: DML, ALTER, RENAME, and CREATE INDEX operations are not allowed on the reservation journal table "JINGYU"."SYS_RESERVJRNL_76171".
  2. Help: https://docs.oracle.com/error-help/db/ora-55727/

3.使用限制

最后聊下关于Lock-Free Reservation的目前使用限制：

  • 该特性仅限于特定场景，主要是经常需要更新特定列而非整行的场景。
  • 更新特定列也不能随便，只能使用原值增加或减少的方式。
  • 支持的数据类型有限：仅支持数值型数据列，不适用于所有数据类型。
  • 只在23ai数据库版本中提供支持。

3.1 修改非特定列肯定不行

这好像是废话。。。但还是提一句，可不要傻傻的认为表中的所有列都可以。

  1. --@session1:
  2. update inventory
  3.      set item_display_name = 'XXBK'
  4.      where item_id = 123;
  5.      
  6. --@session2:
  7. update inventory
  8.      set item_display_name = 'ABCD'
  9.      where item_id = 123;

比如上面更新这个表的其他列时，session2肯定会等待session1提交或回滚之后才能操作成功。

3.2 修改特定列也有特定限制

特定列就可以随便更新了吗？目前也不是的，只能支持特定的场景，比如使用原值增加或减少的方式。

  1. --@session1:
  2. update inventory
  3.      set qty_on_hand = 30
  4.      where item_id = 123;
  5.           
  6. --@session2:
  7. update inventory
  8.      set qty_on_hand = 40
  9.      where item_id = 123;

上面这种直接更新这个特定列的值，也是会报错：

  1. ORA-55746: Reservable column update statement only supports + or - operations on a reservable column.
  2. Help: https://docs.oracle.com/error-help/db/ora-55746/

3.3 不支持非数值型

如果你定义了非数值型的保留列，建表就会直接报错，明确提醒你只支持NUMBER, INTEGER, FLOAT这些数据类型：

  1. ORA-55748: Reservable column property specified on column "QTY_ON_HAND" is supported only on columns of data types Oracle NUMBER, INTEGER, and FLOAT.
  2. Help: https://docs.oracle.com/error-help/db/ora-55748/

3.4 修改表中列的RESERVABLE属性

如果你最终发现，你的业务根本不需要列的RESERVABLE属性，那么就可以修改列属性，去掉RESERVABLE属性：

  1. alter table inventory modify (qty_on_hand NOT RESERVABLE);

这样，这个列就会支持常规更新操作，但同时，就会和普通列一样持有锁：

  1. --@session1:
  2. update inventory
  3.      set qty_on_hand = 30
  4.      where item_id = 123;
  5.           
  6. --@session2:
  7. update inventory
  8.      set qty_on_hand = 40
  9.      where item_id = 123;

3.5 测试环境清理

最后测试回退相关操作，删除测试表：

  1. drop table inventory;

好了，有关Oracle Database 23ai支持Lock-Free Reservation特性实现并发新高度的测试就到这里了。大家可以想想自己公司的业务中是否有合适的场景可以通过这个特性大幅增加并发能力，欢迎一起讨论。

原文链接：https://www.cnblogs.com/jyzhao/p/18245570/shi-xian-bing-fa-xin-gao-du23ai-de-wu-suo-lie-zhi

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

编程经验热门文章

  • Prometheus监控之SNMP Exporter介绍和数据展现
  • Intel 82599网卡异常挂死原因
  • 腾讯防水墙的分析识别与破解
  • 桌面应用自动化WinAppDriver入门
  • 文档在线预览（三）使用js前端实现word、excel、pdf、ppt 在线预览
  • 「教程」如何下载AcFun网站上的视频、A站视频下载工具
  • 基于Hi3559AV100的SVP(NNIE)开发整体流程
  • GBDT(梯度提升树)scikit-klearn中的参数说明及简汇
  • antd之RangePicker设置默认值方式
  • 决胜经典算法之插入排序

    • 编程经验推荐文章

  • wifi基础(一)：无线电波与WIFI信号干扰、衰减
  • 甲方扔给两个存在包名与类名均相同的Jar包，要在工程中同时使用怎么办？
  • 《花100块做个摸鱼小网站! 》第三篇—热搜表结构设计和热搜数据存储
  • Fluent Editor：一个基于 Quill 2.0 的富文本编辑器，功能强大、开箱即用！
  • 方法的三种调用形式
  • 《花100块做个摸鱼小网站! 》第二篇—后端应用搭建和完成第一个爬虫
  • 《熬夜整理》保姆级系列教程-玩转Wireshark抓包神器教程(4)-再识Wireshark - 北京-宏哥
  • 《软件性能测试分析与调优实践之路》(第2版) 读书笔记（二）总体介绍（下）-真正从性能分析与调优来看性能测试
  • 架构知识点（三）
  • 《花100块做个摸鱼小网站! 》第一篇—买云服务器和初始化环境

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号