mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-21 17:20:50 +00:00
72 lines
2.9 KiB
C++
72 lines
2.9 KiB
C++
#pragma once
|
||
|
||
#include <statdaemons/OptimizedRegularExpression.h>
|
||
|
||
#include <DB/Storages/StorageFactory.h>
|
||
#include <DB/Storages/StorageMerge.h>
|
||
#include <DB/Parsers/ASTExpressionList.h>
|
||
#include <DB/Parsers/ASTIdentifier.h>
|
||
#include <DB/Parsers/ASTLiteral.h>
|
||
#include <DB/TableFunctions/ITableFunction.h>
|
||
|
||
|
||
namespace DB
|
||
{
|
||
|
||
/*
|
||
* merge(db_name, tables_regexp)- создаёт временный StorageMerge.
|
||
* Cтруктура таблицы берётся из первой попавшейся таблицы, подходящей под регексп.
|
||
* Если такой таблицы нет - кидается исключение.
|
||
*/
|
||
|
||
class TableFunctionMerge: public ITableFunction
|
||
{
|
||
public:
|
||
std::string getName() const { return "merge"; }
|
||
|
||
StoragePtr execute(ASTPtr ast_function, Context & context)
|
||
{
|
||
ASTs & args_func = dynamic_cast<ASTFunction &>(*ast_function).children;
|
||
|
||
if (args_func.size() != 1)
|
||
throw Exception("Storage Merge requires exactly 2 parameters"
|
||
" - name of source database and regexp for table names.",
|
||
ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
|
||
|
||
ASTs & args = dynamic_cast<ASTExpressionList &>(*args_func.at(0)).children;
|
||
|
||
if (args.size() != 2)
|
||
throw Exception("Storage Merge requires exactly 2 parameters"
|
||
" - name of source database and regexp for table names.",
|
||
ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
|
||
|
||
String source_database = dynamic_cast<ASTIdentifier &>(*args[0]).name;
|
||
String table_name_regexp = safeGet<const String &>(dynamic_cast<ASTLiteral &>(*args[1]).value);
|
||
|
||
/// В InterpreterSelectQuery будет создан ExpressionAnalzyer, который при обработке запроса наткнется на этот Identifier.
|
||
/// Нам необходимо его пометить как имя базы данных, посколку по умолчанию стоит значение column
|
||
dynamic_cast<ASTIdentifier &>(*args[0]).kind = ASTIdentifier::Database;
|
||
|
||
return StorageMerge::create(getName(), chooseColumns(source_database, table_name_regexp, context), source_database, table_name_regexp, context);
|
||
}
|
||
|
||
private:
|
||
NamesAndTypesListPtr chooseColumns(const String & source_database, const String & table_name_regexp_, Context & context) const
|
||
{
|
||
OptimizedRegularExpression table_name_regexp(table_name_regexp_);
|
||
|
||
/// Список таблиц могут менять в другом потоке.
|
||
Poco::ScopedLock<Poco::Mutex> lock(context.getMutex());
|
||
context.assertDatabaseExists(source_database);
|
||
const Tables & tables = context.getDatabases().at(source_database);
|
||
for (Tables::const_iterator it = tables.begin(); it != tables.end(); ++it)
|
||
if (table_name_regexp.match(it->first))
|
||
return new NamesAndTypesList((it->second)->getColumnsList());
|
||
|
||
throw Exception("Error whyle executing table function merge. In database " + source_database + " no one matches regular expression: " + table_name_regexp_, ErrorCodes::UNKNOWN_TABLE);
|
||
}
|
||
};
|
||
|
||
|
||
}
|