Method executeInternal

src/processor/operator/simple/attach_database.cpp:31–63

}

void AttachDatabase::executeInternal(ExecutionContext* context) {
    auto client = context->clientContext;
    auto databaseManager = main::DatabaseManager::Get(*client);
    auto memoryManager = storage::MemoryManager::Get(*client);
    if (common::StringUtils::getUpper(attachInfo.dbType) == common::ATTACHED_LBUG_DB_TYPE) {
        auto db = std::make_unique<main::AttachedLbugDatabase>(attachInfo.dbPath,
            attachInfo.dbAlias, common::ATTACHED_LBUG_DB_TYPE, client);
        client->setDefaultDatabase(db.get());
        databaseManager->registerAttachedDatabase(std::move(db));
        client->addDBDirToFileSearchPath(attachInfo.dbPath);
        appendMessage(attachMessage(), memoryManager);
        return;
    }
    for (auto& storageExtension : client->getDatabase()->getStorageExtensions()) {
        if (storageExtension->canHandleDB(attachInfo.dbType)) {
            auto db = storageExtension->attach(attachInfo.dbAlias, attachInfo.dbPath, client,
                attachInfo.options);
            databaseManager->registerAttachedDatabase(std::move(db));
            client->addDBDirToFileSearchPath(attachInfo.dbPath);
            appendMessage(attachMessage(), memoryManager);
            return;
        }
    }
    auto errMsg =
        std::format("No loaded extension can handle database type: {}.", attachInfo.dbType);
    auto dbType = common::StringUtils::getLower(attachInfo.dbType);
    if (dbType == "adbc" || dbType == "duckdb" || dbType == "postgres" || dbType == "sqlite") {
        errMsg += std::format("\nDid you forget to load {} extension?\nYou can load it by: load "
                              "extension {};",
            dbType, dbType);
    }
    throw common::RuntimeException{errMsg};
}

} // namespace processor
} // namespace lbug