| 187 | } |
| 188 | |
| 189 | ASTPtr DatabaseHDFS::getCreateDatabaseQueryImpl() const |
| 190 | { |
| 191 | const auto & settings = getContext()->getSettingsRef(); |
| 192 | ParserCreateQuery parser; |
| 193 | |
| 194 | const String query = fmt::format("CREATE DATABASE {} ENGINE = HDFS('{}')", backQuoteIfNeed(database_name), source); |
| 195 | ASTPtr ast |
| 196 | = parseQuery(parser, query.data(), query.data() + query.size(), "", 0, settings[Setting::max_parser_depth], settings[Setting::max_parser_backtracks]); |
| 197 | |
| 198 | if (!comment.empty()) |
| 199 | { |
| 200 | auto & ast_create_query = ast->as<ASTCreateQuery &>(); |
| 201 | ast_create_query.set(ast_create_query.comment, make_intrusive<ASTLiteral>(comment)); |
| 202 | } |
| 203 | |
| 204 | return ast; |
| 205 | } |
| 206 | |
| 207 | void DatabaseHDFS::shutdown() |
| 208 | { |
nothing calls this directly
no test coverage detected