Function bindFunc

src/function/table/show_connection.cpp:53–92

}

static std::unique_ptr<TableFuncBindData> bindFunc(const ClientContext* context,
    const TableFuncBindInput* input) {
    std::vector<std::string> columnNames;
    std::vector<LogicalType> columnTypes;
    columnNames.emplace_back("source table name");
    columnTypes.emplace_back(LogicalType::STRING());
    columnNames.emplace_back("destination table name");
    columnTypes.emplace_back(LogicalType::STRING());
    columnNames.emplace_back("source table primary key");
    columnTypes.emplace_back(LogicalType::STRING());
    columnNames.emplace_back("destination table primary key");
    columnTypes.emplace_back(LogicalType::STRING());
    const auto name = input->getLiteralVal<std::string>(0);
    const auto catalog = Catalog::Get(*context);
    auto transaction = transaction::Transaction::Get(*context);
    std::vector<std::pair<NodeTableCatalogEntry*, NodeTableCatalogEntry*>> srcDstEntries;
    if (catalog->containsTable(transaction, name)) {
        auto entry = catalog->getTableCatalogEntry(transaction, name);
        if (entry->getType() != catalog::CatalogEntryType::REL_GROUP_ENTRY) {
            throw BinderException{"Show connection can only be called on a rel table!"};
        }
        for (auto& info : entry->ptrCast<RelGroupCatalogEntry>()
                              ->getRelEntryInfos()) { // Skip foreign-backed rel tables (they have
                                                      // FOREIGN_TABLE_ID)
            if (info.nodePair.srcTableID == common::FOREIGN_TABLE_ID) {
                continue;
            }
            auto srcEntry = catalog->getTableCatalogEntry(transaction, info.nodePair.srcTableID)
                                ->ptrCast<NodeTableCatalogEntry>();
            auto dstEntry = catalog->getTableCatalogEntry(transaction, info.nodePair.dstTableID)
                                ->ptrCast<NodeTableCatalogEntry>();
            srcDstEntries.emplace_back(srcEntry, dstEntry);
        }
    } else {
        throw BinderException{"Show connection can only be called on a rel table!"};
    }
    columnNames = TableFunction::extractYieldVariables(columnNames, input->yieldVariables);
    auto columns = input->binder->createVariables(columnNames, columnTypes);
    return std::make_unique<ShowConnectionBindData>(srcDstEntries, columns, srcDstEntries.size());
}

function_set ShowConnectionFunction::getFunctionSet() {
    function_set functionSet;