com.mongodb.connection

Class UpdateCommandProtocol

java.lang.Object

com.mongodb.connection.WriteCommandProtocol

com.mongodb.connection.UpdateCommandProtocol

All Implemented Interfaces:

Protocol<BulkWriteResult>

class UpdateCommandProtocol
extends WriteCommandProtocol

An implementation of the update command.

Field Summary

Fields

Modifier and Type	Field and Description
private static Logger	LOGGER
private java.util.List<UpdateRequest>	updates

Constructor Summary

Constructors

Constructor and Description
UpdateCommandProtocol(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, java.util.List<UpdateRequest> updates) Construct an instance.

Method Summary

Modifier and Type	Method and Description
protected UpdateCommandMessage	createRequestMessage(MessageSettings messageSettings)
BulkWriteResult	execute(InternalConnection connection) Execute the protocol.
void	executeAsync(InternalConnection connection, SingleResultCallback<BulkWriteResult> callback) Execute the protocol asynchronously.
protected Logger	getLogger() Gets the logger.
protected WriteRequest.Type	getType()

Methods inherited from class com.mongodb.connection.WriteCommandProtocol

getBypassDocumentValidation, getNamespace, getWriteConcern, isOrdered, setCommandListener

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final Logger LOGGER

updates

private final java.util.List<UpdateRequest> updates

Constructor Detail

UpdateCommandProtocol

public UpdateCommandProtocol(MongoNamespace namespace,
                             boolean ordered,
                             WriteConcern writeConcern,
                             java.lang.Boolean bypassDocumentValidation,
                             java.util.List<UpdateRequest> updates)

Construct an instance.

Parameters:

namespace - the namespace

ordered - whether the inserts are ordered

writeConcern - the write concern

bypassDocumentValidation - the bypass documentation validation flag

updates - the list of updates

Method Detail

execute

public BulkWriteResult execute(InternalConnection connection)

Description copied from interface: Protocol

Execute the protocol.

Specified by:

execute in interface Protocol<BulkWriteResult>

Overrides:

execute in class WriteCommandProtocol

Parameters:

connection - the connection to execute the protocol on

Returns:

the response from execution of the protocol

executeAsync

public void executeAsync(InternalConnection connection,
                         SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: Protocol

Execute the protocol asynchronously.

Specified by:

executeAsync in interface Protocol<BulkWriteResult>

Overrides:

executeAsync in class WriteCommandProtocol

Parameters:

connection - the connection to execute the protocol on

callback - the callback that is passed the result of the execution

getType

protected WriteRequest.Type getType()

Specified by:

getType in class WriteCommandProtocol

createRequestMessage

protected UpdateCommandMessage createRequestMessage(MessageSettings messageSettings)

Specified by:

createRequestMessage in class WriteCommandProtocol

getLogger

protected Logger getLogger()

Description copied from class: WriteCommandProtocol

Gets the logger.

Specified by:

getLogger in class WriteCommandProtocol

Returns:

the logger