Struct QueryPipeline 

pub struct QueryPipeline { /* private fields */ }

Query pipeline for batching multiple operations.

Implementations

impl QueryPipeline

pub fn new(config: PipelineConfig) -> Self

Create a new query pipeline.

pub fn for_database(self, db_type: DatabaseType) -> Self

Set database type.

pub fn add_query(self, sql: impl Into<String>, params: Vec<FilterValue>) -> Self

Add a query to the pipeline.

pub fn add_execute( self, sql: impl Into<String>, params: Vec<FilterValue>, ) -> Self

Add an execute-only query.

pub fn add_insert( self, sql: impl Into<String>, params: Vec<FilterValue>, ) -> Self

Add an INSERT query.

pub fn add_update( self, sql: impl Into<String>, params: Vec<FilterValue>, ) -> Self

Add an UPDATE query.

pub fn add_delete( self, sql: impl Into<String>, params: Vec<FilterValue>, ) -> Self

Add a DELETE query.

pub fn add_select( self, sql: impl Into<String>, params: Vec<FilterValue>, ) -> Self

Add a SELECT query.

pub fn push(&mut self, query: PipelineQuery)

Add a custom pipeline query.

pub fn len(&self) -> usize

Get number of queries.

pub fn is_empty(&self) -> bool

Check if pipeline is empty.

pub fn queries(&self) -> &VecDeque<PipelineQuery>

Get the queries.

pub fn to_batch_sql(&self) -> Option<(String, Vec<FilterValue>)>

Convert to batch SQL for databases that support it.

Returns None if the database doesn’t support multi-statement execution.

pub fn into_batches(self) -> Vec<Vec<PipelineQuery>>

Split into batches based on config.

pub fn to_transaction_sql(&self) -> Vec<(String, Vec<FilterValue>)>

Create SQL for transactional execution.

Trait Implementations

impl Debug for QueryPipeline

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

Formats the value using the given formatter.