#pragma once #include namespace DB { /** ALTER запрос * ALTER TABLE [db.]name_type * ADD COLUMN col_name type [AFTER col_after], * DROP COLUMN col_drop, * MODIFY COLUMN col_name type, * DROP PARTITION partition * ... */ class ASTAlterQuery : public IAST { public: enum ParameterType { ADD_COLUMN, DROP_COLUMN, MODIFY_COLUMN, DROP_PARTITION, ATTACH_PARTITION, FETCH_PARTITION, FREEZE_PARTITION, NO_TYPE }; struct Parameters { Parameters() : type(NO_TYPE) {} int type = NO_TYPE; /** В запросе ADD COLUMN здесь хранится имя и тип добавляемого столбца * В запросе DROP это поле не используется * В запросе MODIFY здесь хранится имя столбца и новый тип */ ASTPtr col_decl; /** В запросе ADD COLUMN здесь опционально хранится имя столбца, следующее после AFTER * В запросе DROP здесь хранится имя столбца для удаления */ ASTPtr column; /** В запросе DROP PARTITION здесь хранится имя partition'а. */ ASTPtr partition; bool detach = false; /// true для DETACH PARTITION. bool part = false; /// true для ATTACH [UNREPLICATED] PART bool unreplicated = false; /// true для ATTACH UNREPLICATED ... /** Для FETCH PARTITION - путь в ZK к шарду, с которого скачивать партицию. */ String from; /// deep copy void clone(Parameters & p) const { p = *this; p.col_decl = col_decl->clone(); p.column = column->clone(); p.partition = partition->clone(); } }; typedef std::vector ParameterContainer; ParameterContainer parameters; String database; String table; void addParameters(const Parameters & params) { parameters.push_back(params); if (params.col_decl) children.push_back(params.col_decl); if (params.column) children.push_back(params.column); if (params.partition) children.push_back(params.partition); } ASTAlterQuery(StringRange range_ = StringRange()) : IAST(range_) {}; /** Получить текст, который идентифицирует этот элемент. */ String getID() const override { return ("AlterQuery_" + database + "_" + table); }; ASTPtr clone() const override { ASTAlterQuery * res = new ASTAlterQuery(*this); for (ParameterContainer::size_type i = 0; i < parameters.size(); ++i) { parameters[i].clone(res->parameters[i]); } return res; } }; }