mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-15 19:02:04 +00:00
47 lines
1.0 KiB
C++
47 lines
1.0 KiB
C++
#pragma once
|
|
|
|
#include <Processors/Formats/IRowOutputFormat.h>
|
|
#include <Core/Block.h>
|
|
|
|
#include <Core/MySQL/PacketEndpoint.h>
|
|
#include <Processors/Formats/IOutputFormat.h>
|
|
|
|
|
|
namespace DB
|
|
{
|
|
|
|
class IColumn;
|
|
class IDataType;
|
|
class WriteBuffer;
|
|
struct FormatSettings;
|
|
|
|
/** A stream for outputting data in a binary line-by-line format.
|
|
*/
|
|
class MySQLOutputFormat final : public IOutputFormat, WithContext
|
|
{
|
|
public:
|
|
MySQLOutputFormat(WriteBuffer & out_, const Block & header_, const FormatSettings & settings_);
|
|
|
|
String getName() const override { return "MySQLOutputFormat"; }
|
|
|
|
void setContext(ContextPtr context_);
|
|
|
|
void consume(Chunk) override;
|
|
void finalize() override;
|
|
void flush() override;
|
|
void doWritePrefix() override { initialize(); }
|
|
|
|
private:
|
|
void initialize();
|
|
|
|
bool initialized = false;
|
|
uint32_t client_capabilities = 0;
|
|
uint8_t * sequence_id = nullptr;
|
|
uint8_t dummy_sequence_id = 0;
|
|
MySQLProtocol::PacketEndpointPtr packet_endpoint;
|
|
DataTypes data_types;
|
|
Serializations serializations;
|
|
};
|
|
|
|
}
|