com.mongodb.connection

Class InsertProtocol

java.lang.Object

com.mongodb.connection.WriteProtocol

com.mongodb.connection.InsertProtocol

All Implemented Interfaces:

Protocol<WriteConcernResult>

class InsertProtocol
extends WriteProtocol

An implementation of the insert wire protocol. This class also takes care of applying the write concern.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List<InsertRequest>	insertRequestList
private static Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
InsertProtocol(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<InsertRequest> insertRequestList) Construct a new instance.

Method Summary

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

Methods inherited from class com.mongodb.connection.WriteProtocol

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

insertRequestList

private final java.util.List<InsertRequest> insertRequestList

Constructor Detail

InsertProtocol

public InsertProtocol(MongoNamespace namespace,
                      boolean ordered,
                      WriteConcern writeConcern,
                      java.util.List<InsertRequest> insertRequestList)

Construct a new instance.

Parameters:

namespace - the namespace

ordered - whether the inserts are ordered

writeConcern - the write concern

insertRequestList - the list of documents to insert

Method Detail

execute

public WriteConcernResult execute(InternalConnection connection)

Description copied from interface: Protocol

Execute the protocol.

Specified by:

execute in interface Protocol<WriteConcernResult>

Overrides:

execute in class WriteProtocol

Parameters:

connection - the connection to execute the protocol on

Returns:

the response from execution of the protocol

executeAsync

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

Description copied from interface: Protocol

Execute the protocol asynchronously.

Specified by:

executeAsync in interface Protocol<WriteConcernResult>

Overrides:

executeAsync in class WriteProtocol

Parameters:

connection - the connection to execute the protocol on

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

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

appendToWriteCommandResponseDocument

protected void appendToWriteCommandResponseDocument(RequestMessage curMessage,
                                                    RequestMessage nextMessage,
                                                    WriteConcernResult writeConcernResult,
                                                    BsonDocument response)

Specified by:

appendToWriteCommandResponseDocument in class WriteProtocol

getLogger

protected Logger getLogger()

Description copied from class: WriteProtocol

Gets the logger.

Specified by:

getLogger in class WriteProtocol

Returns:

the logger