Struct BulkWrite

pub struct BulkWrite<'a, R> { /* private fields */ }

Performs multiple write operations. Construct with Client::bulk_write.

Implementations

impl<'a> BulkWrite<'a, SummaryBulkWriteResult>

pub fn verbose_results(self) -> BulkWrite<'a, VerboseBulkWriteResult>

Return a VerboseBulkWriteResult with individual results for each successfully performed write.

impl<'a, R> BulkWrite<'a, R>

where R: BulkWriteResult,

pub fn session( self, session: impl Into<&'a mut ClientSession>, ) -> BulkWrite<'a, R>

Use the provided session when running the operation.

pub fn with_options( self, value: impl Into<Option<BulkWriteOptions>>, ) -> BulkWrite<'a, R>

Set all options. Note that this will replace all previous values set.

pub fn ordered(self, value: bool) -> BulkWrite<'a, R>

Whether the operations should be performed in the order in which they were specified. If true, no more writes will be performed if a single write fails. If false, writes will continue to be attempted if a single write fails.

Defaults to true.

pub fn bypass_document_validation(self, value: bool) -> BulkWrite<'a, R>

Whether document-level validation should be bypassed.

Defaults to false.

pub fn comment(self, value: impl Into<Bson>) -> BulkWrite<'a, R>

An arbitrary comment to help trace the operation through the database profiler, currentOp and logs.

pub fn let_vars(self, value: Document) -> BulkWrite<'a, R>

A map of parameter names and values to apply to all operations within the bulk write. Values must be constant or closed expressions that do not reference document fields. Parameters can then be accessed as variables in an aggregate expression context (e.g. “$$var”).

pub fn write_concern(self, value: WriteConcern) -> BulkWrite<'a, R>

The write concern to use for this operation.

Trait Implementations

impl<'a> Action for BulkWrite<'a, SummaryBulkWriteResult>

fn optional<Value>( self, value: Option<Value>, f: impl FnOnce(Self, Value) -> Self, ) -> Self

where Self: Sized,

If the value is Some, call the provided function on self. Convenient for chained updates with values that need to be set conditionally. For example:

impl<'a> Action for BulkWrite<'a, VerboseBulkWriteResult>

fn optional<Value>( self, value: Option<Value>, f: impl FnOnce(Self, Value) -> Self, ) -> Self

where Self: Sized,

If the value is Some, call the provided function on self. Convenient for chained updates with values that need to be set conditionally. For example:

impl<'a> IntoFuture for BulkWrite<'a, SummaryBulkWriteResult>

type Output = Result<SummaryBulkWriteResult, Error>

The output that the future will produce on completion.

type IntoFuture = SummaryBulkWriteFuture<'a>

Which kind of future are we turning this into?

fn into_future( self, ) -> <BulkWrite<'a, SummaryBulkWriteResult> as IntoFuture>::IntoFuture

Creates a future from a value.

impl<'a> IntoFuture for BulkWrite<'a, VerboseBulkWriteResult>

type Output = Result<VerboseBulkWriteResult, Error>

The output that the future will produce on completion.

type IntoFuture = VerboseBulkWriteFuture<'a>

Which kind of future are we turning this into?

fn into_future( self, ) -> <BulkWrite<'a, VerboseBulkWriteResult> as IntoFuture>::IntoFuture

Creates a future from a value.