mongodb-driver-kotlin-coroutine/com.mongodb.kotlin.client.coroutine/MongoDatabase

MongoDatabase

class MongoDatabase(wrapped: MongoDatabase)

The MongoDatabase representation.

Constructors

MongoDatabase

constructor(wrapped: MongoDatabase)

Functions

aggregate

@JvmName(name = "aggregateAsDocument")

fun aggregate(pipeline: List<Bson>): AggregateFlow<Document>

inline fun <T : Any> aggregate(pipeline: List<Bson>): AggregateFlow<T>

@JvmName(name = "aggregateAsDocumentWithSession")

fun aggregate(clientSession: ClientSession, pipeline: List<Bson>): AggregateFlow<Document>

inline fun <T : Any> aggregate(clientSession: ClientSession, pipeline: List<Bson>): AggregateFlow<T>

fun <T : Any> aggregate(pipeline: List<Bson>, resultClass: Class<T>): AggregateFlow<T>

fun <T : Any> aggregate(clientSession: ClientSession, pipeline: List<Bson>, resultClass: Class<T>): AggregateFlow<T>

Runs an aggregation framework pipeline on the database for pipeline stages that do not require an underlying collection, such as $currentOp and $listLocalSessions.

createCollection

suspend fun createCollection(collectionName: String, createCollectionOptions: CreateCollectionOptions = CreateCollectionOptions())

suspend fun createCollection(clientSession: ClientSession, collectionName: String, createCollectionOptions: CreateCollectionOptions = CreateCollectionOptions())

Create a new collection with the selected options

createView

suspend fun createView(viewName: String, viewOn: String, pipeline: List<Bson>, createViewOptions: CreateViewOptions = CreateViewOptions())

suspend fun createView(clientSession: ClientSession, viewName: String, viewOn: String, pipeline: List<Bson>, createViewOptions: CreateViewOptions = CreateViewOptions())

Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.

drop

suspend fun drop()

suspend fun drop(clientSession: ClientSession)

Drops this database.

getCollection

inline fun <T : Any> getCollection(collectionName: String): MongoCollection<T>

fun <T : Any> getCollection(collectionName: String, resultClass: Class<T>): MongoCollection<T>

Gets a collection.

listCollectionNames

fun listCollectionNames(): Flow<String>

fun listCollectionNames(clientSession: ClientSession): Flow<String>

Gets the names of all the collections in this database.

listCollections

@JvmName(name = "listCollectionsAsDocument")

fun listCollections(): ListCollectionsFlow<Document>

inline fun <T : Any> listCollections(): ListCollectionsFlow<T>

@JvmName(name = "listCollectionsAsDocumentWithSession")

fun listCollections(clientSession: ClientSession): ListCollectionsFlow<Document>

inline fun <T : Any> listCollections(clientSession: ClientSession): ListCollectionsFlow<T>

fun <T : Any> listCollections(resultClass: Class<T>): ListCollectionsFlow<T>

fun <T : Any> listCollections(clientSession: ClientSession, resultClass: Class<T>): ListCollectionsFlow<T>

Gets all the collections in this database.

runCommand

@JvmName(name = "runCommandDocument")

suspend fun runCommand(command: Bson, readPreference: ReadPreference = this.readPreference): Document

inline suspend fun <T : Any> runCommand(command: Bson, readPreference: ReadPreference = this.readPreference): T

@JvmName(name = "runCommandDocumentWithSession")

suspend fun runCommand(clientSession: ClientSession, command: Bson, readPreference: ReadPreference = this.readPreference): Document

inline suspend fun <T : Any> runCommand(clientSession: ClientSession, command: Bson, readPreference: ReadPreference = this.readPreference): T

suspend fun <T : Any> runCommand(command: Bson, readPreference: ReadPreference = this.readPreference, resultClass: Class<T>): T

suspend fun <T : Any> runCommand(clientSession: ClientSession, command: Bson, readPreference: ReadPreference = this.readPreference, resultClass: Class<T>): T

Executes the given command in the context of the current database with the given read preference.

watch