0.20.1

MongoDB request DSL/opensavvy.ktmongo.dsl.command/BulkWrite

BulkWrite

class BulkWrite<Document : Any> : AbstractBsonNode, Command, CompoundNode<AvailableInBulkWrite<Document>> (source)

Performing multiple write operations in a single request.

Example

users.bulkWrite {
    updateOne({ User::name eq "foo" }) {
        User::age set 18
    }

    upsertOne({ User::name eq "bob" }) {
        User::age setOnInsert 18
        User::age inc 1
    }
}

Filtered writes

If we have multiple writes that share a similar filter, we can extract it to be common between them.

users.bulkWrite {
    updateOne({ User::name eq "foo" }) {
        User::age set 18
    }

    filtered({ User::isAlive eq true }) {
        updateMany({ User::name eq "bar" }) {
            User::age inc 2
        }

        updateOne({ User::name eq "baz" }) {
            User::age inc 1
        }
    }
}

To learn more, see filtered.

External resources

Official documentation

See also

BulkWriteOptions

Options

Constructors

constructor(context: <Error class: unknown class>, globalFilter: FilterQuery<Document>.() -> Unit)

Properties

abstract val context: <Error class: unknown class>

The context used to generate this expression.

val operations: <Error class: unknown class><AvailableInBulkWrite<Document>>

val options: BulkWriteOptions<Document>

Functions

open override fun accept(node: AvailableInBulkWrite<Document>)

Adds a new Node into the current node.

fun <N : Node> CompoundNode<N>.acceptAll(nodes: Iterable<N>)

Adds any number of nodes into this one.

fun filtered(filter: FilterQuery<Document>.() -> Unit, operations: BulkWrite<Document>.() -> Unit)

Declares a filter that is shared between all children operations.

abstract override fun freeze()

Makes this expression immutable.

fun insertMany(vararg documents: Document, options: InsertOneOptions<Document>.() -> Unit = {})

fun insertMany(documents: Iterable<Document>, options: InsertOneOptions<Document>.() -> Unit = {})

Inserts multiple documents in a single operation.

fun insertOne(document: Document, options: InsertOneOptions<Document>.() -> Unit = {})

Inserts a document.

abstract fun simplify(): BsonNode?

Returns a simplified (but equivalent) expression to the current expression.

open fun toBson(): <Error class: unknown class>

Writes the result of simplifying to a new Bson.

fun toString(simplified: Boolean): String

abstract override fun toString(): String

JSON representation of this expression.

fun updateMany(options: UpdateOptions<Document>.() -> Unit = {}, filter: FilterQuery<Document>.() -> Unit = {}, update: UpdateQuery<Document>.() -> Unit)

Updates all documents that match filter according to update.

fun updateOne(options: UpdateOptions<Document>.() -> Unit = {}, filter: FilterQuery<Document>.() -> Unit = {}, update: UpdateQuery<Document>.() -> Unit)

Updates a single document that matches filter according to update.

fun upsertOne(options: UpdateOptions<Document>.() -> Unit = {}, filter: FilterQuery<Document>.() -> Unit = {}, update: UpsertQuery<Document>.() -> Unit)

Updates a single document that matches filter according to update.

abstract fun writeTo(writer: <Error class: unknown class>)

Writes the result of simplifying this expression into writer.