Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.async.client.gridfs |
Contains the classes for supporting MongoDB's specification for storing very large files, GridFS.
|
com.mongodb.client |
This package contains classes for the new client api for MongoDatabase and MongoCollection
|
com.mongodb.client.gridfs |
This package contains the new GridFS implementation
|
com.mongodb.client.model |
This package contains models and options that help describe MongoCollection operations
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Class and Description |
---|---|
static class |
WriteConcern.Majority
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
static WriteConcern |
WriteConcern.ACKNOWLEDGED
Write operations that use this write concern will wait for acknowledgement, using the default write concern configured on the server.
|
static WriteConcern |
WriteConcern.FSYNC_SAFE
Deprecated.
Prefer
JOURNALED |
static WriteConcern |
WriteConcern.FSYNCED
Deprecated.
Prefer
JOURNALED |
static WriteConcern |
WriteConcern.JOURNAL_SAFE
Deprecated.
Prefer
JOURNALED |
static WriteConcern |
WriteConcern.JOURNALED
Write operations wait for the server to group commit to the journal file on disk.
|
static WriteConcern |
WriteConcern.MAJORITY
Exceptions are raised for network issues, and server errors; waits on a majority of servers for the write operation.
|
static WriteConcern |
WriteConcern.NORMAL
Deprecated.
Prefer
UNACKNOWLEDGED |
static WriteConcern |
WriteConcern.REPLICA_ACKNOWLEDGED
Deprecated.
Prefer WriteConcern#W2
|
static WriteConcern |
WriteConcern.REPLICAS_SAFE
Deprecated.
Prefer
W2 |
static WriteConcern |
WriteConcern.SAFE
Deprecated.
Prefer
ACKNOWLEDGED |
static WriteConcern |
WriteConcern.UNACKNOWLEDGED
Write operations that use this write concern will return as soon as the message is written to the socket.
|
static WriteConcern |
WriteConcern.W1
Write operations that use this write concern will wait for acknowledgement from a single member.
|
static WriteConcern |
WriteConcern.W2
Write operations that use this write concern will wait for acknowledgement from two members.
|
static WriteConcern |
WriteConcern.W3
Write operations that use this write concern will wait for acknowledgement from three members.
|
private WriteConcern |
MongoCollectionImpl.writeConcern |
private WriteConcern |
InsertOptions.writeConcern |
private WriteConcern |
MongoClientOptions.writeConcern |
private WriteConcern |
MongoClientOptions.Builder.writeConcern |
private WriteConcern |
Mongo.writeConcern |
private WriteConcern |
DBCollection.writeConcern |
private WriteConcern |
AggregateIterableImpl.writeConcern |
private WriteConcern |
DB.writeConcern |
WriteConcern |
MongoOptions.writeConcern
Deprecated.
Sets the write concern.
|
private WriteConcern |
MongoDatabaseImpl.writeConcern |
private WriteConcern |
MapReduceIterableImpl.writeConcern |
private WriteConcern |
ConnectionString.writeConcern |
Modifier and Type | Field and Description |
---|---|
private static java.util.Map<java.lang.String,WriteConcern> |
WriteConcern.NAMED_CONCERNS |
Modifier and Type | Method and Description |
---|---|
private WriteConcern |
ConnectionString.buildWriteConcern(java.lang.Boolean safe,
java.lang.String w,
java.lang.Integer wTimeout,
java.lang.Boolean fsync,
java.lang.Boolean journal) |
private WriteConcern |
ConnectionString.createWriteConcern(java.util.Map<java.lang.String,java.util.List<java.lang.String>> optionsMap) |
WriteConcern |
MongoCollectionImpl.getWriteConcern() |
WriteConcern |
InsertOptions.getWriteConcern()
The write concern to use for the insertion.
|
WriteConcern |
MongoClientOptions.getWriteConcern()
The write concern to use.
|
WriteConcern |
Mongo.getWriteConcern()
Gets the write concern
|
WriteConcern |
DBCollection.getWriteConcern()
Get the
WriteConcern for this collection. |
WriteConcern |
DB.getWriteConcern()
Gets the write concern for this database.
|
WriteConcern |
MongoOptions.getWriteConcern()
Deprecated.
Helper method to return the appropriate WriteConcern instance based on the current related options settings.
|
WriteConcern |
MongoDatabaseImpl.getWriteConcern() |
WriteConcern |
ConnectionString.getWriteConcern()
Gets the write concern specified in the connection string.
|
static WriteConcern |
WriteConcern.valueOf(java.lang.String name)
Gets the WriteConcern constants by name (matching is done case insensitively).
|
WriteConcern |
WriteConcern.withFsync(boolean fsync)
Deprecated.
Prefer
withJournal(Boolean) |
WriteConcern |
WriteConcern.withJ(boolean journal)
Deprecated.
Prefer
withJournal(Boolean) |
WriteConcern |
WriteConcern.withJournal(java.lang.Boolean journal)
Constructs a new WriteConcern from the current one and the specified journal value
|
WriteConcern |
WriteConcern.withW(int w)
Constructs a new WriteConcern from the current one and the specified integer-based value for w
|
WriteConcern |
WriteConcern.withW(java.lang.String w)
Constructs a new WriteConcern from the current one and the specified tag-set based value for w
|
WriteConcern |
WriteConcern.withWTimeout(long wTimeout,
java.util.concurrent.TimeUnit timeUnit)
Constructs a new WriteConcern from the current one and the specified wTimeout in the given time unit.
|
Modifier and Type | Method and Description |
---|---|
BulkWriteResult |
BulkWriteOperation.execute(WriteConcern writeConcern)
Execute the bulk write operation with the given write concern.
|
(package private) BulkWriteResult |
DBCollection.executeBulkWriteOperation(boolean ordered,
java.lang.Boolean bypassDocumentValidation,
java.util.List<WriteRequest> writeRequests,
WriteConcern writeConcern) |
DBObject |
DBCollection.findAndModify(DBObject query,
DBObject fields,
DBObject sort,
boolean remove,
DBObject update,
boolean returnNew,
boolean upsert,
boolean bypassDocumentValidation,
long maxTime,
java.util.concurrent.TimeUnit maxTimeUnit,
WriteConcern writeConcern)
Atomically modify and return a single document.
|
DBObject |
DBCollection.findAndModify(DBObject query,
DBObject fields,
DBObject sort,
boolean remove,
DBObject update,
boolean returnNew,
boolean upsert,
long maxTime,
java.util.concurrent.TimeUnit maxTimeUnit,
WriteConcern writeConcern)
Atomically modify and return a single document.
|
DBObject |
DBCollection.findAndModify(DBObject query,
DBObject fields,
DBObject sort,
boolean remove,
DBObject update,
boolean returnNew,
boolean upsert,
WriteConcern writeConcern)
Atomically modify and return a single document.
|
WriteResult |
DBCollection.insert(DBObject[] documents,
WriteConcern writeConcern)
Insert documents into a collection.
|
WriteResult |
DBCollection.insert(DBObject[] documents,
WriteConcern aWriteConcern,
DBEncoder encoder)
Insert documents into a collection.
|
WriteResult |
DBCollection.insert(DBObject document,
WriteConcern writeConcern)
Insert a document into a collection.
|
WriteResult |
DBCollection.insert(java.util.List<? extends DBObject> documents,
WriteConcern aWriteConcern)
Insert documents into a collection.
|
WriteResult |
DBCollection.insert(java.util.List<? extends DBObject> documents,
WriteConcern aWriteConcern,
DBEncoder dbEncoder)
Insert documents into a collection.
|
private WriteResult |
DBCollection.insert(java.util.List<InsertRequest> insertRequestList,
WriteConcern writeConcern,
boolean continueOnError,
java.lang.Boolean bypassDocumentValidation) |
WriteResult |
DBCollection.insert(WriteConcern writeConcern,
DBObject... documents)
Insert documents into a collection.
|
WriteResult |
DBCollection.remove(DBObject query,
WriteConcern writeConcern)
Remove documents from a collection.
|
WriteResult |
DBCollection.remove(DBObject query,
WriteConcern writeConcern,
DBEncoder encoder)
Remove documents from a collection.
|
private WriteResult |
DBCollection.replaceOrInsert(DBObject obj,
java.lang.Object id,
WriteConcern writeConcern) |
WriteResult |
DBCollection.save(DBObject document,
WriteConcern writeConcern)
Update an existing document or insert a document depending on the parameter.
|
void |
Mongo.setWriteConcern(WriteConcern writeConcern)
Deprecated.
Set the default write concern with either
MongoClientURI or MongoClientOptions |
void |
DBCollection.setWriteConcern(WriteConcern writeConcern)
Set the
WriteConcern for this collection. |
void |
DB.setWriteConcern(WriteConcern writeConcern)
Sets the write concern for this database.
|
void |
MongoOptions.setWriteConcern(WriteConcern writeConcern)
Deprecated.
Sets the write concern.
|
WriteResult |
DBCollection.update(DBObject query,
DBObject update,
boolean upsert,
boolean multi,
WriteConcern aWriteConcern)
Modify an existing document or documents in collection.
|
WriteResult |
DBCollection.update(DBObject query,
DBObject update,
boolean upsert,
boolean multi,
WriteConcern concern,
java.lang.Boolean bypassDocumentValidation,
DBEncoder encoder)
Modify an existing document or documents in collection.
|
WriteResult |
DBCollection.update(DBObject query,
DBObject update,
boolean upsert,
boolean multi,
WriteConcern concern,
DBEncoder encoder)
Modify an existing document or documents in collection.
|
MongoCollection<TDocument> |
MongoCollectionImpl.withWriteConcern(WriteConcern writeConcern) |
MongoDatabase |
MongoDatabaseImpl.withWriteConcern(WriteConcern writeConcern) |
InsertOptions |
InsertOptions.writeConcern(WriteConcern writeConcern)
Set the write concern to use for the insert.
|
MongoClientOptions.Builder |
MongoClientOptions.Builder.writeConcern(WriteConcern writeConcern)
Sets the write concern.
|
Constructor and Description |
---|
AggregateIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
OperationExecutor executor,
java.util.List<? extends Bson> pipeline) |
MapReduceIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
OperationExecutor executor,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
MongoCollectionImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
OperationExecutor executor) |
MongoDatabaseImpl(java.lang.String name,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
OperationExecutor executor) |
Modifier and Type | Field and Description |
---|---|
private WriteConcern |
MongoCollectionImpl.writeConcern |
private WriteConcern |
AggregateIterableImpl.writeConcern |
private WriteConcern |
MongoClientSettings.writeConcern |
private WriteConcern |
MongoClientSettings.Builder.writeConcern |
private WriteConcern |
MongoDatabaseImpl.writeConcern |
private WriteConcern |
MapReduceIterableImpl.writeConcern |
Modifier and Type | Method and Description |
---|---|
WriteConcern |
MongoCollectionImpl.getWriteConcern() |
WriteConcern |
MongoDatabase.getWriteConcern()
Get the write concern for the MongoDatabase.
|
WriteConcern |
MongoCollection.getWriteConcern()
Get the write concern for the MongoCollection.
|
WriteConcern |
MongoClientSettings.getWriteConcern()
The write concern to use.
|
WriteConcern |
MongoDatabaseImpl.getWriteConcern() |
Modifier and Type | Method and Description |
---|---|
MongoCollection<TDocument> |
MongoCollectionImpl.withWriteConcern(WriteConcern writeConcern) |
MongoDatabase |
MongoDatabase.withWriteConcern(WriteConcern writeConcern)
Create a new MongoDatabase instance with a different write concern.
|
MongoCollection<TDocument> |
MongoCollection.withWriteConcern(WriteConcern writeConcern)
Create a new MongoCollection instance with a different write concern.
|
MongoDatabase |
MongoDatabaseImpl.withWriteConcern(WriteConcern writeConcern) |
MongoClientSettings.Builder |
MongoClientSettings.Builder.writeConcern(WriteConcern writeConcern)
Sets the write concern.
|
Constructor and Description |
---|
AggregateIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
AsyncOperationExecutor executor,
java.util.List<? extends Bson> pipeline) |
MapReduceIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
AsyncOperationExecutor executor,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
MongoCollectionImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
AsyncOperationExecutor executor) |
MongoDatabaseImpl(java.lang.String name,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
AsyncOperationExecutor executor) |
Modifier and Type | Method and Description |
---|---|
WriteConcern |
GridFSBucketImpl.getWriteConcern() |
WriteConcern |
GridFSBucket.getWriteConcern()
Get the write concern for the GridFSBucket.
|
Modifier and Type | Method and Description |
---|---|
GridFSBucket |
GridFSBucketImpl.withWriteConcern(WriteConcern writeConcern) |
GridFSBucket |
GridFSBucket.withWriteConcern(WriteConcern writeConcern)
Create a new GridFSBucket instance with a different write concern.
|
Modifier and Type | Method and Description |
---|---|
WriteConcern |
MongoDatabase.getWriteConcern()
Get the write concern for the MongoDatabase.
|
WriteConcern |
MongoCollection.getWriteConcern()
Get the write concern for the MongoCollection.
|
Modifier and Type | Method and Description |
---|---|
MongoDatabase |
MongoDatabase.withWriteConcern(WriteConcern writeConcern)
Create a new MongoDatabase instance with a different write concern.
|
MongoCollection<TDocument> |
MongoCollection.withWriteConcern(WriteConcern writeConcern)
Create a new MongoCollection instance with a different write concern.
|
Modifier and Type | Method and Description |
---|---|
WriteConcern |
GridFSBucketImpl.getWriteConcern() |
WriteConcern |
GridFSBucket.getWriteConcern()
Get the write concern for the GridFSBucket.
|
Modifier and Type | Method and Description |
---|---|
GridFSBucket |
GridFSBucketImpl.withWriteConcern(WriteConcern writeConcern) |
GridFSBucket |
GridFSBucket.withWriteConcern(WriteConcern writeConcern)
Create a new GridFSBucket instance with a different write concern.
|
Modifier and Type | Field and Description |
---|---|
private WriteConcern |
DBCollectionRemoveOptions.writeConcern |
private WriteConcern |
DBCollectionFindAndModifyOptions.writeConcern |
private WriteConcern |
DBCollectionUpdateOptions.writeConcern |
Modifier and Type | Method and Description |
---|---|
WriteConcern |
DBCollectionRemoveOptions.getWriteConcern()
The write concern to use for the insertion.
|
WriteConcern |
DBCollectionFindAndModifyOptions.getWriteConcern()
Returns the writeConcern
|
WriteConcern |
DBCollectionUpdateOptions.getWriteConcern()
The write concern to use for the insertion.
|
Modifier and Type | Method and Description |
---|---|
DBCollectionRemoveOptions |
DBCollectionRemoveOptions.writeConcern(WriteConcern writeConcern)
Sets the write concern
|
DBCollectionFindAndModifyOptions |
DBCollectionFindAndModifyOptions.writeConcern(WriteConcern writeConcern)
Sets the writeConcern
|
DBCollectionUpdateOptions |
DBCollectionUpdateOptions.writeConcern(WriteConcern writeConcern)
Sets the write concern
|
Modifier and Type | Field and Description |
---|---|
private WriteConcern |
InsertMessage.writeConcern |
private WriteConcern |
BulkWriteBatchCombiner.writeConcern |
private WriteConcern |
BaseWriteCommandMessage.writeConcern |
private WriteConcern |
WriteCommandProtocol.writeConcern |
private WriteConcern |
WriteProtocol.writeConcern |
Modifier and Type | Method and Description |
---|---|
WriteConcern |
BaseWriteCommandMessage.getWriteConcern()
Gets the write concern.
|
WriteConcern |
WriteCommandProtocol.getWriteConcern()
Gets the write concern.
|
protected WriteConcern |
WriteProtocol.getWriteConcern()
Gets the write concern.
|
Modifier and Type | Method and Description |
---|---|
WriteConcernResult |
Connection.delete(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Delete the documents using the delete wire protocol and apply the write concern.
|
WriteConcernResult |
DefaultServerConnection.delete(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes) |
void |
AsyncConnection.deleteAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<WriteConcernResult> callback)
Delete the documents using the delete wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.deleteAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<WriteConcernResult> callback) |
BulkWriteResult |
Connection.deleteCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Delete the documents using the delete command.
|
BulkWriteResult |
DefaultServerConnection.deleteCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes) |
void |
AsyncConnection.deleteCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<BulkWriteResult> callback)
Delete the documents using the delete command asynchronously.
|
void |
DefaultServerConnection.deleteCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<BulkWriteResult> callback) |
WriteConcernResult |
Connection.insert(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts)
Insert the documents using the insert wire protocol and apply the write concern.
|
WriteConcernResult |
DefaultServerConnection.insert(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts) |
void |
AsyncConnection.insertAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<WriteConcernResult> callback)
Insert the documents using the insert wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.insertAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<WriteConcernResult> callback) |
BulkWriteResult |
Connection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts)
Insert the documents using the insert command.
|
BulkWriteResult |
DefaultServerConnection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts) |
BulkWriteResult |
Connection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts)
Deprecated.
|
BulkWriteResult |
DefaultServerConnection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts) |
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
Insert the documents using the insert command asynchronously.
|
void |
DefaultServerConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback) |
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
|
void |
DefaultServerConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback) |
WriteConcernResult |
Connection.update(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Update the documents using the update wire protocol and apply the write concern.
|
WriteConcernResult |
DefaultServerConnection.update(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates) |
void |
AsyncConnection.updateAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<WriteConcernResult> callback)
Update the documents using the update wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.updateAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<WriteConcernResult> callback) |
BulkWriteResult |
Connection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates)
Update the documents using the update command.
|
BulkWriteResult |
DefaultServerConnection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates) |
BulkWriteResult |
Connection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Deprecated.
|
BulkWriteResult |
DefaultServerConnection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates) |
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
Update the documents using the update command asynchronously.
|
void |
DefaultServerConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback) |
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
|
void |
DefaultServerConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback) |
Constructor and Description |
---|
BaseWriteCommandMessage(MongoNamespace writeNamespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
MessageSettings settings)
Construct an instance.
|
BulkWriteBatchCombiner(ServerAddress serverAddress,
boolean ordered,
WriteConcern writeConcern)
Construct an instance.
|
DeleteCommandMessage(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
MessageSettings settings,
java.util.List<DeleteRequest> deletes)
Construct an instance.
|
DeleteCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Construct an instance.
|
DeleteProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Construct an instance.
|
InsertCommandMessage(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
MessageSettings settings,
java.util.List<InsertRequest> insertRequestList)
Construct a new instance.
|
InsertCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> insertRequests)
Construct an instance.
|
InsertMessage(java.lang.String collectionName,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> insertRequestList,
MessageSettings settings)
Construct an instance.
|
InsertProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> insertRequestList)
Construct a new instance.
|
UpdateCommandMessage(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
MessageSettings settings,
java.util.List<UpdateRequest> updates)
Construct an instance.
|
UpdateCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates)
Construct an instance.
|
UpdateProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Construct an instance.
|
WriteCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation)
Construct an instance.
|
WriteProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern)
Construct a new instance.
|
Modifier and Type | Field and Description |
---|---|
private WriteConcern |
BaseWriteOperation.writeConcern |
private WriteConcern |
FindAndDeleteOperation.writeConcern |
private WriteConcern |
RenameCollectionOperation.writeConcern |
private WriteConcern |
MapReduceToCollectionOperation.writeConcern |
private WriteConcern |
CreateViewOperation.writeConcern |
private WriteConcern |
FindAndReplaceOperation.writeConcern |
private WriteConcern |
CreateIndexesOperation.writeConcern |
private WriteConcern |
DropCollectionOperation.writeConcern |
private WriteConcern |
DropIndexOperation.writeConcern |
private WriteConcern |
DropDatabaseOperation.writeConcern |
private WriteConcern |
UpdateUserOperation.writeConcern |
private WriteConcern |
DropUserOperation.writeConcern |
private WriteConcern |
FindAndUpdateOperation.writeConcern |
private WriteConcern |
CreateCollectionOperation.writeConcern |
private WriteConcern |
MixedBulkWriteOperation.writeConcern |
private WriteConcern |
CreateUserOperation.writeConcern |
private WriteConcern |
AggregateToCollectionOperation.writeConcern |
Modifier and Type | Method and Description |
---|---|
WriteConcern |
BaseWriteOperation.getWriteConcern()
Gets the write concern to apply
|
WriteConcern |
FindAndDeleteOperation.getWriteConcern()
Get the write concern for this operation
|
WriteConcern |
RenameCollectionOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
MapReduceToCollectionOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
CreateViewOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
FindAndReplaceOperation.getWriteConcern()
Get the write concern for this operation
|
WriteConcern |
CreateIndexesOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
DropCollectionOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
DropIndexOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
DropDatabaseOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
FindAndUpdateOperation.getWriteConcern()
Get the write concern for this operation
|
WriteConcern |
CreateCollectionOperation.getWriteConcern()
Gets the write concern.
|
WriteConcern |
MixedBulkWriteOperation.getWriteConcern()
Gets the write concern to apply
|
WriteConcern |
AggregateToCollectionOperation.getWriteConcern()
Gets the write concern.
|
Modifier and Type | Method and Description |
---|---|
(package private) static void |
WriteConcernHelper.appendWriteConcernToCommand(WriteConcern writeConcern,
BsonDocument commandDocument,
ConnectionDescription description) |
(package private) static void |
OperationHelper.checkBypassDocumentValidationIsSupported(AsyncConnection connection,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.checkBypassDocumentValidationIsSupported(Connection connection,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern) |
(package private) static void |
OperationHelper.validateCollationAndWriteConcern(AsyncConnection connection,
Collation collation,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateCollationAndWriteConcern(Connection connection,
Collation collation,
WriteConcern writeConcern) |
(package private) static void |
OperationHelper.validateWriteRequestCollations(AsyncConnection connection,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateWriteRequestCollations(Connection connection,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern) |
(package private) static void |
OperationHelper.validateWriteRequests(AsyncConnection connection,
java.lang.Boolean bypassDocumentValidation,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateWriteRequests(Connection connection,
java.lang.Boolean bypassDocumentValidation,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern) |
Constructor and Description |
---|
AggregateToCollectionOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline,
WriteConcern writeConcern)
Construct a new instance.
|
BaseWriteOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern)
Construct an instance
|
CreateCollectionOperation(java.lang.String databaseName,
java.lang.String collectionName,
WriteConcern writeConcern)
Construct a new instance.
|
CreateIndexesOperation(MongoNamespace namespace,
java.util.List<IndexRequest> requests,
WriteConcern writeConcern)
Construct a new instance.
|
CreateUserOperation(MongoCredential credential,
boolean readOnly,
WriteConcern writeConcern)
Construct a new instance.
|
CreateViewOperation(java.lang.String databaseName,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<BsonDocument> pipeline,
WriteConcern writeConcern)
Construct a new instance.
|
DeleteOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deleteRequests)
Construct an instance.
|
DropCollectionOperation(MongoNamespace namespace,
WriteConcern writeConcern)
Construct a new instance.
|
DropDatabaseOperation(java.lang.String databaseName,
WriteConcern writeConcern)
Construct a new instance.
|
DropIndexOperation(MongoNamespace namespace,
BsonDocument keys,
WriteConcern writeConcern)
Construct a new instance.
|
DropIndexOperation(MongoNamespace namespace,
java.lang.String indexName,
WriteConcern writeConcern)
Construct a new instance.
|
DropUserOperation(java.lang.String databaseName,
java.lang.String userName,
WriteConcern writeConcern)
Construct a new instance.
|
FindAndDeleteOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder)
Construct a new instance.
|
FindAndReplaceOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument replacement)
Construct a new instance.
|
FindAndUpdateOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument update)
Construct a new instance.
|
InsertOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> insertRequests)
Construct an instance.
|
MapReduceToCollectionOperation(MongoNamespace namespace,
BsonJavaScript mapFunction,
BsonJavaScript reduceFunction,
java.lang.String collectionName,
WriteConcern writeConcern)
Construct a MapReduceOperation with all the criteria it needs to execute
|
MixedBulkWriteOperation(MongoNamespace namespace,
java.util.List<? extends WriteRequest> writeRequests,
boolean ordered,
WriteConcern writeConcern)
Construct a new instance.
|
RenameCollectionOperation(MongoNamespace originalNamespace,
MongoNamespace newNamespace,
WriteConcern writeConcern) |
UpdateOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Construct an instance.
|
UpdateUserOperation(MongoCredential credential,
boolean readOnly,
WriteConcern writeConcern)
Construct a new instance.
|