com.mongodb.connection

Class UpdateProtocol

java.lang.Object

com.mongodb.connection.WriteProtocol

com.mongodb.connection.UpdateProtocol

All Implemented Interfaces:

LegacyProtocol<WriteConcernResult>

class UpdateProtocol
extends WriteProtocol

An implementation of the MongoDB OP_UPDATE wire protocol.

Field Summary

Fields

Modifier and Type	Field and Description
private static Logger	LOGGER
private UpdateRequest	updateRequest

Constructor Summary

Constructors

Constructor and Description
UpdateProtocol(MongoNamespace namespace, boolean ordered, UpdateRequest updateRequest)

Method Summary

Modifier and Type	Method and Description
protected RequestMessage	createRequestMessage(MessageSettings settings) Create the initial request message for the write.
WriteConcernResult	execute(InternalConnection connection)
void	executeAsync(InternalConnection connection, SingleResultCallback<WriteConcernResult> callback)
protected BsonDocument	getAsWriteCommand(ByteBufferBsonOutput bsonOutput, int firstDocumentPosition)
protected Logger	getLogger() Gets the logger.

Methods inherited from class com.mongodb.connection.WriteProtocol

getBaseCommandDocument, getCommandName, getNamespace, 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

updateRequest

private final UpdateRequest updateRequest

Constructor Detail

UpdateProtocol

UpdateProtocol(MongoNamespace namespace,
               boolean ordered,
               UpdateRequest updateRequest)

Method Detail

execute

public WriteConcernResult execute(InternalConnection connection)

Specified by:

execute in interface LegacyProtocol<WriteConcernResult>

Overrides:

execute in class WriteProtocol

executeAsync

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

Specified by:

executeAsync in interface LegacyProtocol<WriteConcernResult>

Overrides:

executeAsync in class WriteProtocol

getAsWriteCommand

protected BsonDocument getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
                                         int firstDocumentPosition)

Specified by:

getAsWriteCommand in class WriteProtocol

createRequestMessage

protected RequestMessage createRequestMessage(MessageSettings settings)

Description copied from class: WriteProtocol

Create the initial request message for the write.

Specified by:

createRequestMessage in class WriteProtocol

Parameters:

settings - the message settings

Returns:

the request message

getLogger

protected Logger getLogger()

Description copied from class: WriteProtocol

Gets the logger.

Specified by:

getLogger in class WriteProtocol

Returns:

the logger