Method processQueryText

programs/keeper-client/KeeperClient.cpp:450–547

}

bool KeeperClient::processQueryText(const String & text, bool is_interactive)
{
    if (exit_strings.contains(text))
        return false;

    static constexpr size_t total_retries = 10;
    std::chrono::milliseconds current_sleep{100};
    size_t i = 0;

    auto component_guard = Coordination::setCurrentComponent("KeeperClient::processQueryText");
    while (true)
    {
        try
        {
            if (i > 0)
                connectToKeeper();

            if (waiting_confirmation)
            {
                waiting_confirmation = false;
                if (text.size() == 1 && (text == "y" || text == "Y"))
                    confirmation_callback();
                return true;
            }

            const char * begin = text.data();
            const char * end = begin + text.size();

            /// Tokenize once for the entire input. We use skip_insignificant=false
            /// so that whitespace tokens are explicit — needed for `\ ` (escaped space)
            /// handling in parseKeeperArg. We avoid tryParseQuery because it rejects
            /// Error tokens (like `\`) during its lookahead scan.
            Tokens tokens(begin, end, 0, false);
            IParser::Pos pos(tokens, DBMS_DEFAULT_MAX_PARSER_DEPTH, DBMS_DEFAULT_MAX_PARSER_BACKTRACKS);

            while (!pos->isEnd())
            {
                /// Skip leading whitespace and semicolons (to support multi statements).
                while (!pos->isEnd() && (pos->type == TokenType::Whitespace || pos->type == TokenType::Semicolon))
                    ++pos;

                if (pos->isEnd())
                    break;

                KeeperParser parser;
                ASTPtr res;
                Expected expected;
                bool parsed = parser.parse(pos, res, expected);

                if (!parsed || !res)
                {
                    std::cerr << "Syntax error at position " << (pos->begin - begin) << "\n";
                    return true;
                }

                /// Skip trailing whitespace after the parsed command.
                while (!pos->isEnd() && pos->type == TokenType::Whitespace)
                    ++pos;