Struct mongodb::sync::Database

pub struct Database { /* fields omitted */ }

This is supported on crate feature sync only.

Database is the client-side abstraction of a MongoDB database. It can be used to perform database-level operations or to obtain handles to specific collections within the database. A Database can only be obtained through a Client by calling either Client::database or Client::database_with_options.

Database uses std::sync::Arc internally, so it can safely be shared across threads. For example:

let db = client.database("items");

for i in 0..5 {
    let db_ref = db.clone();

    std::thread::spawn(move || {
        let collection = db_ref.collection::<Document>(&format!("coll{}", i));

        // Do something with the collection
    });
}

Implementations

impl Database

pub fn name(&self) -> &str

Gets the name of the Database.

pub fn selection_criteria(&self) -> Option<&SelectionCriteria>

Gets the read preference of the Database.

pub fn read_concern(&self) -> Option<&ReadConcern>

Gets the read concern of the Database.

pub fn write_concern(&self) -> Option<&WriteConcern>

Gets the write concern of the Database.

pub fn collection<T>(&self, name: &str) -> Collection<T> where
    T: Serialize + DeserializeOwned + Unpin + Debug, 

Gets a handle to a collection with type T specified by name of the database. The Collection options (e.g. read preference and write concern) will default to those of the Database.

This method does not send or receive anything across the wire to the database, so it can be used repeatedly without incurring any costs from I/O.

pub fn collection_with_options<T>(
    &self,
    name: &str,
    options: CollectionOptions
) -> Collection<T> where
    T: Serialize + DeserializeOwned + Unpin + Debug, 

Gets a handle to a collection with type T specified by name in the cluster the Client is connected to. Operations done with this Collection will use the options specified by options by default and will otherwise default to those of the Database.

This method does not send or receive anything across the wire to the database, so it can be used repeatedly without incurring any costs from I/O.

pub fn drop(
    &self,
    options: impl Into<Option<DropDatabaseOptions>>
) -> Result<()>

Drops the database, deleting all data, collections, users, and indexes stored in it.

pub fn drop_with_session(
    &self,
    options: impl Into<Option<DropDatabaseOptions>>,
    session: &mut ClientSession
) -> Result<()>

Drops the database, deleting all data, collections, users, and indexes stored in it using the provided ClientSession.

pub fn list_collections(
    &self,
    filter: impl Into<Option<Document>>,
    options: impl Into<Option<ListCollectionsOptions>>
) -> Result<Cursor<CollectionSpecification>>

Gets information about each of the collections in the database. The cursor will yield a document pertaining to each collection in the database.

pub fn list_collections_with_session(
    &self,
    filter: impl Into<Option<Document>>,
    options: impl Into<Option<ListCollectionsOptions>>,
    session: &mut ClientSession
) -> Result<SessionCursor<CollectionSpecification>>

Gets information about each of the collections in the database using the provided ClientSession. The cursor will yield a document pertaining to each collection in the database.

pub fn list_collection_names(
    &self,
    filter: impl Into<Option<Document>>
) -> Result<Vec<String>>

Gets the names of the collections in the database.

pub fn list_collection_names_with_session(
    &self,
    filter: impl Into<Option<Document>>,
    session: &mut ClientSession
) -> Result<Vec<String>>

Gets the names of the collections in the database using the provided ClientSession.

pub fn create_collection(
    &self,
    name: impl AsRef<str>,
    options: impl Into<Option<CreateCollectionOptions>>
) -> Result<()>

Creates a new collection in the database with the given name and options.

Note that MongoDB creates collections implicitly when data is inserted, so this method is not needed if no special options are required.

pub fn create_collection_with_session(
    &self,
    name: impl AsRef<str>,
    options: impl Into<Option<CreateCollectionOptions>>,
    session: &mut ClientSession
) -> Result<()>

Creates a new collection in the database with the given name and options using the provided ClientSession.

Note that MongoDB creates collections implicitly when data is inserted, so this method is not needed if no special options are required.

pub fn run_command(
    &self,
    command: Document,
    selection_criteria: impl Into<Option<SelectionCriteria>>
) -> Result<Document>

Runs a database-level command.

Note that no inspection is done on doc, so the command will not use the database’s default read concern or write concern. If specific read concern or write concern is desired, it must be specified manually.

pub fn run_command_with_session(
    &self,
    command: Document,
    selection_criteria: impl Into<Option<SelectionCriteria>>,
    session: &mut ClientSession
) -> Result<Document>

Runs a database-level command using the provided ClientSession.

Note that no inspection is done on doc, so the command will not use the database’s default read concern or write concern. If specific read concern or write concern is desired, it must be specified manually.

pub fn aggregate(
    &self,
    pipeline: impl IntoIterator<Item = Document>,
    options: impl Into<Option<AggregateOptions>>
) -> Result<Cursor<Document>>

Runs an aggregation operation.

See the documentation here for more information on aggregations.

pub fn aggregate_with_session(
    &self,
    pipeline: impl IntoIterator<Item = Document>,
    options: impl Into<Option<AggregateOptions>>,
    session: &mut ClientSession
) -> Result<SessionCursor<Document>>

Runs an aggregation operation using the provided ClientSession.

See the documentation here for more information on aggregations.

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Database

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

Formats the value using the given formatter.