lbug 0.16.1

An in-process property graph database management system built for query speed and scalability
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

#include "binder/binder.h"
#include "binder/bound_table_scan_info.h"
#include "binder/expression/expression_util.h"
#include "binder/expression/literal_expression.h"
#include "catalog/catalog.h"
#include "function/built_in_function_utils.h"
#include "main/client_context.h"
#include "transaction/transaction.h"

using namespace lbug::common;
using namespace lbug::function;

namespace lbug {
namespace binder {

BoundTableScanInfo Binder::bindTableFunc(const std::string& tableFuncName,
    const parser::ParsedExpression& expr, std::vector<parser::YieldVariable> yieldVariables) {
    auto catalog = catalog::Catalog::Get(*clientContext);
    auto transaction = transaction::Transaction::Get(*clientContext);
    auto entry = catalog->getFunctionEntry(transaction, tableFuncName,
        clientContext->useInternalCatalogEntry());
    expression_vector positionalParams;
    std::vector<LogicalType> positionalParamTypes;
    optional_params_t optionalParams;
    expression_vector optionalParamsLegacy;
    for (auto i = 0u; i < expr.getNumChildren(); i++) {
        auto& childExpr = *expr.getChild(i);
        auto param = expressionBinder.bindExpression(childExpr);
        ExpressionUtil::validateExpressionType(*param,
            {ExpressionType::LITERAL, ExpressionType::PARAMETER, ExpressionType::PATTERN});
        if (!childExpr.hasAlias()) {
            positionalParams.push_back(param);
            positionalParamTypes.push_back(param->getDataType().copy());
        } else {
            if (param->expressionType == ExpressionType::LITERAL) {
                auto literalExpr = param->constPtrCast<LiteralExpression>();
                optionalParams.emplace(childExpr.getAlias(), literalExpr->getValue());
            }
            param->setAlias(expr.getChild(i)->getAlias());
            optionalParamsLegacy.push_back(param);
        }
    }
    auto func = BuiltInFunctionsUtils::matchFunction(tableFuncName, positionalParamTypes,
        entry->ptrCast<catalog::FunctionCatalogEntry>());
    auto tableFunc = func->constPtrCast<TableFunction>();
    std::vector<LogicalType> inputTypes;
    if (tableFunc->inferInputTypes) {
        // For functions which take in nested data types, we have to use the input parameters to
        // detect the input types. (E.g. query_hnsw_index takes in an ARRAY which needs the user
        // input parameters to decide the array dimension).
        inputTypes = tableFunc->inferInputTypes(positionalParams);
    } else {
        // For functions which don't have nested type parameters, we can simply use the types
        // declared in the function signature.
        for (auto i = 0u; i < tableFunc->parameterTypeIDs.size(); i++) {
            inputTypes.push_back(LogicalType(tableFunc->parameterTypeIDs[i]));
        }
    }
    for (auto i = 0u; i < positionalParams.size(); ++i) {
        auto parameterTypeID = tableFunc->parameterTypeIDs[i];
        if (positionalParams[i]->expressionType == ExpressionType::LITERAL &&
            parameterTypeID != LogicalTypeID::ANY) {
            positionalParams[i] = expressionBinder.foldExpression(
                expressionBinder.implicitCastIfNecessary(positionalParams[i], inputTypes[i]));
        }
    }
    auto bindInput = TableFuncBindInput();
    bindInput.params = std::move(positionalParams);
    bindInput.optionalParams = std::move(optionalParams);
    bindInput.optionalParamsLegacy = std::move(optionalParamsLegacy);
    bindInput.binder = this;
    bindInput.yieldVariables = std::move(yieldVariables);
    return BoundTableScanInfo{*tableFunc, tableFunc->bindFunc(clientContext, &bindInput)};
}

} // namespace binder
} // namespace lbug