Method sendDataFrom

src/Client/ClientBase.cpp:2213–2263

void ClientBase::sendDataFrom(ReadBuffer & buf, Block & sample, const ColumnsDescription & columns_description, ASTPtr parsed_query, bool have_more_data)
{
    String current_format = "Values";

    /// Data format can be specified in the INSERT query.
    if (const auto * insert = parsed_query->as<ASTInsertQuery>())
    {
        if (!insert->format.empty())
            current_format = insert->format;
    }

    const Settings & settings = client_context->getSettingsRef();

    /// Setting value from cmd arg overrides one from config.
    size_t insert_format_max_block_size_rows = settings[Setting::max_insert_block_size].changed
        ? settings[Setting::max_insert_block_size]
        : insert_format_max_block_size_rows_from_config.value_or(settings[Setting::max_insert_block_size]);

    size_t insert_format_max_block_size_bytes = settings[Setting::max_insert_block_size_bytes].changed
        ? settings[Setting::max_insert_block_size_bytes]
        : insert_format_max_block_size_bytes_from_config.value_or(settings[Setting::max_insert_block_size_bytes]);

    size_t insert_format_min_block_size_rows = settings[Setting::min_insert_block_size_rows].changed
        ? settings[Setting::min_insert_block_size_rows]
        : insert_format_min_block_size_rows_from_config.value_or(settings[Setting::min_insert_block_size_rows]);

    size_t insert_format_min_block_size_bytes = settings[Setting::min_insert_block_size_bytes].changed
        ? settings[Setting::min_insert_block_size_bytes]
        : insert_format_min_block_size_bytes_from_config.value_or(settings[Setting::min_insert_block_size_bytes]);

    auto source = client_context->getInputFormat(
        current_format,
        buf,
        sample,
        insert_format_max_block_size_rows,
        std::nullopt,
        insert_format_max_block_size_bytes,
        insert_format_min_block_size_rows,
        insert_format_min_block_size_bytes);
    Pipe pipe(source);

    if (columns_description.hasDefaults())
    {
        pipe.addSimpleTransform([&](const SharedHeader & header)
        {
            return std::make_shared<AddingDefaultsTransform>(header, columns_description, *source, client_context);
        });
    }

    sendDataFromPipe(std::move(pipe), parsed_query, have_more_data);
}

void ClientBase::sendDataFromPipe(Pipe && pipe, ASTPtr parsed_query, bool have_more_data)
{