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

MongoCollection

class MongoCollection<T : Any>(wrapped: MongoCollection<T>)

The MongoCollection representation.

Note: Additions to this interface will not be considered to break binary compatibility.

Parameters

The type that this collection will encode documents from and decode documents to.

Constructors

MongoCollection

constructor(wrapped: MongoCollection<T>)

Functions

aggregate

@JvmName(name = "aggregateAsT")

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

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

@JvmName(name = "aggregateAsTWithSession")

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

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

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

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

Aggregates documents according to the specified aggregation pipeline.

bulkWrite

suspend fun bulkWrite(requests: List<WriteModel<out T>>, options: BulkWriteOptions = BulkWriteOptions()): BulkWriteResult

suspend fun bulkWrite(clientSession: ClientSession, requests: List<WriteModel<out T>>, options: BulkWriteOptions = BulkWriteOptions()): BulkWriteResult

Executes a mix of inserts, updates, replaces, and deletes.

countDocuments

suspend fun countDocuments(filter: Bson = BsonDocument(), options: CountOptions = CountOptions()): Long

Counts the number of documents in the collection.

suspend fun countDocuments(clientSession: ClientSession, filter: Bson = BsonDocument(), options: CountOptions = CountOptions()): Long

Counts the number of documents in the collection according to the given options.

createIndex

suspend fun createIndex(keys: Bson, options: IndexOptions = IndexOptions()): String

suspend fun createIndex(clientSession: ClientSession, keys: Bson, options: IndexOptions = IndexOptions()): String

Create an index with the given keys and options.

createIndexes

fun createIndexes(indexes: List<IndexModel>, options: CreateIndexOptions = CreateIndexOptions()): Flow<String>

fun createIndexes(clientSession: ClientSession, indexes: List<IndexModel>, options: CreateIndexOptions = CreateIndexOptions()): Flow<String>

Create multiple indexes.

createSearchIndex

suspend fun createSearchIndex(definition: Bson): String

Create an Atlas Search index with default name for the collection.

suspend fun createSearchIndex(indexName: String, definition: Bson): String

Create an Atlas Search index for the collection.

createSearchIndexes

fun createSearchIndexes(searchIndexModels: List<SearchIndexModel>): Flow<String>

Create one or more Atlas Search indexes for the collection.

deleteMany

suspend fun deleteMany(filter: Bson, options: DeleteOptions = DeleteOptions()): DeleteResult

suspend fun deleteMany(clientSession: ClientSession, filter: Bson, options: DeleteOptions = DeleteOptions()): DeleteResult

Removes all documents from the collection that match the given query filter.

deleteOne

suspend fun deleteOne(filter: Bson, options: DeleteOptions = DeleteOptions()): DeleteResult

suspend fun deleteOne(clientSession: ClientSession, filter: Bson, options: DeleteOptions = DeleteOptions()): DeleteResult

Removes at most one document from the collection that matches the given filter.

distinct

inline fun <R : Any> distinct(fieldName: String, filter: Bson = BsonDocument()): DistinctFlow<R>

inline fun <R : Any> distinct(clientSession: ClientSession, fieldName: String, filter: Bson = BsonDocument()): DistinctFlow<R>

fun <R : Any> distinct(fieldName: String, filter: Bson = BsonDocument(), resultClass: Class<R>): DistinctFlow<R>

fun <R : Any> distinct(clientSession: ClientSession, fieldName: String, filter: Bson = BsonDocument(), resultClass: Class<R>): DistinctFlow<R>

Gets the distinct values of the specified field name.

drop

suspend fun drop(options: DropCollectionOptions = DropCollectionOptions())

suspend fun drop(clientSession: ClientSession, options: DropCollectionOptions = DropCollectionOptions())

Drops this collection from the Database.

dropIndex

suspend fun dropIndex(indexName: String, options: DropIndexOptions = DropIndexOptions())

suspend fun dropIndex(clientSession: ClientSession, indexName: String, options: DropIndexOptions = DropIndexOptions())

Drops the index given its name.

suspend fun dropIndex(keys: Bson, options: DropIndexOptions = DropIndexOptions())

suspend fun dropIndex(clientSession: ClientSession, keys: Bson, options: DropIndexOptions = DropIndexOptions())

Drops the index given the keys used to create it.

dropIndexes

suspend fun dropIndexes(options: DropIndexOptions = DropIndexOptions())

suspend fun dropIndexes(clientSession: ClientSession, options: DropIndexOptions = DropIndexOptions())

Drop all the indexes on this collection, except for the default on _id.

dropSearchIndex

suspend fun dropSearchIndex(indexName: String)

Drop an Atlas Search index given its name.

estimatedDocumentCount

suspend fun estimatedDocumentCount(options: EstimatedDocumentCountOptions = EstimatedDocumentCountOptions()): Long

Gets an estimate of the count of documents in a collection using collection metadata.

find

@JvmName(name = "findAsT")

fun find(filter: Bson = BsonDocument()): FindFlow<T>

inline fun <R : Any> find(filter: Bson = BsonDocument()): FindFlow<R>

@JvmName(name = "findAsTWithSession")

fun find(clientSession: ClientSession, filter: Bson = BsonDocument()): FindFlow<T>

inline fun <R : Any> find(clientSession: ClientSession, filter: Bson = BsonDocument()): FindFlow<R>

fun <R : Any> find(filter: Bson = BsonDocument(), resultClass: Class<R>): FindFlow<R>

fun <R : Any> find(clientSession: ClientSession, filter: Bson = BsonDocument(), resultClass: Class<R>): FindFlow<R>

Finds all documents in the collection.

findOneAndDelete

suspend fun findOneAndDelete(filter: Bson, options: FindOneAndDeleteOptions = FindOneAndDeleteOptions()): T?

suspend fun findOneAndDelete(clientSession: ClientSession, filter: Bson, options: FindOneAndDeleteOptions = FindOneAndDeleteOptions()): T?

Atomically find a document and remove it.

findOneAndReplace

suspend fun findOneAndReplace(filter: Bson, replacement: T, options: FindOneAndReplaceOptions = FindOneAndReplaceOptions()): T?

suspend fun findOneAndReplace(clientSession: ClientSession, filter: Bson, replacement: T, options: FindOneAndReplaceOptions = FindOneAndReplaceOptions()): T?

Atomically find a document and replace it.

findOneAndUpdate

suspend fun findOneAndUpdate(filter: Bson, update: List<Bson>, options: FindOneAndUpdateOptions = FindOneAndUpdateOptions()): T?

suspend fun findOneAndUpdate(filter: Bson, update: Bson, options: FindOneAndUpdateOptions = FindOneAndUpdateOptions()): T?

suspend fun findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: List<Bson>, options: FindOneAndUpdateOptions = FindOneAndUpdateOptions()): T?

suspend fun findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: Bson, options: FindOneAndUpdateOptions = FindOneAndUpdateOptions()): T?

Atomically find a document and update it.

insertMany

suspend fun insertMany(documents: List<T>, options: InsertManyOptions = InsertManyOptions()): InsertManyResult

suspend fun insertMany(clientSession: ClientSession, documents: List<T>, options: InsertManyOptions = InsertManyOptions()): InsertManyResult

Inserts one or more documents. A call to this method is equivalent to a call to the bulkWrite method

insertOne

suspend fun insertOne(document: T, options: InsertOneOptions = InsertOneOptions()): InsertOneResult

suspend fun insertOne(clientSession: ClientSession, document: T, options: InsertOneOptions = InsertOneOptions()): InsertOneResult

Inserts the provided document. If the document is missing an identifier, the driver should generate one.

listIndexes

@JvmName(name = "listIndexesAsDocument")

fun listIndexes(): ListIndexesFlow<Document>

inline fun <R : Any> listIndexes(): ListIndexesFlow<R>

@JvmName(name = "listIndexesAsDocumentWithSession")

fun listIndexes(clientSession: ClientSession): ListIndexesFlow<Document>

inline fun <R : Any> listIndexes(clientSession: ClientSession): ListIndexesFlow<R>

fun <R : Any> listIndexes(resultClass: Class<R>): ListIndexesFlow<R>

fun <R : Any> listIndexes(clientSession: ClientSession, resultClass: Class<R>): ListIndexesFlow<R>

Get all the indexes in this collection.

listSearchIndexes

@JvmName(name = "listSearchIndexesAsDocument")

fun listSearchIndexes(): ListSearchIndexesFlow<Document>

inline fun <R : Any> listSearchIndexes(): ListSearchIndexesFlow<R>

fun <R : Any> listSearchIndexes(resultClass: Class<R>): ListSearchIndexesFlow<R>

Get all the Atlas Search indexes in this collection.

mapReduce

@JvmName(name = "mapReduceAsT")

fun ~~mapReduce~~(mapFunction: String, reduceFunction: String): MapReduceFlow<T>

inline fun <R : Any> ~~mapReduce~~(mapFunction: String, reduceFunction: String): MapReduceFlow<R>

@JvmName(name = "mapReduceAsTWithSession")

fun ~~mapReduce~~(clientSession: ClientSession, mapFunction: String, reduceFunction: String): MapReduceFlow<T>

inline fun <R : Any> ~~mapReduce~~(clientSession: ClientSession, mapFunction: String, reduceFunction: String): MapReduceFlow<R>

fun <R : Any> ~~mapReduce~~(mapFunction: String, reduceFunction: String, resultClass: Class<R>): MapReduceFlow<R>

fun <R : Any> ~~mapReduce~~(clientSession: ClientSession, mapFunction: String, reduceFunction: String, resultClass: Class<R>): MapReduceFlow<R>

Aggregates documents according to the specified map-reduce function.

renameCollection

suspend fun renameCollection(newCollectionNamespace: MongoNamespace, options: RenameCollectionOptions = RenameCollectionOptions())

suspend fun renameCollection(clientSession: ClientSession, newCollectionNamespace: MongoNamespace, options: RenameCollectionOptions = RenameCollectionOptions())

Rename the collection with oldCollectionName to the newCollectionName.

replaceOne

suspend fun replaceOne(filter: Bson, replacement: T, options: ReplaceOptions = ReplaceOptions()): UpdateResult

suspend fun replaceOne(clientSession: ClientSession, filter: Bson, replacement: T, options: ReplaceOptions = ReplaceOptions()): UpdateResult

Replace a document in the collection according to the specified arguments.

updateMany

suspend fun updateMany(filter: Bson, update: List<Bson>, options: UpdateOptions = UpdateOptions()): UpdateResult

suspend fun updateMany(filter: Bson, update: Bson, options: UpdateOptions = UpdateOptions()): UpdateResult

suspend fun updateMany(clientSession: ClientSession, filter: Bson, update: List<Bson>, options: UpdateOptions = UpdateOptions()): UpdateResult

suspend fun updateMany(clientSession: ClientSession, filter: Bson, update: Bson, options: UpdateOptions = UpdateOptions()): UpdateResult

Update all documents in the collection according to the specified arguments.

updateOne

suspend fun updateOne(filter: Bson, update: List<Bson>, options: UpdateOptions = UpdateOptions()): UpdateResult

suspend fun updateOne(filter: Bson, update: Bson, options: UpdateOptions = UpdateOptions()): UpdateResult

suspend fun updateOne(clientSession: ClientSession, filter: Bson, update: List<Bson>, options: UpdateOptions = UpdateOptions()): UpdateResult

suspend fun updateOne(clientSession: ClientSession, filter: Bson, update: Bson, options: UpdateOptions = UpdateOptions()): UpdateResult

Update a single document in the collection according to the specified arguments.

updateSearchIndex

suspend fun updateSearchIndex(indexName: String, definition: Bson)

Update an Atlas Search index in the collection.

watch

@JvmName(name = "watchAsDocument")

fun watch(pipeline: List<Bson> = emptyList()): ChangeStreamFlow<T>

inline fun <R : Any> watch(pipeline: List<Bson> = emptyList()): ChangeStreamFlow<R>

@JvmName(name = "watchAsDocumentWithSession")

fun watch(clientSession: ClientSession, pipeline: List<Bson> = emptyList()): ChangeStreamFlow<T>

inline fun <R : Any> watch(clientSession: ClientSession, pipeline: List<Bson> = emptyList()): ChangeStreamFlow<R>

fun <R : Any> watch(pipeline: List<Bson> = emptyList(), resultClass: Class<R>): ChangeStreamFlow<R>

fun <R : Any> watch(clientSession: ClientSession, pipeline: List<Bson> = emptyList(), resultClass: Class<R>): ChangeStreamFlow<R>

Creates a change stream for this collection.

withCodecRegistry

fun withCodecRegistry(newCodecRegistry: CodecRegistry): MongoCollection<T>

Create a new collection instance with a different codec registry.

withDocumentClass

inline fun <R : Any> withDocumentClass(): MongoCollection<R>

fun <R : Any> withDocumentClass(resultClass: Class<R>): MongoCollection<R>

Create a new collection instance with a different default class to cast any documents returned from the database into.

withReadConcern

fun withReadConcern(newReadConcern: ReadConcern): MongoCollection<T>

Create a new collection instance with a different read concern.

withReadPreference

fun withReadPreference(newReadPreference: ReadPreference): MongoCollection<T>

Create a new collection instance with a different read preference.

withWriteConcern

fun withWriteConcern(newWriteConcern: WriteConcern): MongoCollection<T>

Create a new collection instance with a different write concern.

Properties

codecRegistry

val codecRegistry: CodecRegistry

The codec registry for the collection.

documentClass

val documentClass: Class<T>

The class of documents stored in this collection.

namespace

val namespace: MongoNamespace

The namespace of this collection.

readConcern

val readConcern: ReadConcern

The read concern for the collection.

readPreference

val readPreference: ReadPreference

the read preference for the collection.

writeConcern

val writeConcern: WriteConcern

The write concern for the collection.