Package com.mongodb.operation

Class BaseFindAndModifyOperation<T>

java.lang.Object

com.mongodb.operation.BaseFindAndModifyOperation<T>

Type Parameters:

T - the document type

All Implemented Interfaces:

AsyncWriteOperation<T>, WriteOperation<T>

Direct Known Subclasses:

FindAndDeleteOperation, FindAndReplaceOperation, FindAndUpdateOperation

public abstract class BaseFindAndModifyOperation<T>
extends Object
implements AsyncWriteOperation<T>, WriteOperation<T>

Abstract base class for findAndModify-based operations

Since:

3.8

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseFindAndModifyOperation(MongoNamespace namespace, WriteConcern writeConcern, boolean retryWrites, Decoder<T> decoder)	Construct a new instance.

Method Summary

Modifier and Type	Method	Description
protected void	addTxnNumberToCommand(ServerDescription serverDescription, ConnectionDescription connectionDescription, BsonDocument commandDocument, SessionContext sessionContext)
protected void	addWriteConcernToCommand(ConnectionDescription connectionDescription, BsonDocument commandDocument, SessionContext sessionContext)
T	execute(WriteBinding binding)	General execute which can return anything of type T
void	executeAsync(AsyncWriteBinding binding, SingleResultCallback<T> callback)	General execute which can return anything of type T
protected abstract com.mongodb.operation.CommandOperationHelper.CommandCreator	getCommandCreator(SessionContext sessionContext)
protected abstract String	getDatabaseName()
Decoder<T>	getDecoder()	Gets the decoder used to decode the result documents.
protected abstract FieldNameValidator	getFieldNameValidator()
MongoNamespace	getNamespace()	Gets the namespace.
WriteConcern	getWriteConcern()	Get the write concern for this operation
boolean	isRetryWrites()	Returns true if the operation should be retried.

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseFindAndModifyOperation

protected BaseFindAndModifyOperation(MongoNamespace namespace,
                                     WriteConcern writeConcern,
                                     boolean retryWrites,
                                     Decoder<T> decoder)

Construct a new instance.

Parameters:

namespace - the database and collection namespace for the operation.

writeConcern - the writeConcern for the operation

retryWrites - if writes should be retried if they fail due to a network error.

decoder - the decoder for the result documents.

Method Detail

execute

public T execute(WriteBinding binding)

Description copied from interface: WriteOperation

General execute which can return anything of type T

Specified by:

execute in interface WriteOperation<T>

Parameters:

binding - the binding to execute in the context of

Returns:

T, the result of the execution

executeAsync

public void executeAsync(AsyncWriteBinding binding,
                         SingleResultCallback<T> callback)

Description copied from interface: AsyncWriteOperation

General execute which can return anything of type T

Specified by:

executeAsync in interface AsyncWriteOperation<T>

Parameters:

binding - the binding to execute in the context of

callback - the callback to be called when the operation has been executed

getDatabaseName

protected abstract String getDatabaseName()

getNamespace

public MongoNamespace getNamespace()

Gets the namespace.

Returns:

the namespace

getWriteConcern

public WriteConcern getWriteConcern()

Get the write concern for this operation

Returns:

the WriteConcern

Since:

3.2

Since server release

3.2

getDecoder

public Decoder<T> getDecoder()

Gets the decoder used to decode the result documents.

Returns:

the decoder

isRetryWrites

public boolean isRetryWrites()

Returns true if the operation should be retried.

Returns:

true if the operation should be retried

Since:

3.8

getCommandCreator

protected abstract com.mongodb.operation.CommandOperationHelper.CommandCreator getCommandCreator(SessionContext sessionContext)

addTxnNumberToCommand

protected void addTxnNumberToCommand(ServerDescription serverDescription,
                                     ConnectionDescription connectionDescription,
                                     BsonDocument commandDocument,
                                     SessionContext sessionContext)

addWriteConcernToCommand

protected void addWriteConcernToCommand(ConnectionDescription connectionDescription,
                                        BsonDocument commandDocument,
                                        SessionContext sessionContext)

getFieldNameValidator

protected abstract FieldNameValidator getFieldNameValidator()