Struct Pipeline 

pub struct Pipeline { /* private fields */ }

A query pipeline for executing multiple queries efficiently.

Pipelines combine multiple queries and execute them with minimal round-trips to the database. This is especially useful for:

• Fetching a parent record and its relations
• Performing multiple inserts in sequence
• Complex transactions with multiple operations

Example

use prax_query::batch::Pipeline;

let pipeline = Pipeline::new()
    .query("SELECT * FROM users WHERE id = $1", vec![id.into()])
    .query("SELECT * FROM posts WHERE author_id = $1", vec![id.into()])
    .build();

let results = engine.execute_pipeline(pipeline).await?;

Implementations

impl Pipeline

pub fn new() -> Self

Create a new empty pipeline.

pub fn with_capacity(capacity: usize) -> Self

Create a pipeline with pre-allocated capacity.

pub fn push(&mut self, sql: impl Into<String>, params: Vec<FilterValue>)

Add a query to the pipeline.

pub fn push_execute(&mut self, sql: impl Into<String>, params: Vec<FilterValue>)

Add an execute-only query (no result rows expected).

pub fn queries(&self) -> &[PipelineQuery]

Get the queries.

pub fn len(&self) -> usize

Get the number of queries.

pub fn is_empty(&self) -> bool

Check if empty.

Trait Implementations

impl Clone for Pipeline

fn clone(&self) -> Pipeline

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Pipeline

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

Formats the value using the given formatter.

impl Default for Pipeline

fn default() -> Self

Returns the “default value” for a type.