Struct BulkUpdatePipeline 

pub struct BulkUpdatePipeline { /* private fields */ }

Builder for creating bulk update pipelines.

Implementations

impl BulkUpdatePipeline

pub fn new(table: impl Into<String>) -> Self

Create a new bulk update pipeline.

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

Set database type.

pub fn add_update( &mut self, set: Vec<(String, FilterValue)>, where_clause: Vec<(String, FilterValue)>, )

Add an update.

pub fn len(&self) -> usize

Get number of updates.

pub fn is_empty(&self) -> bool

Check if empty.

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

Generate UPDATE statements.

pub fn to_pipeline(self) -> QueryPipeline

Convert to query pipeline.

Trait Implementations

impl Debug for BulkUpdatePipeline

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

Formats the value using the given formatter.