Struct BulkLoadRequest 

pub struct BulkLoadRequest<'a, S>
where
    S: AsyncRead + AsyncWrite + Unpin + Send,
{ /* private fields */ }

A handler for a bulk insert data flow.

Implementations

impl<'a, S> BulkLoadRequest<'a, S>

where S: AsyncRead + AsyncWrite + Unpin + Send,

pub async fn send(&mut self, row: TokenRow<'a>) -> Result<()>

Adds a new row to the bulk insert, flushing only when having a full packet of data.

A row that fails to encode is not sent, and the request stays usable. Dropping the request without finalize cancels the bulk insert; the connection stays usable.

Warning

After the last row, finalize must be called to flush the buffered data and for the data to actually be available in the table.

pub async fn finalize(self) -> Result<ExecuteResult>

Ends the bulk load, flushing all pending data to the wire.

This method must be called after sending all the data to flush all pending data and to get the server actually to store the rows to the table.

Trait Implementations

impl<'a, S> Debug for BulkLoadRequest<'a, S>

where S: AsyncRead + AsyncWrite + Unpin + Send + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.