2013-08-07 13:07:42 +00:00
|
|
|
|
#pragma once
|
|
|
|
|
|
|
|
|
|
#include <DB/Parsers/IAST.h>
|
|
|
|
|
|
|
|
|
|
namespace DB
|
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
/** ALTER запрос
|
|
|
|
|
* ALTER TABLE [db.]name_type
|
|
|
|
|
* ADD COLUMN col_name type [AFTER col_after],
|
|
|
|
|
* DROP COLUMN col_drop,
|
2014-08-06 09:24:30 +00:00
|
|
|
|
* MODIFY COLUMN col_name type,
|
|
|
|
|
* DROP PARTITION partition
|
2013-08-07 13:07:42 +00:00
|
|
|
|
* ...
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
class ASTAlterQuery : public IAST
|
|
|
|
|
{
|
|
|
|
|
public:
|
|
|
|
|
enum ParameterType
|
|
|
|
|
{
|
2014-08-06 09:24:30 +00:00
|
|
|
|
ADD_COLUMN,
|
|
|
|
|
DROP_COLUMN,
|
|
|
|
|
MODIFY_COLUMN,
|
|
|
|
|
DROP_PARTITION,
|
2014-08-07 11:46:01 +00:00
|
|
|
|
ATTACH_PARTITION,
|
2014-10-09 20:28:33 +00:00
|
|
|
|
FETCH_PARTITION,
|
2014-11-11 04:11:07 +00:00
|
|
|
|
FREEZE_PARTITION,
|
2013-08-07 13:07:42 +00:00
|
|
|
|
NO_TYPE
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
struct Parameters
|
|
|
|
|
{
|
|
|
|
|
Parameters() : type(NO_TYPE) {}
|
2014-08-07 09:23:55 +00:00
|
|
|
|
int type = NO_TYPE;
|
2013-08-07 13:07:42 +00:00
|
|
|
|
|
2013-08-13 08:27:37 +00:00
|
|
|
|
/** В запросе ADD COLUMN здесь хранится имя и тип добавляемого столбца
|
2014-07-10 10:16:50 +00:00
|
|
|
|
* В запросе DROP это поле не используется
|
|
|
|
|
* В запросе MODIFY здесь хранится имя столбца и новый тип
|
|
|
|
|
*/
|
2014-10-07 09:09:59 +00:00
|
|
|
|
ASTPtr col_decl;
|
2014-07-10 10:16:50 +00:00
|
|
|
|
|
2013-08-13 08:27:37 +00:00
|
|
|
|
/** В запросе ADD COLUMN здесь опционально хранится имя столбца, следующее после AFTER
|
2014-07-10 10:16:50 +00:00
|
|
|
|
* В запросе DROP здесь хранится имя столбца для удаления
|
|
|
|
|
*/
|
2013-08-07 13:07:42 +00:00
|
|
|
|
ASTPtr column;
|
|
|
|
|
|
2014-08-06 09:24:30 +00:00
|
|
|
|
/** В запросе DROP PARTITION здесь хранится имя partition'а.
|
|
|
|
|
*/
|
|
|
|
|
ASTPtr partition;
|
2014-08-07 09:23:55 +00:00
|
|
|
|
bool detach = false; /// true для DETACH PARTITION.
|
2014-08-06 09:24:30 +00:00
|
|
|
|
|
2014-08-07 11:46:01 +00:00
|
|
|
|
bool part = false; /// true для ATTACH [UNREPLICATED] PART
|
2015-04-21 13:10:08 +00:00
|
|
|
|
bool unreplicated = false; /// true для ATTACH UNREPLICATED, DROP UNREPLICATED ...
|
2014-08-07 11:46:01 +00:00
|
|
|
|
|
2014-10-09 20:28:33 +00:00
|
|
|
|
/** Для FETCH PARTITION - путь в ZK к шарду, с которого скачивать партицию.
|
|
|
|
|
*/
|
|
|
|
|
String from;
|
|
|
|
|
|
2013-08-07 13:07:42 +00:00
|
|
|
|
/// deep copy
|
2013-08-09 00:12:59 +00:00
|
|
|
|
void clone(Parameters & p) const
|
2013-08-07 13:07:42 +00:00
|
|
|
|
{
|
2014-08-07 11:46:01 +00:00
|
|
|
|
p = *this;
|
2014-10-07 09:09:59 +00:00
|
|
|
|
p.col_decl = col_decl->clone();
|
2014-08-06 09:24:30 +00:00
|
|
|
|
p.column = column->clone();
|
|
|
|
|
p.partition = partition->clone();
|
2013-08-07 13:07:42 +00:00
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
typedef std::vector<Parameters> ParameterContainer;
|
|
|
|
|
ParameterContainer parameters;
|
|
|
|
|
String database;
|
|
|
|
|
String table;
|
|
|
|
|
|
|
|
|
|
|
2014-08-06 09:24:30 +00:00
|
|
|
|
void addParameters(const Parameters & params)
|
|
|
|
|
{
|
|
|
|
|
parameters.push_back(params);
|
2014-10-07 09:09:59 +00:00
|
|
|
|
if (params.col_decl)
|
|
|
|
|
children.push_back(params.col_decl);
|
2014-08-06 09:24:30 +00:00
|
|
|
|
if (params.column)
|
|
|
|
|
children.push_back(params.column);
|
|
|
|
|
if (params.partition)
|
|
|
|
|
children.push_back(params.partition);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2014-04-08 07:47:51 +00:00
|
|
|
|
ASTAlterQuery(StringRange range_ = StringRange()) : IAST(range_) {};
|
2013-08-07 13:07:42 +00:00
|
|
|
|
|
|
|
|
|
/** Получить текст, который идентифицирует этот элемент. */
|
2014-12-17 15:26:24 +00:00
|
|
|
|
String getID() const override { return ("AlterQuery_" + database + "_" + table); };
|
2013-08-07 13:07:42 +00:00
|
|
|
|
|
2014-12-17 15:26:24 +00:00
|
|
|
|
ASTPtr clone() const override
|
2013-08-07 13:07:42 +00:00
|
|
|
|
{
|
|
|
|
|
ASTAlterQuery * res = new ASTAlterQuery(*this);
|
2013-08-09 00:12:59 +00:00
|
|
|
|
for (ParameterContainer::size_type i = 0; i < parameters.size(); ++i)
|
2013-08-07 13:07:42 +00:00
|
|
|
|
{
|
|
|
|
|
parameters[i].clone(res->parameters[i]);
|
|
|
|
|
}
|
|
|
|
|
return res;
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
}
|