KtMongo: MongoDB driver for Kotlin • Synchronous/opensavvy.ktmongo.sync/MongoCollection

MongoCollection

Methods to interact with a MongoDB collection.

Operations

External resources

Official documentation

Inheritors

JvmMongoCollection

Properties

context

@LowLevelApi

abstract val context: BsonContext

Functions

aggregate

abstract fun aggregate(): MongoAggregationPipeline<Document>

Start an aggregation pipeline.

bulkWrite

abstract fun bulkWrite(options: BulkWriteOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, operations: BulkWrite<Document>.() -> Unit)

Performs multiple update operations in a single request.

count

abstract fun count(): Long

Counts how many documents exist in the collection.

abstract fun count(options: CountOptions<Document>.() -> Unit, predicate: FilterQuery<Document>.() -> Unit): Long

Counts how many documents match predicate in the collection.

countEstimated

abstract fun countEstimated(): Long

Counts all documents in the collection.

deleteMany

abstract fun deleteMany(options: DeleteManyOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit)

Deletes all documents that match filter.

deleteOne

abstract fun deleteOne(options: DeleteOneOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit)

Deletes the first document found that matches filter.

drop

abstract fun drop(options: DropOptions<Document>.() -> Unit)

Removes an entire collection from the database.

exists

open fun exists(options: CountOptions<Document>.() -> Unit, predicate: FilterQuery<Document>.() -> Unit): Boolean

Tests if there exists a document that matches predicate in the collection.

filter

fun <Document : Any> MongoCollection<Document>.filter(filter: FilterQuery<Document>.() -> Unit): MongoCollection<Document>

Returns a filtered collection that only contains the elements that match filter.

find

abstract fun find(): MongoIterable<Document>

Finds all documents in this collection.

abstract fun find(options: FindOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit): MongoIterable<Document>

Finds all documents in this collection that satisfy filter.

findOne

open fun findOne(options: FindOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit): Document?

Finds a document in this collection that satisfies filter.

findOneAndUpdate

abstract fun findOneAndUpdate(options: UpdateOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, update: UpdateQuery<Document>.() -> Unit): Document?

Updates one element that matches filter according to update and returns it, atomically.

insertMany

open fun insertMany(vararg documents: Document, options: InsertManyOptions<Document>.() -> Unit)

abstract fun insertMany(documents: Iterable<Document>, options: InsertManyOptions<Document>.() -> Unit)

Inserts multiple documents in a single operation.

insertOne

abstract fun insertOne(document: Document, options: InsertOneOptions<Document>.() -> Unit)

Inserts a document.

newId

abstract fun newId(): ObjectId

replaceOne

abstract fun replaceOne(options: ReplaceOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, document: Document)

Replaces a document that matches filter by document.

repsertOne

abstract fun repsertOne(options: ReplaceOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, document: Document)

Replaces a document that matches filter by document.

updateMany

@IgnorableReturnValue

abstract fun updateMany(options: UpdateOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, update: UpdateQuery<Document>.() -> Unit): UpdateOperations.UpdateResult

Updates all documents that match filter according to update.

updateManyWithPipeline

@IgnorableReturnValue

abstract fun updateManyWithPipeline(options: UpdateOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, update: UpdateWithPipelineQuery<Document>.() -> Unit): UpdateOperations.UpdateResult

Updates all documents that match filter according to the update pipeline.

updateOne

@IgnorableReturnValue

abstract fun updateOne(options: UpdateOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, update: UpdateQuery<Document>.() -> Unit): UpdateOperations.UpdateResult

Updates a single document that matches filter according to update.

updateOneWithPipeline

@IgnorableReturnValue

abstract fun updateOneWithPipeline(options: UpdateOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, update: UpdateWithPipelineQuery<Document>.() -> Unit): UpdateOperations.UpdateResult

Updates a single document that matches filter according to the update pipeline.

upsertOne

@IgnorableReturnValue

abstract fun upsertOne(options: UpdateOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, update: UpsertQuery<Document>.() -> Unit): UpdateOperations.UpsertResult

Updates a single document that matches filter according to update.

upsertOneWithPipeline

@IgnorableReturnValue

abstract fun upsertOneWithPipeline(options: UpdateOptions<Document>.() -> Unit, filter: FilterQuery<Document>.() -> Unit, update: UpdateWithPipelineQuery<Document>.() -> Unit): UpdateOperations.UpsertResult

Updates a single document that matches filter according to the update pipeline.