#include #include #include #include #include #include #include #include #include #include #include namespace DB { void ReplaceQueryParameterVisitor::visit(ASTPtr & ast) { for (auto & child : ast->children) { if (child->as()) visitQP(child); else visit(child); } } String ReplaceQueryParameterVisitor::getParamValue(const String & name) { auto search = parameters_substitution.find(name); if (search != parameters_substitution.end()) return search->second; else throw Exception("Expected name " + name + " in argument --param_{name}", ErrorCodes::BAD_ARGUMENTS); } void ReplaceQueryParameterVisitor::visitQP(ASTPtr & ast) { auto ast_param = ast->as(); const String value = getParamValue(ast_param->name); String type = ast_param->type; /// Replacing all occurrences of types Date and DateTime with String. /// String comparison is used in "WHERE" conditions with this types. boost::replace_all(type, "DateTime", "String"); boost::replace_all(type, "Date", "String"); const auto data_type = DataTypeFactory::instance().get(type); auto temp_column_ptr = data_type->createColumn(); IColumn & temp_column = *temp_column_ptr; ReadBufferFromString read_buffer{value}; FormatSettings format_settings; data_type->deserializeAsWholeText(temp_column, read_buffer, format_settings); Field field = temp_column[0]; ast = std::make_shared(std::move(field)); } }