Method finalizeImpl

src/Processors/Formats/Impl/MySQLOutputFormat.cpp:110–153

}

void MySQLOutputFormat::finalizeImpl()
{
    if (!use_binary_result_set)
    {
        size_t affected_rows = 0;
        std::string human_readable_info;
        if (QueryStatusPtr process_list_elem = getContext()->getProcessListElement())
        {
            CurrentThread::finalizePerformanceCounters();
            QueryStatusInfo info = process_list_elem->getInfo();
            affected_rows = info.written_rows;
            double elapsed_seconds = static_cast<double>(info.elapsed_microseconds) / 1000000.0;
            human_readable_info = fmt::format(
                "Read {} rows, {} in {} sec., {} rows/sec., {}/sec.",
                info.read_rows,
                ReadableSize(info.read_bytes),
                elapsed_seconds,
                static_cast<size_t>(static_cast<double>(info.read_rows) / elapsed_seconds),
                ReadableSize(static_cast<double>(info.read_bytes) / elapsed_seconds));
        }

        const auto & header = getPort(PortKind::Main).getHeader();
        if (header.columns() == 0)
            packet_endpoint->sendPacket(OKPacket(0x0, client_capabilities, affected_rows, 0, 0, "", human_readable_info));
        else if (client_capabilities & CLIENT_DEPRECATE_EOF)
            packet_endpoint->sendPacket(OKPacket(0xfe, client_capabilities, affected_rows, 0, 0, "", human_readable_info));
        else
            packet_endpoint->sendPacket(EOFPacket(0, 0));
    }
    else
    {
        size_t affected_rows = 0;
        if (QueryStatusPtr process_list_elem = getContext()->getProcessListElement())
        {
            CurrentThread::finalizePerformanceCounters();
            QueryStatusInfo info = process_list_elem->getInfo();
            affected_rows = info.written_rows;
        }
        if (client_capabilities & CLIENT_DEPRECATE_EOF)
            packet_endpoint->sendPacket(OKPacket(0xfe, client_capabilities, affected_rows, 0, 0, "", ""));
        else
            packet_endpoint->sendPacket(EOFPacket(0, 0));
    }
}

void MySQLOutputFormat::flushImpl()
{