database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-01 06:46:55 +03:00
Code Activity

feat(optimizer): stack-based filters walker

Browse Source
This commit is contained in:
drrtuy
2025-06-27 18:28:36 +00:00
parent cd857f60dd
commit 991f8953e3
1 changed files with 32 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
dbcon/mysql/rulebased_optimizer.cpp
View File

@ -18,6 +18,7 @@
#include "constantcolumn.h" #include "constantcolumn.h"
#include "execplan/calpontselectexecutionplan.h" #include "execplan/calpontselectexecutionplan.h"
#include "execplan/simplecolumn.h" #include "execplan/simplecolumn.h"
#include "existsfilter.h"
#include "logicoperator.h" #include "logicoperator.h"
#include "operator.h" #include "operator.h"
#include "predicateoperator.h" #include "predicateoperator.h"
@ -95,6 +96,37 @@ bool Rule::walk(execplan::CalpontSelectExecutionPlan& csep) const
rewrite |= walk(unionUnitLocal); rewrite |= walk(unionUnitLocal);
} }
if (csep.filters() != nullptr)
{
bool rewriteLocal = false;
std::vector<execplan::ParseTree*> stack;
stack.push_back(csep.filters());
while (!stack.empty())
{
execplan::ParseTree* node = stack.back();
stack.pop_back();
if (node == nullptr)
continue;
auto* existsFilter = dynamic_cast<execplan::ExistsFilter*>(node->data());
if (existsFilter)
{
if (matchRule(*existsFilter->sub()))
{
applyRule(*existsFilter->sub());
rewriteLocal = true;
}
}
if (node->right())
stack.push_back(node->right());
if (node->left())
stack.push_back(node->left());
}
if (rewriteLocal)
rewrite |= rewriteLocal;
}
if (matchRule(csep)) if (matchRule(csep))
{ {
applyRule(csep); applyRule(csep);