Method sendData

src/Client/ClientBase.cpp:2051–2210

void ClientBase::sendData(Block & sample, const ColumnsDescription & columns_description, ASTPtr parsed_query)
{
    /// Get columns description from variable or (if it was empty) create it from sample.
    auto columns_description_for_query = columns_description.empty() ? ColumnsDescription(sample.getNamesAndTypesList()) : columns_description;
    if (columns_description_for_query.empty())
    {
        throw Exception(ErrorCodes::LOGICAL_ERROR,
                        "Column description is empty and it can't be built from sample from table. "
                        "Cannot execute query.");
    }

    /// If INSERT data must be sent.
    auto * parsed_insert_query = parsed_query->as<ASTInsertQuery>();
    if (!parsed_insert_query)
        return;

    /// If it's clickhouse-local, and the input data reading is already baked into the query pipeline,
    /// don't read the data again here. This happens in some cases (e.g. input() table function) but not others (e.g. INFILE).
    if (!connection->isSendDataNeeded())
        return;

    bool have_data_in_stdin = !is_interactive && !stdin_is_a_tty && isStdinNotEmptyAndValid(*std_in);

    if (need_render_progress)
    {
        if (auto * std_in_desc = typeid_cast<ReadBufferFromFileDescriptor *>(std_in.get()))
        {
            /// Set total_bytes_to_read for current fd.
            FileProgress file_progress(0, std_in_desc->getFileSize());
            progress_indication.updateProgress(Progress(file_progress));

            /// Set callback to be called on file progress.
            if (tty_buf)
                progress_indication.setFileProgressCallback(client_context, *tty_buf, tty_mutex);
        }
    }

    /// If data fetched from file (maybe compressed file)
    if (parsed_insert_query->infile)
    {
        if (isEmbeeddedClient())
            throw Exception(ErrorCodes::SUPPORT_IS_DISABLED, "Reading from INFILE is disabled when you are running client embedded into server.");

        /// Get name of this file (path to file)
        const auto & in_file_node = parsed_insert_query->infile->as<ASTLiteral &>();
        const auto in_file = in_file_node.value.safeGet<std::string>();

        std::string compression_method;
        /// Compression method can be specified in query
        if (parsed_insert_query->compression)
        {
            const auto & compression_method_node = parsed_insert_query->compression->as<ASTLiteral &>();
            compression_method = compression_method_node.value.safeGet<std::string>();
        }

        String current_format = parsed_insert_query->format;
        if (current_format.empty())
            current_format = FormatFactory::instance().getFormatFromFileName(in_file);