Struct CopyEncoder 

pub struct CopyEncoder { /* private fields */ }

Encoder for COPY operations.

This encoder produces CopyData messages for PGCOPY binary, text, and CSV formats.

Implementations

impl CopyEncoder

pub fn new_binary(schema: Arc<Vec<FieldInfo>>) -> Self

Create a new binary format COPY encoder.

pub fn new_text(schema: Arc<Vec<FieldInfo>>, options: CopyTextOptions) -> Self

Create a new text format COPY encoder.

pub fn new_csv(schema: Arc<Vec<FieldInfo>>, options: CopyCsvOptions) -> Self

Create a new CSV format COPY encoder.

pub fn encode_field<T>(&mut self, value: &T) -> PgWireResult<()>

where T: ToSql + ToSqlText + Sized,

Encode a field value.

This method uses the type and format information from the schema.

pub fn take_copy(&mut self) -> CopyData

Take the current row as a CopyData message.

For binary format: first call includes PGCOPY header. For text/CSV format: each call returns one row with a trailing newline.

pub fn finish_copy_binary() -> CopyData

Finish the COPY operation of binary format.

For binary format: returns trailer (-1). Note that this trailer is automatically appended to stream if you use CopyResponse API.