openGauss 之谓词下推代码走读

2024-08-26 08:20

本文主要是介绍openGauss 之谓词下推代码走读,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一. 前言

       谓词下推是每一个SQL引擎必备的功能。本文主要通过走读代码了解openGauss中是如何实现谓词下推能力的。

       谓词下推即是将过滤条件尽可能往tablescan的数据源节点下推,以实现上层算子尽可能少计算的能力,如下所示的执行计划便已经将谓词id<55下推到了tablescan节点。

二. 执行计划生成时将谓词信息保存在ScanState.ps.qual中

     实现谓词下推首先需要在执行计划生成节点时将谓词过滤条件信息保存到tablescan节点,openGuass主要靠如下的步骤实现过滤条件保存到SeqScan的:

      1. openGuass首先会在将Join中涉及的物理表提取出来,然后处理where条件中,将where条件谓词的信息保存到对应relation的baserestrictinfo字段中,此步的操作入口在deconstruct_jointree函数中,代码流程如下所示:

deconstruct_jointreedeconstruct_recurseif (IsA(jtnode, FromExpr)){foreach (l, f->fromlist) {    // 找出from后边的物理表sub_joinlist = deconstruct_recurse(...&child_postponed_quals); // 抽取from实体表的eqal条件,保存在child_postponed_quals中foreach (l, (List*)f->quals) {  // 把每一个谓词条件和其对应的relation绑定起来distribute_restrictinfo_to_relsrel->baserestrictinfo = lappend(rel->baserestrictinfo, restrictinfo);}}}

      2. 生成seqscan_plan的时候,如果对应的relation有谓词条件,将谓词条件的信息保存在plan->qual中

create_seqscan_planscan_clauses = rel->baserestrictinfo;scan_clauses = extract_actual_clauses(scan_clauses, false);scan_plan = make_seqscan(tlist, scan_clauses, scan_relid);plan->qual = qpqual;

      3. 在初始化SeqScan Node节点的relation时,再将plan->qual的expr转换成ExprState,保存在node->ps.qual中

BeginScanRelationreset_scan_qualnode->ps.qual = ExecInitExprByRecursion(node->ps.plan->qual)  // 把expr转换成ExprState

     

三. 执行层根据seqscan Node 的ps.qual过滤扫描出来的元祖

       执行层的实现是每扫描扫一个元组,那么使用ps.qual构造出来的谓词条件去比对,满足谓词条件则保留且将元组返回上层,不满足则继续扫描下一个元组,直到满足为止。

ExecScanslot = ExecScanFetch(node, access_mtd, recheck_mtd);  // 取到表的元组econtext->ecxt_scantuple = slot;   // 将元组放置同时保存在econtext->ecxt_scantuple中qual = node->ps.qual   // 章节2中构造处理的谓词条件ExecQual(qual, econtext)   // 将扫描到的元组数据传入谓词条件中测试,看是否满足谓词条件ExecQualByRecursionforeach (l, qual) {ExecEvalExpr(clause, econtext, &isNull, NULL);ExecEvalOperExecMakeFunctionResultNoSets<false, false>(fcache, econtext, isNull, isDone);fcinfo->arg[i] = ExecEvalExpr(argstate, econtext, &fcinfo->argnull[i], NULL); //将从slot的具体值取出来,作为谓词比较函数(如int4lt)的参数,计算谓词的结果}// 后续如果谓词条件满足,则返回此元组,否则就继续扫描一个元组,继续比对

这篇关于openGauss 之谓词下推代码走读的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1108040

相关文章

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函

Redis实现高效内存管理的示例代码

《Redis实现高效内存管理的示例代码》Redis内存管理是其核心功能之一,为了高效地利用内存,Redis采用了多种技术和策略,如优化的数据结构、内存分配策略、内存回收、数据压缩等,下面就来详细的介绍... 目录1. 内存分配策略jemalloc 的使用2. 数据压缩和编码ziplist示例代码3. 优化的

Python 基于http.server模块实现简单http服务的代码举例

《Python基于http.server模块实现简单http服务的代码举例》Pythonhttp.server模块通过继承BaseHTTPRequestHandler处理HTTP请求,使用Threa... 目录测试环境代码实现相关介绍模块简介类及相关函数简介参考链接测试环境win11专业版python

Python从Word文档中提取图片并生成PPT的操作代码

《Python从Word文档中提取图片并生成PPT的操作代码》在日常办公场景中,我们经常需要从Word文档中提取图片,并将这些图片整理到PowerPoint幻灯片中,手动完成这一任务既耗时又容易出错,... 目录引言背景与需求解决方案概述代码解析代码核心逻辑说明总结引言在日常办公场景中,我们经常需要从 W

使用Spring Cache本地缓存示例代码

《使用SpringCache本地缓存示例代码》缓存是提高应用程序性能的重要手段,通过将频繁访问的数据存储在内存中,可以减少数据库访问次数,从而加速数据读取,:本文主要介绍使用SpringCac... 目录一、Spring Cache简介核心特点:二、基础配置1. 添加依赖2. 启用缓存3. 缓存配置方案方案

MySQL的配置文件详解及实例代码

《MySQL的配置文件详解及实例代码》MySQL的配置文件是服务器运行的重要组成部分,用于设置服务器操作的各种参数,下面:本文主要介绍MySQL配置文件的相关资料,文中通过代码介绍的非常详细,需要... 目录前言一、配置文件结构1.[mysqld]2.[client]3.[mysql]4.[mysqldum

Python多线程实现大文件快速下载的代码实现

《Python多线程实现大文件快速下载的代码实现》在互联网时代,文件下载是日常操作之一,尤其是大文件,然而,网络条件不稳定或带宽有限时,下载速度会变得很慢,本文将介绍如何使用Python实现多线程下载... 目录引言一、多线程下载原理二、python实现多线程下载代码说明:三、实战案例四、注意事项五、总结引

IDEA与MyEclipse代码量统计方式

《IDEA与MyEclipse代码量统计方式》文章介绍在项目中不安装第三方工具统计代码行数的方法,分别说明MyEclipse通过正则搜索(排除空行和注释)及IDEA使用Statistic插件或调整搜索... 目录项目场景MyEclipse代码量统计IDEA代码量统计总结项目场景在项目中,有时候我们需要统计