#include #include #include #include namespace DB { namespace { void formatRenameTo(const String & new_name, const IAST::FormatSettings & settings) { settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << " RENAME TO " << (settings.hilite ? IAST::hilite_none : "") << quoteString(new_name); } void formatAuthentication(const Authentication & authentication, const IAST::FormatSettings & settings) { settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << " IDENTIFIED WITH " << (settings.hilite ? IAST::hilite_none : ""); switch (authentication.getType()) { case Authentication::Type::NO_PASSWORD: settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "no_password" << (settings.hilite ? IAST::hilite_none : ""); break; case Authentication::Type::PLAINTEXT_PASSWORD: settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "plaintext_password BY " << (settings.hilite ? IAST::hilite_none : "") << quoteString(authentication.getPassword()); break; case Authentication::Type::SHA256_PASSWORD: settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "sha256_hash BY " << (settings.hilite ? IAST::hilite_none : "") << quoteString(authentication.getPasswordHashHex()); break; case Authentication::Type::DOUBLE_SHA1_PASSWORD: settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "double_sha1_hash BY " << (settings.hilite ? IAST::hilite_none : "") << quoteString(authentication.getPasswordHashHex()); break; case Authentication::Type::LDAP_PASSWORD: settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "ldap BY " << (settings.hilite ? IAST::hilite_none : "") << quoteString(authentication.getLDAPServerName()); break; } } void formatHosts(const char * prefix, const AllowedClientHosts & hosts, const IAST::FormatSettings & settings) { if (prefix) settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << " " << prefix << " HOST " << (settings.hilite ? IAST::hilite_none : ""); else settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << " HOST " << (settings.hilite ? IAST::hilite_none : ""); if (hosts.empty()) { settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "NONE" << (settings.hilite ? IAST::hilite_none : ""); return; } if (hosts.containsAnyHost()) { settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "ANY" << (settings.hilite ? IAST::hilite_none : ""); return; } bool need_comma = false; if (hosts.containsLocalHost()) { if (std::exchange(need_comma, true)) settings.ostr << ", "; settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "LOCAL" << (settings.hilite ? IAST::hilite_none : ""); } const auto & addresses = hosts.getAddresses(); const auto & subnets = hosts.getSubnets(); if (!addresses.empty() || !subnets.empty()) { if (std::exchange(need_comma, true)) settings.ostr << ", "; settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "IP " << (settings.hilite ? IAST::hilite_none : ""); bool need_comma2 = false; for (const auto & address : addresses) { if (std::exchange(need_comma2, true)) settings.ostr << ", "; settings.ostr << quoteString(address.toString()); } for (const auto & subnet : subnets) { if (std::exchange(need_comma2, true)) settings.ostr << ", "; settings.ostr << quoteString(subnet.toString()); } } const auto & names = hosts.getNames(); if (!names.empty()) { if (std::exchange(need_comma, true)) settings.ostr << ", "; settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "NAME " << (settings.hilite ? IAST::hilite_none : ""); bool need_comma2 = false; for (const auto & name : names) { if (std::exchange(need_comma2, true)) settings.ostr << ", "; settings.ostr << quoteString(name); } } const auto & name_regexps = hosts.getNameRegexps(); if (!name_regexps.empty()) { if (std::exchange(need_comma, true)) settings.ostr << ", "; settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "REGEXP " << (settings.hilite ? IAST::hilite_none : ""); bool need_comma2 = false; for (const auto & host_regexp : name_regexps) { if (std::exchange(need_comma2, true)) settings.ostr << ", "; settings.ostr << quoteString(host_regexp); } } const auto & like_patterns = hosts.getLikePatterns(); if (!like_patterns.empty()) { if (std::exchange(need_comma, true)) settings.ostr << ", "; settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << "LIKE " << (settings.hilite ? IAST::hilite_none : ""); bool need_comma2 = false; for (const auto & like_pattern : like_patterns) { if (std::exchange(need_comma2, true)) settings.ostr << ", "; settings.ostr << quoteString(like_pattern); } } } void formatDefaultRoles(const ASTExtendedRoleSet & default_roles, const IAST::FormatSettings & settings) { settings.ostr << (settings.hilite ? IAST::hilite_keyword : "") << " DEFAULT ROLE " << (settings.hilite ? IAST::hilite_none : ""); default_roles.format(settings); } void formatSettings(const ASTSettingsProfileElements & settings, const IAST::FormatSettings & format) { format.ostr << (format.hilite ? IAST::hilite_keyword : "") << " SETTINGS " << (format.hilite ? IAST::hilite_none : ""); settings.format(format); } } String ASTCreateUserQuery::getID(char) const { return "CreateUserQuery"; } ASTPtr ASTCreateUserQuery::clone() const { return std::make_shared(*this); } void ASTCreateUserQuery::formatImpl(const FormatSettings & format, FormatState &, FormatStateStacked) const { if (attach) { format.ostr << (format.hilite ? hilite_keyword : "") << "ATTACH USER" << (format.hilite ? hilite_none : ""); } else { format.ostr << (format.hilite ? hilite_keyword : "") << (alter ? "ALTER USER" : "CREATE USER") << (format.hilite ? hilite_none : ""); } if (if_exists) format.ostr << (format.hilite ? hilite_keyword : "") << " IF EXISTS" << (format.hilite ? hilite_none : ""); else if (if_not_exists) format.ostr << (format.hilite ? hilite_keyword : "") << " IF NOT EXISTS" << (format.hilite ? hilite_none : ""); else if (or_replace) format.ostr << (format.hilite ? hilite_keyword : "") << " OR REPLACE" << (format.hilite ? hilite_none : ""); format.ostr << " " << backQuoteIfNeed(name); formatOnCluster(format); if (!new_name.empty()) formatRenameTo(new_name, format); if (authentication) formatAuthentication(*authentication, format); if (hosts) formatHosts(nullptr, *hosts, format); if (add_hosts) formatHosts("ADD", *add_hosts, format); if (remove_hosts) formatHosts("DROP", *remove_hosts, format); if (default_roles) formatDefaultRoles(*default_roles, format); if (settings && (!settings->empty() || alter)) formatSettings(*settings, format); } }