Struct AsyncInserter 

pub struct AsyncInserter<'conn> { /* private fields */ }

An async high-performance bulk data inserter.

AsyncInserter is the async mirror of Inserter. Both produce identical wire output (HyperBinary COPY) and have identical throughput characteristics; the difference is whether the network I/O is blocking (Inserter) or async/await (AsyncInserter).

Lifetime safety

The inserter borrows the underlying AsyncConnection for 'conn. The borrow checker prevents the connection from being dropped or moved while the inserter is live.

Single-use

Like the sync Inserter, AsyncInserter is intended for one COPY session per instance. After execute returns, the row counter is zeroed so a stray second call returns Ok(0) rather than corrupting the stream. To insert a second batch, construct a new AsyncInserter.

Implementations

impl<'conn> AsyncInserter<'conn>

pub fn new( connection: &'conn AsyncConnection, table_def: &TableDefinition, ) -> Result<Self>

Creates a new async inserter for the given table.

The underlying COPY session is started lazily on the first flush or execute, so construction is lightweight. The connection’s transport is validated eagerly — a gRPC connection returns an error immediately.

Errors

• Returns Error::InvalidTableDefinition if table_def has zero columns.
• Returns Error::Other if connection is using gRPC transport (COPY is TCP-only).

pub fn add_null(&mut self) -> Result<()>

Adds a NULL value to the next column.

pub fn add_bool(&mut self, value: bool) -> Result<()>

Adds a boolean value.

pub fn add_i16(&mut self, value: i16) -> Result<()>

Adds a 16-bit signed integer.

pub fn add_i32(&mut self, value: i32) -> Result<()>

Adds a 32-bit signed integer.

pub fn add_i64(&mut self, value: i64) -> Result<()>

Adds a 64-bit signed integer.

pub fn add_f32(&mut self, value: f32) -> Result<()>

Adds a 32-bit float.

pub fn add_f64(&mut self, value: f64) -> Result<()>

Adds a 64-bit float.

pub fn add_str(&mut self, value: &str) -> Result<()>

Adds a string (TEXT) value.

pub fn add_bytes(&mut self, value: &[u8]) -> Result<()>

Adds a bytes (BYTEA) value.

pub fn add_date(&mut self, value: Date) -> Result<()>

Adds a Date value.

pub fn add_time(&mut self, value: Time) -> Result<()>

Adds a Time value.

pub fn add_timestamp(&mut self, value: Timestamp) -> Result<()>

Adds a Timestamp value.

pub fn add_offset_timestamp(&mut self, value: OffsetTimestamp) -> Result<()>

Adds an OffsetTimestamp value.

pub fn add_interval(&mut self, value: Interval) -> Result<()>

Adds an Interval value.

pub fn add_numeric(&mut self, value: Numeric) -> Result<()>

Adds a Numeric value (NUMERIC). The encoding (small vs big) is chosen from the table definition’s column precision at this position.

Errors

Returns an error if the column’s precision cannot be determined from the table definition (NUMERIC columns must be declared with explicit precision/scale).

pub async fn end_row(&mut self) -> Result<()>

Marks the end of the current row. Must be called after every full row. May trigger an automatic flush of the buffered data to the server.

Errors

• Returns Error::Other if the column count for the row doesn’t match the table definition.
• Returns Error::Client / Error::Io on transport failures during the auto-flush.

pub async fn execute(&mut self) -> Result<u64>

Executes the insert and commits all buffered rows.

Sends any remaining buffered data and finishes the COPY operation. Returns the number of rows inserted.

The inserter is single-use: calling execute a second time returns Ok(0). Construct a new AsyncInserter to insert another batch.

Errors

• Returns Error::Other if there’s an incomplete row (partial column).
• Returns Error::Client / Error::Io if the COPY session or transport fails.

pub fn cancel(&mut self)

Cancels the insert and discards all buffered rows.

The Drop impl on AsyncCopyInWriter queues a CopyFail on the connection so the server tears the COPY down cleanly on the next connection use.

Trait Implementations

impl<'conn> Debug for AsyncInserter<'conn>

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

Formats the value using the given formatter.