数据库变更时，OceanBase如何自动生成回滚 SQL

背景

在开发中，数据的变更与维护工作一般较频繁。当我们执行数据库的DML操作时，必须谨慎考虑变更对数据可能产生的后果，以及变更是否能够顺利执行。若出现意外数据丢失、操作失误或语法错误等情况，我们必须迅速将数据库恢复到变更之前的状态，以确保数据的一致性和完整性。然而，回滚操作通常需要开发人员手动编写回滚SQL脚本，这不仅繁琐复杂，而且极易出错。

为了解决这个问题，ODC（OceanBase Developer Center）V4.2.0支持在执行数据库变更任务时自动生成备份回滚 SQL 以提高开发效率、减少错误率，保证数据的一致性和完整性。当单条误操作 SQL 受影响的数据量在10万以内时，您可使用该方法进行数据恢复。

功能体验

  1. 点击「工单」-> 「新建工单」-> 「数据库变更」，在 ODC 的「新建数据库变更」页面中，勾选「生成备份回滚方案」并填写工单详情。

  1. 点击「新建」后待工单审批通过。
  2. ODC 会根据您填写的「SQL内容」生成对应的「备份回滚方案」，您可以在工单的「任务详情」中的「任务信息」页面点击「下载备份回滚方案」以下载 ODC 生成的「备份回滚方案」文件：

也可以在工单「任务详情」中的「任务流程」中点击「下载备份回滚方案」以下载该文件。

  1. 如需回滚该工单您可以在此工单的「任务详情」页面的右下脚点击「回滚」重新发起数据库变更工单以申请回滚操作。发起回滚工单后您可以在此工单的「任务详情」中的「回滚工单」页面查看此工单关联的回滚工单。

例如，针对 「SQL内容」为以下的数据库变更任务：

update t2 set c2=11 where c1=1;
update tab2 set c2=11 where id=1;

生成的「备份回滚方案」示例如下：

/* 
[SQL]: 
update t2 set c2=11 where c1=1[QUERY SQL]: 
SELECT t2.* FROM t2 WHERE c1=1;*/ 
REPLACE INTO `jingtian_test`.`t2` VALUES (1,11,1);/* 
[SQL]: 
update tab2 set c2=11 where id=1[ERROR MESSAGE]: 
It is not supported to generate rollback plan for tables without primary key or unique key
*/

包含以下几部分内容：

  • 原始的变更 SQL 语句（仅针对 UPDATE/DELETE 语句）。
  • 查询原始变更数据的 SQL 语句。
  • 生成的回滚 SQL。
  • 若针对一条 UPDATE/DELETE 变更 SQL 无法生成回滚 SQL，则其原因会显示在 [ERROR MESSAGE]中。

ODC 如何自动生成一条回滚 SQL

下面是 ODC 根据一条 SQL 生成对应的回滚 SQL 的流程图：

  • SQL 解析：通过 SQL 解析器遍历 SQL 语法树从而将一条 SQL 解析为 SQL 对象。
  • SQL 校验：基于 SQL 对象校验是符合能够生成对应的回滚 SQL 的条件，包括：
    1. 判断是否是 UPDATE/DELETE SQL，ODC 仅针对 UPDATE/DELETE 语句生成对应的回滚 SQL；
    2. 若是 OB MYSQL 模式，判断变更表是否具有主键或唯一建，对于没有主键或唯一键的表执行的变更 SQL 不支持生成回滚 SQL。
  • 基于 SQL 对象生成查询原始变更数据的 SQL。
  • 查询原始变更数据。
  • 基于 SQL 对象和原始变更数据生成对应的回滚 SQL：
    • OB MYSQL 模式针对 UPDATE 语句生成 REPLACE INTO 的回滚 SQL；
    • OB ORACLE 模式针对 UPDATE 语句生成 DELETE 语句和 INSERT INTO 语句；
    • 针对 DELETE 语句生成 INSERT INTO 语句。

接下来详解介绍每一个流程的具体实现。

SQL 解析

SQL 解析可以理解为对 SQL 进行建模，将原始 SQL 语句转化为一个 SQL 对象。我们根据 SQL 的词法和语法文件可以生成 SQL 的词法分析器和语法分析器。词法分析阶段将 SQL 语句拆解成 Token 序列，并识别出关键词、标识、常量等，而语法分析阶段基于词法分析的结果，构造出一棵抽象语法数。例如一条 SQL：

UPDATE tab1, tab2 SET tab1.c2 = 100, tab2.c2=200 WHERE tab1.c1 = tab2.c1;

生成对应的抽象语法树如下图：

通过遍历语法树将其转化为一个 SQL 对象：

可以看到，这个 SQL 对象实际上是将 SQL 语句结构化了，对 SQL 的各个部分都定义了相应的抽象，比如针对 where 的查询条件我们定义成了 CompoundExpression对象。通过将 SQL 语句解析成对象，我们就可以围绕这个对象编写生成对应回滚 SQL 的处理逻辑。

SQL 校验

SQL 校验阶段就是基于解析出来的 SQL statement 对象去做一些校验的逻辑：

  • 判断该 SQL 的类型是否是 UPDATE/DELETE 类型。
  • 针对 OB MYSQL 模式，我们需要做格外的校验变更表是否具有主键或者唯一键的逻辑判断。之所以有这个校验逻辑是由于首先后续的批量查询策略逻辑依赖主键/唯一键，其次针对 UPDATE 语句生成的回滚 SQL 是 REPLACE INTO，该语句也依赖主键/唯一键。通过 SQL 对象我们可以获取到 update 语句的 table_references 对象，我们就基于这个变更的 table 名用以下去查询校验该 table 是否具有主键或者唯一键：
-- 查询主键
SHOW INDEX FROM table_name WHERE Non_unique = 0 and Key_name='PRIMARY';-- 查询唯一建
SHOW INDEX FROM table_name WHERE Non_unique = 0;

而针对 OB ORACLE 模式，我们直接采用 ROWID 作为每一张变更表的唯一建，因此不需要有校验变更表是否具有主键或者唯一键的逻辑。

  • 校验该变更 SQL 是否符合能够生成回滚 SQL 的语句。比如如下 SQL：
UPDATE t1, t2 set col1=2222, col2=333 WHERE t1.c1=t2.c1;

由于 table_references 中涉及多个表，但是 set column_name=... 时没有指明该column_name 的表名，导致我们仅根据这一条 SQL 无法直接确认变更的字段属于哪个表，因此该 SQL 不符合能够生成回滚 SQL 的语句。这种情况只需稍做修改，指明列所属的表就可以支持生成回滚 SQL：

UPDATE t1, t2 set t1.col1=2222, t2.col2=333 WHERE t1.c1=t2.c1;

查询原始变更数据

如何基于一条 SQL 生成对应的查询原始数据的 SQL 呢？其实核心逻辑就是基于解析出的 SQL 对象和 SQL 语句格式去获取我们需要的信息进而拼接出查询 SQL。拿 UPDATE 语句为例，以下是 OB MYSQL 的 UPDATE 语句的格式：

UPDATE [IGNORE] table_referencesSET update_asgn_list[WHERE where_condition] [ORDER BY order_list][LIMIT row_count];table_references:tbl_name [PARTITION (partition_name,...)] [, ...]update_asgn_list:column_name = expr [, ...]order_list: column_name [ASC|DESC] [, column_name [ASC|DESC]...]

简单示例

比如基于以下 SQL：

UPDATE tab1, tab2 SET tab1.c2 = 100, tab2.c2=200 WHERE tab1.c1 = tab2.c1;

通过 SQL 解析后基于 SQL 对象我们可以获取该 SQL Statement 的 table_references、update_asgn_list 和 where_condition，通过 update_asgn_list 我们可以知道该 SQL 涉及的变更表有2个：tab1 和 tab2，进而我们就可以针对每个变更表生成的查询 SQL ：

SELECT * FROM tab1 WHERE tab1.c1 = tab2.c1;SELECT * FROM tab2 WHERE tab1.c1 = tab2.c1;

当然以上的示例 SQL 是一个最简单的例子，复杂一点的场景比如涉及 多表 join 和 子查询 的场景又该怎么生成对应的查询 SQL 呢？其实不管 SQL 多复杂我们的核心都是基于 SQL Statement 去拼接出查询 SQL。

考虑如下涉及多表 join 的 SQL：

UPDATE tab1 v1 inner join tab2 v2 inner join tab3 v3 on v1.c1 = v2.c1 and v1.c1=v3.c1 SET v1.c2=200, v2.c2=200;

针对这条 SQL 我们通过解析 table_references、 update_asgn_list 从而拼接的查询 SQL 如下：

SELECT v1.* FROM tab1 v1 inner join tab2 v2 inner join tab3 v3 on v1.c1 = v2.c1 and v1.c1=v3.c1;SELECT v2.* FROM tab1 v1 inner join tab2 v2 inner join tab3 v3 on v1.c1 = v2.c1 and v1.c1=v3.c1;

批量查询策略

获取到基于原始 SQL 生成的查询 SQL 后，我们就可以执行查询 SQL 来获取原始数据了。在查询数据的时候可能会遇上这个问题：一次查询出的数据过大，导致内存溢出怎么办？针对这个问题传统的处理方式也有很多，比如通过 limit 分页查询，但是这种方式在我们的场景下不适用，比如如果原始 SQL 就带了 limit 那么这种方式就失效了。ODC 采用根据表的主键或唯一键（优先采用主键）拼接批量查询 SQL 的方式来解决这个问题。

OB MYSQL 模式

比如我们通过查询 SQL 可以获取到表 tab1 的主键列为 c1，如果原始的查询 SQL 如下：

SELECT tab1.* FROM tab1 WHERE c3 > 1；

我们先查询出所有变更行数据的主键值：

SELECT tab1.c1 FROM tab1 WHERE c3 > 1；

通过以上 SQL 我们就可以查询出变更的总行数以及每一行的主键值，若总变更行数为 1500 且设置的批量查询的大小为 1000，也就是每次查询最多获取 1000 行的数据，那么基于以上查询 SQL 得到的批量查询 SQL 为：

SELECT tab1.* FROM tab1 WHERE c3 > 1 AND c1 IN (1,2,3, ..., 1000);SELECT tab1.* FROM tab1 WHERE c3 > 1 AND c1 IN (1001,1002,1003, ..., 1500);

这样以来就可以做到批量查询原始变更数据了。由于增加的 where 条件也是走索引的，因此也不存在性能瓶颈问题。

OB ORACLE 模式

针对 ORACLE 模式我们直接利用 ROWID 来拼接批量查询 SQL。比如原始 SQL；

SELECT tab1.* FROM tab1 WHERE c3 > 1；

我们先查询出所有变更行数据的 ROWID 值：

SELECT ROWID FROM tab1 WHERE c3 > 1；

那么基于以上查询 SQL 得到的批量查询 SQL 为：

SELECT tab1.* FROM tab1 WHERE c3 > 1 AND ROWID IN (...);

生成回滚 SQL

通过以上处理逻辑，我们已经获得了原始变更数据，那么接下来就是最后一步基于变更行数据生成回滚 SQL 了。

UPDATE 语句

OB MYSQL 模式

针对 OB MYSQL 模式，UPDATE 语句生成的对应回滚 SQL 为 REPLACE INTO 语句，REPLACE INTO 用于实时覆盖写入数据。写入数据时，会先根据主键或唯一键判断待写入的数据是否已经存在于表中，并根据判断结果选择不同的方式写入数据：

  • 如果待写入数据已经存在，则先删除该行数据，然后插入新的数据。
  • 如果待写入数据不存在，则直接插入新数据。

这里要求变更表必须有主键或者是唯一索引，否则 replace into 会直接插入数据（等效于 INSERT INTO），这可能会导致表中出现重复的数据。

最终 ODC 生成的完整的备份回滚 SQL 文件如下所示：

/* 
[SQL]: 
update tab set col2=2 where col=1;[QUERY SQL]: 
SELECT tab.* FROM tab WHERE col=1;*/ 
REPLACE INTO `schema_name`.`tab` VALUES (1,1,1);

OB ORACLE 模式

针对 OB ORACLE 模式，会先生成 DELTE 语句来删除变更数据，然后生成 INSERT INTO 语句插入原始的变更前的数据，从而避免插入数据时存在主键或者唯一键的冲突。

/* 
[SQL]: 
UPDATE TAB1 set c2=2 where c1=1[QUERY SQL]: 
SELECT TAB1.* FROM TAB1 WHERE c1=1;*/ 
DELETE FROM TAB1 WHERE c1=1;
INSERT INTO "TEST"."TAB1" VALUES (1,1);

DELETE 语句

针对 DELETE 语句，生成的回滚 SQL 为 INSERT INTO 语句。例如针对以下变更 SQL：

delete from tab where col=1;

最终生成的备份回滚文件内容如下:

/* 
[SQL]: 
delete from tab where col=1;[QUERY SQL]: 
SELECT tab.* FROM tab WHERE col=1;*/ 
INSERT INTO `schema_`.`tab` VALUES (1,1,1);

结语

感谢您的阅读～ODC 已于 2023 年 DTCC 大会上正式宣布开源。ODC 希望通过开源，与社区共同打造一款帮助 Dev 和 DBA 真正实现“ONE team”的企业级数据库协同开发工具。如果你对这个开源项目感兴趣，欢迎以任何形式参与 ODC 社区。无论是贡献代码、提出问题、分享见解，或者仅仅是表达对这个开源项目的喜爱与支持，都将成为推动 ODC 项目发展的动力。

↓ 前往 GitHub，深入了解 ODC 的更多细节

GitHub - oceanbase/odc: OceanBase Developer Center(ODC), An open-source, enterprise-grade database tool for collaborative development

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/2994.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

jsp+springboot+java二手车交易管理系统258u6

jsp+springboot+java二手车交易管理系统258u6

设计而成的系统要有以下目标：管理员和用户能够跳转到不同的页面当中。因此要把系统的目标设置为如下几项： (1) 系统在操作上不能过于复杂。 (2) 用户对应着不同的角色 (3) 设计完成的数据库要有能够处理并发和安全的作用 (4) 设计完成的管理…
阅读更多...
亚马逊云科技提高企业生产力神器Amazon Q评测分析

亚马逊云科技提高企业生产力神器Amazon Q评测分析

一年一度的全球云计算春晚，亚马逊云科技Re:invent在2023年11月27于Vegas震撼来袭，其中最令人关注的就是CEO Adam在Keynote中分享的内容。其中一个新内容就是提升生产力神器: Amazon Q，可以说它重新定义了企业的工作模式。那具体它神在哪里呢&…
阅读更多...
Python构建学生信息管理系统：网站路由补充和首次运行

Python构建学生信息管理系统：网站路由补充和首次运行

在之前的内容中，我们已经完成了学生信息管理系统（Student Information Management System, SIMS）的需求分析、环境搭建、数据库创建、项目结构的初始化，以及运行。正常做下来的朋友，会发现项目运行后输入http://127.0.…
阅读更多...
vulfocus靶场thinkphp命令执行cve-2018-1002015

vulfocus靶场thinkphp命令执行cve-2018-1002015

thinkPHP 5.0.x版本和5.1.x版本中存在远程代码执行漏洞，该漏洞源于ThinkPHP在获取控制器名时未对用户提交的参数进行严格的过滤。远程攻击者可通过输入‘＼’字符的方式调用任意方法利用该漏洞执行代码 开启靶场： 使用工具： think…
阅读更多...
使用微软Phi-3-mini模型快速创建生成式AI应用

使用微软Phi-3-mini模型快速创建生成式AI应用

微软Phi-3大语言模型是微软研究院推出的新一代系列先进的小语言模型。Phi-3系列包括phi-3-mini、phi-3-small和phi-3-medium三个不同规模的版本。这些模型在保持较小的参数规模的同时，通过精心设计的训练数据集和优化的算法，实现了与大型模型相媲美的语言…
阅读更多...
Edge下载文件提示无法安全下载的解决方法

Edge下载文件提示无法安全下载的解决方法

问题描述：最近Edge在下载文件时总是提示：无法安全下载，本文记录一下解决方法。 提示截图： 解决方式一： 1. 点击下图红框的三个点，选择保留 2. 选择仍然保留 解决方式二： 第一种方式每下载一次…
阅读更多...
✅为什么MySQL默认使用RR隔离级别？

✅为什么MySQL默认使用RR隔离级别？

对于数据库的默认隔离级别，Oracle默认的隔离级别是 RC，而MySQL默认的隔离级别是 RR。 那么，你知道为什么Oracle选择RC作为默认级别，而MySQL要选择RR作为默认的隔离级别吗？ Oracle的隔离级别 Oracle支持ANSI/ISO SQL…
阅读更多...
HTB靶场 Perfection

HTB靶场 Perfection

端口 打开了ssh和http服务 访问 Perfection靶机的网站 是一个根据权重计算总成绩的网站 Wappalyzer查看网页用的什么编写搭建的 抓包看一下是怎么工作的 发送,，返回的结果 如果我在 类别 后面多加一句命令 就会出现提示 恶意输入阻止 大概率有命令注入 通过插件…
阅读更多...
2024最新版JavaScript逆向爬虫教程-------基础篇之JavaScript密码学以及CryptoJS各种常用算法的实现

2024最新版JavaScript逆向爬虫教程-------基础篇之JavaScript密码学以及CryptoJS各种常用算法的实现

目录 一、密码学介绍1.1 为什么要学密码学?1.2 密码学里面学哪一些 二、字符编码三、位运算四、Hex 编码与 Base64 编码4.1 Hex 编码4.2 Base64 编码 五、消息摘要算法5.1 简介5.2 JS中的MD5、SHA、HMAC、SM3 六、对称加密算法6.1 介绍6.2 加密模式和填充方式6.3 CryptoJS 中D…
阅读更多...
元宇宙虚拟空间的角色状态更新（七）

元宇宙虚拟空间的角色状态更新（七）

前言 该文章主要讲元宇宙虚拟空间的角色状态更新，基本核心技术点 角色状态更新 对角色设置一个位置判断（从中心点向下投射一射线确定角色的位置） character.feetRaycast(); feetRaycast的start获取碰撞体的位置，end射线结束的…
阅读更多...
Linux驱动开发：掌握SPI通信机制

Linux驱动开发：掌握SPI通信机制

目录标题 1、SPI简介2、SPI通信机制3、Linux内核中的SPI支持4、SPI核心API5、SPI控制器驱动6、SPI设备驱动 7、编写SPI设备驱动8、调试SPI驱动 在Linux驱动开发中，串行外设接口(SPI)是一种常见的高速全双工通信协议，用于连接处理器和各种外设。本文将深入…
阅读更多...
QFD赋能人工智能：打造智能化需求分析与优化新纪元

QFD赋能人工智能：打造智能化需求分析与优化新纪元

在科技飞速发展的今天，人工智能(AI)已经渗透到我们生活的方方面面。然而，如何让AI更加贴合用户需求，提供更加精准和个性化的服务？这成为了一个亟待解决的问题。质量功能展开（Quality Function Deployment，简…
阅读更多...
Linux的FTP服务

Linux的FTP服务

目录 1.什么是FTP服务？ 2.FTP的工作原理和流程 1 主动模式 2 被动模式 3.搭建和配置FTP服务 1 下载服务包、备份配置文件 2 修改配置文件​编辑 3 匿名访问测试 4 设置黑白命令 1.什么是FTP服务？ FTP（file Transfer Protocol&#…
阅读更多...
Vue3 实现 Three.js粒子特效

Vue3 实现 Three.js粒子特效

效果 <template><div id"waves" /> </template><script setup> import { ref, onMounted, onUnmounted } from "vue"; import * as THREE from "three";const amountX ref(50); const amountY ref(50); const color …
阅读更多...
QT学习之窗口基本设置

QT学习之窗口基本设置

this->setWindowTitle("二代证测试工具"); // 设置窗口名this->setWindowIcon(QIcon("logo.jpg")); // 设置角标this->setFixedSize(900, 730); // 设置窗口大小设置exe图标 .rc文件代码中设置如下
阅读更多...
数据结构入门——排序（代码实现）（下）

数据结构入门——排序（代码实现）（下）

int GetMidi(int* a, int left, int right) {int mid (left right) / 2;// left mid rightif (a[left] < a[mid]){if (a[mid] < a[right]){return mid;}else if (a[left] > a[right]) // mid是最大值{return left;}else{return right;}}else // a[left] > a[mid…
阅读更多...
一寸照片裁剪怎么弄？修改照片尺寸，3种方法调整

一寸照片裁剪怎么弄？修改照片尺寸，3种方法调整

一寸照片裁剪怎么弄&#xff1f;将照片裁剪为一寸尺寸&#xff0c;可以方便我们在各种场合中使用。无论是办理证件、申请签证&#xff0c;还是制作简历、参与活动&#xff0c;一寸照片都是不可或缺的资料。通过裁剪&#xff0c;我们能够确保照片的尺寸、比例符合标准&#xff0…
阅读更多...
视频怎么批量压缩？5个好用的电脑软件和在线网站

视频怎么批量压缩？5个好用的电脑软件和在线网站

视频怎么批量压缩&#xff1f;有时候我们需要批量压缩视频来节省存储空间&#xff0c;便于管理文件和空间&#xff0c;快速的传输发送给他人。有些快捷的视频压缩工具却只支持单个视频导入&#xff0c;非常影响压缩效率&#xff0c;那么今天就向大家从软件和在线网站2个角度介绍…
阅读更多...
GoLand远程开发IDE：使用SSH远程连接服务器进行云端编程

GoLand远程开发IDE：使用SSH远程连接服务器进行云端编程

目录 ⛳️推荐 1. 安装配置GoLand 2. 服务器开启SSH服务 3. GoLand本地服务器远程连接测试 4. 安装cpolar内网穿透远程访问服务器端 4.1 服务器端安装cpolar 4.2 创建远程连接公网地址 5. 使用固定TCP地址远程开发 ⛳️推荐 前些天发现了一个巨牛的人工智能学习网站&am…
阅读更多...
OpenG中的读写簇函数

OpenG中的读写簇函数

1.首先需要在Vi Package Manager中安装Open G 2.找到openG中的读写ini函数&#xff0c;第一组是将簇标签作为段名&#xff0c;第二组是指定段名&#xff0c;本质上都是一样 3.读写簇到ini文件 4.禁用写入&#xff0c;更改簇的元素&#xff0c;增加或者删除&#xff0c;原来…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023