Struct AsyncArrowInserterOwned 

pub struct AsyncArrowInserterOwned { /* private fields */ }

Owned-handle variant of AsyncArrowInserter that holds an Arc<AsyncConnection> instead of a borrow.

Semantics are identical to AsyncArrowInserter — same HyperBinary Arrow-stream COPY pipeline, same flush threshold, same Drop-time best-effort cancel. The only difference is that this variant is 'static and can therefore live in structs that can’t carry lifetimes (N-API classes, tokio::spawn tasks that outlive the constructor’s stack frame, etc).

Implementations

impl AsyncArrowInserterOwned

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

Creates a new owned-handle async Arrow inserter.

Arguments

• connection - Arc-shared async database connection. The Arc is cloned into the inserter and kept alive for its lifetime, so callers can drop their own handle immediately after construction.
• table_def - The table definition for the target table.

Errors

• Returns Error::Other with message "Table definition must have at least one column" if table_def has no columns.
• Returns Error::Other if connection is using gRPC transport.

pub fn with_flush_threshold(self, threshold: usize) -> Self

Sets a custom flush threshold in bytes. Default: 16 MB.

pub async fn insert_data(&mut self, arrow_ipc_data: &[u8]) -> Result<()>

Inserts a complete Arrow IPC stream (schema + record batches). Use this for single-chunk inserts or as the first call of a multi-chunk insert; subsequent chunks use insert_record_batches.

Errors

• Returns Error::Other if a schema was already sent.
• Returns Error::Other / Error::Client if the lazy COPY session cannot be opened.
• Returns Error::Client / Error::Io if the server rejects the data or the socket write fails.

pub async fn insert_record_batches( &mut self, arrow_batch_data: &[u8], ) -> Result<()>

Inserts Arrow record-batch bytes without a schema header. Must be called after insert_data or insert_raw.

Errors

• Returns Error::Other if no schema has been sent yet.
• Returns Error::Client / Error::Io if the server rejects the data or the socket write fails.

pub async fn insert_raw(&mut self, data: &[u8]) -> Result<()>

Low-level: send raw bytes without schema tracking. The first call transitions schema_sent to true. Use this when you are managing Arrow IPC framing yourself.

Errors

• Returns Error::Other / Error::Client if the lazy COPY session cannot be opened.
• Returns Error::Client / Error::Io if the server rejects the data or the socket write fails.

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

Finalizes the COPY session and returns the affected row count.

Errors

• Returns Error::Other with message "No data was inserted before execute()" if no COPY session was ever opened.
• Returns Error::Client / Error::Io if the CommandComplete round-trip fails.

pub async fn cancel(self)

Cancels the COPY session; any data sent so far is discarded.

pub fn has_data(&self) -> bool

Returns true if any data has been inserted.

pub fn total_bytes(&self) -> usize

Returns the total bytes sent.

pub fn chunk_count(&self) -> usize

Returns the number of chunks sent.

Trait Implementations

impl Debug for AsyncArrowInserterOwned

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

Formats the value using the given formatter.

impl Drop for AsyncArrowInserterOwned

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.