mongodb 3.3.0

The official MongoDB driver for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

use crate::bson::{Bson, Document};
use std::time::Duration;

use crate::{
    collation::Collation,
    concern::WriteConcern,
    db::options::{
        ChangeStreamPreAndPostImages,
        ClusteredIndex,
        IndexOptionDefaults,
        TimeseriesOptions,
        ValidationAction,
        ValidationLevel,
    },
    options::CreateCollectionOptions,
    ClientSession,
    Database,
};

use super::{deeplink, export_doc, option_setters, options_doc};

impl Database {
    /// Creates a new collection in the database with the given `name`.
    ///
    /// Note that MongoDB creates collections implicitly when data is inserted, so this method is
    /// not needed if no special options are required.
    ///
    /// `await` will return d[`Result<()>`].
    #[deeplink]
    #[options_doc(create_coll)]
    pub fn create_collection(&self, name: impl Into<String>) -> CreateCollection {
        CreateCollection {
            db: self,
            name: name.into(),
            options: None,
            session: None,
        }
    }
}

#[cfg(feature = "sync")]
impl crate::sync::Database {
    /// Creates a new collection in the database with the given `name`.
    ///
    /// Note that MongoDB creates collections implicitly when data is inserted, so this method is
    /// not needed if no special options are required.
    ///
    /// [`run`](CreateCollection::run) will return d[`Result<()>`].
    #[deeplink]
    #[options_doc(create_coll, sync)]
    pub fn create_collection(&self, name: impl Into<String>) -> CreateCollection {
        self.async_database.create_collection(name)
    }
}

/// Creates a new collection.  Construct with [`Database::create_collection`].
#[must_use]
pub struct CreateCollection<'a> {
    pub(crate) db: &'a Database,
    pub(crate) name: String,
    pub(crate) options: Option<CreateCollectionOptions>,
    pub(crate) session: Option<&'a mut ClientSession>,
}

#[option_setters(crate::db::options::CreateCollectionOptions)]
#[export_doc(create_coll)]
impl<'a> CreateCollection<'a> {
    /// Use the provided session when running the operation.
    pub fn session(mut self, value: impl Into<&'a mut ClientSession>) -> Self {
        self.session = Some(value.into());
        self
    }
}

// Action impl in src/db/action/create_collection.rs