OceanBase 源码解读(四):事务的一生

简介: 源码是 OceanBase 的“方向盘”,本系列主要围绕“源码解读”,通过文章阐述,帮助大家理清数据库的内在本质。此前,带你读源码第三篇《戳这里回顾:OceanBase 源码解读(三)分区的一生》为大家介绍了OceanBase 的存储层的相关内容。在第一节讲通信协议 obmp_query 时,跳过了事务控制的细节,本文为 OceanBase 数据库源码解读系列文章的第四篇,将主要为大家介绍事务的外部接口相关知识。

121.gif

源码是 OceanBase 的“方向盘”,本系列主要围绕“源码解读”,通过文章阐述,帮助大家理清数据库的内在本质。此前,带你读源码第三篇《戳这里回顾:OceanBase 源码解读(三)分区的一生》为大家介绍了OceanBase 的存储层的相关内容。在第一节讲通信协议 obmp_query 时,跳过了事务控制的细节,本文为 OceanBase 数据库源码解读系列文章的第四篇,将主要为大家介绍事务的外部接口相关知识。


事务的外部接口

1.1. 协议层对事务层的封装

协议层对事务层提供的原始接口进行了封装,源码位置:sql/ob_sql_trans_control.h,截图如下。这层封装维护了 TransState 状态,且便于 SQL 层调用,语句执行结束时在统一的位置根据 TransState 调用正确的事务接口,保证在任何异常状态下事务资源不泄露。
image.png

2.2. 原始的事务接口

原始的事务接口位于源码文件 storage/transaction/ob_trans_service.h,主要接口为:


  • start_trans & end_trans (参见截图)
  • start_stmt & end_stmt
  • start_participant & end_participant


它们分别对应事务、语句、语句内参与者(分区)的访问生命周期。start trans 开启事务后,返回一个 ObTransDesc 对象。该对象作为事务唯一标识,会被保存到 session 对象中,其他事务接口和后续语句执行都需要它,也常用于问题诊断。
image.gifimage.png

3.3. 分布式事务

开始执行前,根据语句涉及分区信息从 location cache 中获取主副本(leader)位置,选择对应类别的执行计划。一般的,一个 SQL 查询或 DML 会产生三类执行计划(ObPhyPlanType):

  • local 计划表示所有该语句执行需访问分区的 leader 都在本节点
  • remote 计划表示所有分区 leader 都在远程一个节点上
  • distributed 计划表示分区 leader 在多节点上的情况。


location cache 是一个整体架构上的重要组件,用于高效查找分区副本信息,它对外提供统一接口,屏蔽了很多分布式细节。它的主体实现位于 share/partition_table目录(参见截图),而源文件 sql/ob_sql_partition_location_cache.h 对它进行了封装,同时统一了虚拟表的处理。

事务控制调用往往要综合考虑多种因素:

  • 语句类型(是否只读)
  • 事务类型(是否自动提交,是否弱一致性读)
  • 当前事务状态和执行计划类型等

例如,本地计划自动提交,在本节点顺序执行 start_trans ➡︎ start_stmt ➡︎ start_participant ➡︎ end_participant ➡︎ end_stmt ➡︎ end trans;远程计划自动提交,上述接口都在远程节点执行。而对于分布式执行计划,start/end_stmt 在本节点执行,start/end_participant 在每个分区 leader 所在节点上执行。这组接口设计目的是在简化事务接口与分场景优化事务性能间取得一定的平衡。

image.gifimage.png

以上就是 OceanBase 事务的一生,在后续的源码解读第五篇我们将会为大家解析 OceanBase 数据库多租户架构的相关内容,敬请期待。



相关文章
|
Oracle 关系型数据库 MySQL
第四章:OceanBase集群技术架构(分布式事务、MVCC、事务隔离级别)
第四章:OceanBase集群技术架构(分布式事务、MVCC、事务隔离级别)
400 0
|
4月前
|
OLAP OLTP OceanBase
构建基于 OceanBase 的混合事务与分析处理(HTAP)系统
【8月更文第31天】 随着业务复杂性的增加,企业需要同时处理大量的在线事务处理(OLTP)和在线分析处理(OLAP)。传统的做法是维护两个独立的系统,分别用于事务处理和数据分析。然而,这种分离的方式不仅增加了运维的复杂度,还可能导致数据不一致的问题。为了解决这些问题,混合事务与分析处理(Hybrid Transactional/Analytical Processing, HTAP)的概念应运而生。OceanBase 作为一款支持 HTAP 的分布式数据库系统,能够同时满足事务处理和分析查询的需求。本文将介绍如何利用 OceanBase 构建 HTAP 系统。
100 1
|
7月前
|
数据库 OceanBase
在OceanBase数据库中,clog和slog文件夹的内容包含了事务日志和系统日志
在OceanBase数据库中,clog和slog文件夹的内容包含了事务日志和系统日志
200 7
|
7月前
|
存储 数据库 OceanBase
OceanBase数据库的磁盘配置包括数据盘和事务日志盘的大小
OceanBase数据库的磁盘配置包括数据盘和事务日志盘的大小
67 1
|
存储 SQL 缓存
OceanBase 源码解读(十二):宏块的垃圾回收和坏块检查
此前,OceanBase 源码解读第十一篇《Location Cache 模块浅析》,为大家介绍了 observer 上的一个基础模块,为 SQL、事务、CLOG 等多个其他模块提供获取及缓存某个副本位置信息的能力的 Location Cache 模块。本期“源码解读”继续由 OceanBase 技术专家公祺为大家带来“存储层代码解读之「宏块的垃圾回收和坏块检查」”。
326 0
OceanBase 源码解读(十二):宏块的垃圾回收和坏块检查
|
SQL 存储 缓存
OceanBase 源码解读(十一):Location Cache 模块浅析
OceanBase 源码解读(十一):Location Cache 模块浅析
344 0
OceanBase 源码解读(十一):Location Cache 模块浅析
|
存储 Java 数据库
OceanBase 源码解读(九):存储层代码解读之「宏块存储格式」
此前,带你读源码第八篇《事务日志的提交和回放》,为大家介绍了日志模块的设计理念和日志的一生。本期“源码解读”由数据库技术专家公祺为大家带来“存储层代码解读之「宏块存储格式」”
495 0
OceanBase 源码解读(九):存储层代码解读之「宏块存储格式」
|
SQL 存储 Java
OceanBase 源码解读(七):一文读懂数据库索引实现原理
此前,带你读源码第六篇《戳这里回顾:OceanBase 源码解读(六):存储引擎详解》为大家详细讲解了 OceanBase 存储引擎,并为大家回答了关于 OceanBase 数据库的相关提问。
746 1
|
存储 缓存 Oracle
OceanBase 源码解读(六):存储引擎详解
从2010年一路走来,每一步 OceanBase 犹如走在悬崖峭壁,走得十分小心翼翼。回头看,非处当时之情景,不能理解当时之设计。好的设计不是“想”出来的,而是“痛”出来的,希望大家在阅读时也能够感受到这份成果背后的“痛并快乐着”。
1387 0
OceanBase 源码解读(六):存储引擎详解
|
SQL 调度 数据库
OceanBase 源码解读(五):租户的一生
此前,带你读源码第四篇《戳这里回顾:OceanBase 源码解读(四):事务的一生》为大家介绍了事务的外部接口相关知识。本文将介绍社区版中创建、删除租户、资源隔离的相关代码。
458 0
OceanBase 源码解读(五):租户的一生

热门文章

最新文章

下一篇
DataWorks