Method getPlanFromCache

src/QueryPlan/PlanCache.cpp:108–155

}

QueryPlanPtr PlanCacheManager::getPlanFromCache(UInt128 query_hash, ContextMutablePtr & context)
{
    if (!context->getPlanCacheManager())
        throw Exception("plan cache has to be initialized", ErrorCodes::LOGICAL_ERROR);

    auto & cached = context->getPlanCacheManager()->instance();
    try
    {
        auto plan_object = cached.get(query_hash);
        if (!plan_object || !plan_object->plan_root)
            return nullptr;

        // check statistic version
        for (auto & item : plan_object->query_info->stats_version)
        {
            Statistics::StatsTableIdentifier table_identifier{item.first};
            auto version_value = Statistics::getVersion(context, table_identifier);
            Int64 version = version_value.has_value() ? version_value.value().convertTo<Int64>() : 0;
            if (version != item.second)
            {
                cached.remove(query_hash);
                return nullptr;
            }      
        }
        PlanNodeId max_id;
        auto root  = PlanCacheManager::getNewPlanNode(plan_object->plan_root, context, false, max_id);
        CTEInfo cte_info;
        for (auto & cte : plan_object->cte_map)
            cte_info.add(cte.first, PlanCacheManager::getNewPlanNode(cte.second, context, false, max_id));

        if (plan_object->query_info && context->hasQueryContext())
        {
            for (auto & [database, table_info] : plan_object->query_info->query_access_info)
            {
                for (auto & [table, columns] : table_info)
                    context->addQueryAccessInfo(database, table, columns);
            }
        }

        context->createPlanNodeIdAllocator(max_id+1);
        return  std::make_unique<QueryPlan>(root, cte_info, context->getPlanNodeIdAllocator());
    }
    catch (...)
    {
        cached.remove(query_hash);
        return nullptr;
    }
}

bool PlanCacheManager::addPlanToCache(UInt128 query_hash, QueryPlanPtr & plan, AnalysisPtr analysis, ContextMutablePtr & context)
{