com.mongodb.operation

Class DeleteOperation

java.lang.Object

com.mongodb.operation.BaseWriteOperation

com.mongodb.operation.DeleteOperation

All Implemented Interfaces:

AsyncWriteOperation<WriteConcernResult>, WriteOperation<WriteConcernResult>

public class DeleteOperation
extends BaseWriteOperation

An operation that deletes one or more documents from a collection.

Since:

3.0

Constructor Summary

Constructors

Constructor and Description
DeleteOperation(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, List<DeleteRequest> deleteRequests) 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<DeleteRequest>	getDeleteRequests() Gets the list of remove 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

DeleteOperation

public DeleteOperation(MongoNamespace namespace,
                       boolean ordered,
                       WriteConcern writeConcern,
                       List<DeleteRequest> deleteRequests)

Construct an instance.

Parameters:

namespace - the database and collection namespace for the operation.

ordered - whether the writes are ordered.

writeConcern - the write concern for the operation.

deleteRequests - the remove requests.

Method Detail

getDeleteRequests

public List<DeleteRequest> getDeleteRequests()

Gets the list of remove requests.

Returns:

the remove 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