Method runInteractive

src/Client/ClientBase.cpp:3846–4094

}

void ClientBase::runInteractive()
{
    if (getClientConfiguration().has("query_id"))
        throw Exception(ErrorCodes::BAD_ARGUMENTS, "query_id could be specified only in non-interactive mode");
    if (getClientConfiguration().getBool("print-time-to-stderr", false))
        throw Exception(ErrorCodes::BAD_ARGUMENTS, "time option could be specified only in non-interactive mode");

    initQueryIdFormats();

#if USE_CLIENT_AI
    /// AI SQL generation is disabled for the embedded client (SSH and WebSocket protocols)
    /// because it accesses the environment (API keys) which could be a security concern.
    if (!isEmbeeddedClient())
        initAIProvider();
#endif

    /// Initialize DateLUT here to avoid counting time spent here as query execution time.
    const auto local_tz = DateLUT::instance().getTimeZone();

    suggest.emplace();
    if (load_suggestions)
    {
        /// Load suggestion data from the server.
        if (client_context->getApplicationType() == Context::ApplicationType::CLIENT)
            suggest->load<Connection>(client_context, connection_parameters, getClientConfiguration().getInt("suggestion_limit"), wait_for_suggestions_to_load);
        else if (client_context->getApplicationType() == Context::ApplicationType::LOCAL || client_context->getApplicationType() == Context::ApplicationType::SERVER)
            suggest->load<LocalConnection>(client_context, connection_parameters, getClientConfiguration().getInt("suggestion_limit"), wait_for_suggestions_to_load);
    }

    if (home_path.empty())
    {
        const char * home_path_cstr = getenv("HOME"); // NOLINT(concurrency-mt-unsafe)
        if (home_path_cstr)
            home_path = home_path_cstr;
    }

    history_max_entries = getClientConfiguration().getUInt("history_max_entries", 1000000);

    LineReader::Patterns query_extenders = {"\\"};
    LineReader::Patterns query_delimiters = {";", "\\G", "\\G;"};
    char word_break_characters[] = " \t\v\f\a\b\r\n`~!@#$%^&*()-=+[{]}\\|;:'\",<.>/?";

    std::unique_ptr<LineReader> lr;


#if USE_REPLXX
    replxx::Replxx::highlighter_callback_with_pos_t highlight_callback{};

    if (getClientConfiguration().getBool("highlight", true))
    {
        highlight_callback = [this](const String & query, std::vector<replxx::Replxx::Color> & colors, int pos)
        {
            highlight(query, colors, *client_context, pos, rainbow_parentheses);
        };
    }

    /// Don't allow embedded client to read from and write to any file on the server's filesystem.
    String actual_history_file_path;