ClickHouse/dbms/src/Interpreters/InterpreterOptimizeQuery.cpp

#include <Storages/IStorage.h>
#include <Parsers/ASTOptimizeQuery.h>
#include <Interpreters/Context.h>
#include <Interpreters/DDLWorker.h>
#include <Interpreters/InterpreterOptimizeQuery.h>
#include <Common/typeid_cast.h>


namespace DB
{

namespace ErrorCodes
{
    extern const int BAD_ARGUMENTS;
}


BlockIO InterpreterOptimizeQuery::execute()
{
    const auto * ast = query_ptr->As<ASTOptimizeQuery>();

    if (!ast->cluster.empty())
        return executeDDLQueryOnCluster(query_ptr, context, {ast->database});

    StoragePtr table = context.getTable(ast->database, ast->table);
    auto table_lock = table->lockStructureForShare(true, context.getCurrentQueryId());
    table->optimize(query_ptr, ast->partition, ast->final, ast->deduplicate, context);
    return {};
}

}