com.mongodb.operation

Class InsertOperation

java.lang.Object

com.mongodb.operation.BaseWriteOperation

com.mongodb.operation.InsertOperation

All Implemented Interfaces:

AsyncWriteOperation<WriteConcernResult>, WriteOperation<WriteConcernResult>

public class InsertOperation
extends BaseWriteOperation

An operation that inserts one or more documents into a collection.

Since:

3.0

Constructor Summary

Constructors

Constructor and Description
InsertOperation(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, List<InsertRequest> insertRequests) 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)
List<InsertRequest>	getInsertRequests() Gets the list of insert requests.
protected WriteRequest.Type	getType()

Methods inherited from class com.mongodb.operation.BaseWriteOperation

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

Methods inherited from class java.lang.Object

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

Constructor Detail

InsertOperation

public InsertOperation(MongoNamespace namespace,
                       boolean ordered,
                       WriteConcern writeConcern,
                       List<InsertRequest> insertRequests)

Construct an instance.

Parameters:

namespace - the database and collection namespace for the operation.

ordered - whether the inserts are ordered.

writeConcern - the write concern for the operation.

insertRequests - the list of inserts.

Method Detail

getInsertRequests

public List<InsertRequest> getInsertRequests()

Gets the list of insert requests.

Returns:

the list of insert 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