Struct dittolive_ditto::store::query_builder::ScopedStore

pub struct ScopedStore<'batch> { /* private fields */ }

Use .with_batched_write(...) to group operations in a transaction.

Example

use dittolive_ditto::prelude::*;

ditto.store().with_batched_write(|mut batch| {
    let mut foo_collection = batch.collection("foo");
    foo_collection.find_by_id((&b"fooey"[..]).into()).remove();

    // Expensive multi-mutation op:
    let mut bar_collection = batch.collection("bar");
    for i in 0..10_000 {
        bar_collection.upsert(serde_json::json!({
            "bar_count": i
        })).unwrap();
    }

    // At this point, we must say whether we commit or revert
    // these changes:
    batch.commit_changes()
})?;

Implementations

impl<'batch> ScopedStore<'batch>

pub fn commit_changes(self: ScopedStore<'batch>) -> Action<'batch>

Commit changes done in this ScopedStore.

pub fn revert_changes(self: ScopedStore<'batch>) -> Action<'batch>

Revert changes done in this ScopedStore.

pub fn collection<'coll>( self: &'coll mut ScopedStore<'batch>, collection_name: &str, ) -> ScopedCollection<'coll, 'batch>

Return an handle to change a single Collection.