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

相关文章

Django开发时如何避免频繁发送短信验证码(python图文代码)

《Django开发时如何避免频繁发送短信验证码(python图文代码)》Django开发时,为防止频繁发送验证码,后端需用Redis限制请求频率,结合管道技术提升效率,通过生产者消费者模式解耦业务逻辑... 目录避免频繁发送 验证码1. www.chinasem.cn避免频繁发送 验证码逻辑分析2. 避免频繁

精选20个好玩又实用的的Python实战项目(有图文代码)

《精选20个好玩又实用的的Python实战项目(有图文代码)》文章介绍了20个实用Python项目,涵盖游戏开发、工具应用、图像处理、机器学习等,使用Tkinter、PIL、OpenCV、Kivy等库... 目录① 猜字游戏② 闹钟③ 骰子模拟器④ 二维码⑤ 语言检测⑥ 加密和解密⑦ URL缩短⑧ 音乐播放

Python使用Tenacity一行代码实现自动重试详解

《Python使用Tenacity一行代码实现自动重试详解》tenacity是一个专为Python设计的通用重试库,它的核心理念就是用简单、清晰的方式,为任何可能失败的操作添加重试能力,下面我们就来看... 目录一切始于一个简单的 API 调用Tenacity 入门:一行代码实现优雅重试精细控制:让重试按我

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

MySQL进行数据库审计的详细步骤和示例代码

《MySQL进行数据库审计的详细步骤和示例代码》数据库审计通过触发器、内置功能及第三方工具记录和监控数据库活动,确保安全、完整与合规,Java代码实现自动化日志记录,整合分析系统提升监控效率,本文给大... 目录一、数据库审计的基本概念二、使用触发器进行数据库审计1. 创建审计表2. 创建触发器三、Java

Java中调用数据库存储过程的示例代码

《Java中调用数据库存储过程的示例代码》本文介绍Java通过JDBC调用数据库存储过程的方法,涵盖参数类型、执行步骤及数据库差异,需注意异常处理与资源管理,以优化性能并实现复杂业务逻辑,感兴趣的朋友... 目录一、存储过程概述二、Java调用存储过程的基本javascript步骤三、Java调用存储过程示

Visual Studio 2022 编译C++20代码的图文步骤

《VisualStudio2022编译C++20代码的图文步骤》在VisualStudio中启用C++20import功能,需设置语言标准为ISOC++20,开启扫描源查找模块依赖及实验性标... 默认创建Visual Studio桌面控制台项目代码包含C++20的import方法。右键项目的属性:

MySQL数据库的内嵌函数和联合查询实例代码

《MySQL数据库的内嵌函数和联合查询实例代码》联合查询是一种将多个查询结果组合在一起的方法,通常使用UNION、UNIONALL、INTERSECT和EXCEPT关键字,下面:本文主要介绍MyS... 目录一.数据库的内嵌函数1.1聚合函数COUNT([DISTINCT] expr)SUM([DISTIN

Java实现自定义table宽高的示例代码

《Java实现自定义table宽高的示例代码》在桌面应用、管理系统乃至报表工具中,表格(JTable)作为最常用的数据展示组件,不仅承载对数据的增删改查,还需要配合布局与视觉需求,而JavaSwing... 目录一、项目背景详细介绍二、项目需求详细介绍三、相关技术详细介绍四、实现思路详细介绍五、完整实现代码

Go语言代码格式化的技巧分享

《Go语言代码格式化的技巧分享》在Go语言的开发过程中,代码格式化是一个看似细微却至关重要的环节,良好的代码格式化不仅能提升代码的可读性,还能促进团队协作,减少因代码风格差异引发的问题,Go在代码格式... 目录一、Go 语言代码格式化的重要性二、Go 语言代码格式化工具:gofmt 与 go fmt(一)