Struct InsertBatcher 

pub struct InsertBatcher { /* private fields */ }

INSERT Batcher

Batches INSERT statements for improved throughput.

Implementations

impl InsertBatcher

pub fn new(config: BatchConfig) -> Self

Create a new INSERT batcher

pub fn add( &self, table: String, columns: Vec<String>, values: Vec<Vec<String>>, original_sql: String, ) -> Result<BatchTicket, BatchError>

Add an INSERT to the batch

pub fn flush_batch(&self, table: &str)

Flush a batch for a table

pub fn flush_all(&self)

Flush all pending batches

pub fn batch_size(&self, table: &str) -> usize

Get the current batch size for a table

pub fn stats(&self) -> BatchStats

Get statistics snapshot

pub fn shutdown(&self)

Shutdown the batcher

pub fn start_auto_flush(self: Arc<Self>) -> JoinHandle<()>

Start auto-flush background task