AsyncWriteOperation<WriteConcernResult>
, WriteOperation<WriteConcernResult>
DeleteOperation
, InsertOperation
, UpdateOperation
public abstract class BaseWriteOperation extends Object implements AsyncWriteOperation<WriteConcernResult>, WriteOperation<WriteConcernResult>
Constructor | Description |
---|---|
BaseWriteOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern) |
Deprecated.
|
BaseWriteOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
boolean retryWrites) |
Construct an instance
|
Modifier and Type | Method | Description |
---|---|---|
BaseWriteOperation |
bypassDocumentValidation(Boolean bypassDocumentValidation) |
Sets the bypass document level validation flag.
|
WriteConcernResult |
execute(WriteBinding binding) |
General execute which can return anything of type T
|
void |
executeAsync(AsyncWriteBinding binding,
SingleResultCallback<WriteConcernResult> callback) |
General execute which can return anything of type T
|
Boolean |
getBypassDocumentValidation() |
Gets the the bypass document level validation flag
|
MongoNamespace |
getNamespace() |
Gets the namespace of the collection to write to.
|
protected abstract WriteRequest.Type |
getType() |
|
WriteConcern |
getWriteConcern() |
Gets the write concern to apply
|
protected abstract List<? extends WriteRequest> |
getWriteRequests() |
|
boolean |
isOrdered() |
Gets whether the writes are ordered.
|
@Deprecated public BaseWriteOperation(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern)
BaseWriteOperation(MongoNamespace, boolean, WriteConcern, boolean)
insteadnamespace
- the database and collection namespace for the operation.ordered
- whether the writes are ordered.writeConcern
- the write concern for the operation.public BaseWriteOperation(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, boolean retryWrites)
namespace
- the database and collection namespace for the operation.ordered
- whether the writes are ordered.writeConcern
- the write concern for the operation.retryWrites
- if writes should be retried if they fail due to a network error.protected abstract List<? extends WriteRequest> getWriteRequests()
protected abstract WriteRequest.Type getType()
public MongoNamespace getNamespace()
public WriteConcern getWriteConcern()
public boolean isOrdered()
public Boolean getBypassDocumentValidation()
public BaseWriteOperation bypassDocumentValidation(Boolean bypassDocumentValidation)
bypassDocumentValidation
- If true, allows the write to opt-out of document level validation.public WriteConcernResult execute(WriteBinding binding)
WriteOperation
execute
in interface WriteOperation<WriteConcernResult>
binding
- the binding to execute in the context ofpublic void executeAsync(AsyncWriteBinding binding, SingleResultCallback<WriteConcernResult> callback)
AsyncWriteOperation
executeAsync
in interface AsyncWriteOperation<WriteConcernResult>
binding
- the binding to execute in the context ofcallback
- the callback to be called when the operation has been executed