com.mongodb.operation

Class UpdateOperation

java.lang.Object

com.mongodb.operation.BaseWriteOperation

com.mongodb.operation.UpdateOperation

All Implemented Interfaces:

AsyncWriteOperation<WriteConcernResult>, WriteOperation<WriteConcernResult>

public class UpdateOperation
extends BaseWriteOperation

An operation that updates a document in a collection.

Since:

3.0

Constructor Summary

Constructors

Constructor and Description
UpdateOperation(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, List<UpdateRequest> updates) Construct an instance.

Method Summary

Modifier and Type	Method and Description
protected BulkWriteResult	executeCommandProtocol(Connection connection) Executes the write command protocol.
protected void	executeCommandProtocolAsync(AsyncConnection connection, SingleResultCallback<BulkWriteResult> callback) Asynchronously executes the write command protocol.
protected WriteConcernResult	executeProtocol(Connection connection) Executes the write protocol
protected void	executeProtocolAsync(AsyncConnection connection, SingleResultCallback<WriteConcernResult> callback) Asynchronously executes the write protocol
protected int	getCount(BulkWriteResult bulkWriteResult)
protected WriteRequest.Type	getType()
protected boolean	getUpdatedExisting(BulkWriteResult bulkWriteResult)
List<UpdateRequest>	getUpdateRequests() Gets the list of update requests.

Methods inherited from class com.mongodb.operation.BaseWriteOperation

bypassDocumentValidation, execute, executeAsync, getBypassDocumentValidation, getNamespace, getWriteConcern, isOrdered

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UpdateOperation

public UpdateOperation(MongoNamespace namespace,
                       boolean ordered,
                       WriteConcern writeConcern,
                       List<UpdateRequest> updates)

Construct an instance.

Parameters:

namespace - the database and collection namespace for the operation.

ordered - whether the updates are ordered.

writeConcern - the write concern for the operation.

updates - the update requests.

Method Detail

getUpdateRequests

public List<UpdateRequest> getUpdateRequests()

Gets the list of update requests.

Returns:

the update requests

executeProtocol

protected WriteConcernResult executeProtocol(Connection connection)

Description copied from class: BaseWriteOperation

Executes the write protocol

Specified by:

executeProtocol in class BaseWriteOperation

Parameters:

connection - the connection

Returns:

the write protocol

executeProtocolAsync

protected void executeProtocolAsync(AsyncConnection connection,
                                    SingleResultCallback<WriteConcernResult> callback)

Description copied from class: BaseWriteOperation

Asynchronously executes the write protocol

Specified by:

executeProtocolAsync in class BaseWriteOperation

Parameters:

connection - the connection

callback - the callback to be passed the WriteConcernResult

executeCommandProtocol

protected BulkWriteResult executeCommandProtocol(Connection connection)

Description copied from class: BaseWriteOperation

Executes the write command protocol.

Specified by:

executeCommandProtocol in class BaseWriteOperation

Parameters:

connection - the connection

Returns:

the result

executeCommandProtocolAsync

protected void executeCommandProtocolAsync(AsyncConnection connection,
                                           SingleResultCallback<BulkWriteResult> callback)

Description copied from class: BaseWriteOperation

Asynchronously executes the write command protocol.

Specified by:

executeCommandProtocolAsync in class BaseWriteOperation

Parameters:

connection - the connection

callback - the callback to be passed the BulkWriteResult

getType

protected WriteRequest.Type getType()

Specified by:

getType in class BaseWriteOperation

getCount

protected int getCount(BulkWriteResult bulkWriteResult)

Specified by:

getCount in class BaseWriteOperation

getUpdatedExisting

protected boolean getUpdatedExisting(BulkWriteResult bulkWriteResult)

Overrides:

getUpdatedExisting in class BaseWriteOperation