mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-19 06:01:57 +00:00
32 lines
775 B
C++
32 lines
775 B
C++
#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 {};
|
|
}
|
|
|
|
}
|