#include #include #include #include namespace DB { /// Parse database.table or table. static bool parseDatabaseAndTable( ASTRenameQuery::Table & db_and_table, IParser::Pos & pos, Expected & expected) { ParserIdentifier name_p; ParserToken s_dot(TokenType::Dot); ASTPtr database; ASTPtr table; if (!name_p.parse(pos, table, expected)) return false; if (s_dot.ignore(pos, expected)) { database = table; if (!name_p.parse(pos, table, expected)) return false; } db_and_table.database.clear(); tryGetIdentifierNameInto(database, db_and_table.database); tryGetIdentifierNameInto(table, db_and_table.table); return true; } bool ParserRenameQuery::parseImpl(Pos & pos, ASTPtr & node, Expected & expected) { ParserKeyword s_rename_table("RENAME TABLE"); ParserKeyword s_to("TO"); ParserToken s_comma(TokenType::Comma); if (!s_rename_table.ignore(pos, expected)) return false; ASTRenameQuery::Elements elements; while (true) { if (!elements.empty() && !s_comma.ignore(pos)) break; elements.push_back(ASTRenameQuery::Element()); if (!parseDatabaseAndTable(elements.back().from, pos, expected) || !s_to.ignore(pos) || !parseDatabaseAndTable(elements.back().to, pos, expected)) return false; } String cluster_str; if (ParserKeyword{"ON"}.ignore(pos, expected)) { if (!ASTQueryWithOnCluster::parse(pos, cluster_str, expected)) return false; } auto query = std::make_shared(); query->cluster = cluster_str; node = query; query->elements = elements; return true; } }