| Package | Description |
|---|---|
| com.mongodb |
Main package with core files.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
WriteConcern.Majority
A write concern that blocks acknowledgement of a write operation until a majority of replica set members have applied it.
|
| Modifier and Type | Field and Description |
|---|---|
private WriteConcern |
Mongo._concern |
private WriteConcern |
DBCollection._concern |
private WriteConcern |
DB._concern |
private WriteConcern |
WriteResult._lastConcern |
static WriteConcern |
WriteConcern.ACKNOWLEDGED
Write operations that use this write concern will wait for acknowledgement from the primary server before returning.
|
static WriteConcern |
WriteConcern.ERRORS_IGNORED
Deprecated.
There is no replacement for this write concern. The closest would be to use WriteConcern#UNACKNOWLEDGED,
then catch and ignore any exceptions of type MongoSocketException.
|
static WriteConcern |
WriteConcern.FSYNC_SAFE
Exceptions are raised for network issues, and server errors; the write operation waits for the server to flush the data to
disk.
|
static WriteConcern |
WriteConcern.FSYNCED
Exceptions are raised for network issues, and server errors; the write operation waits for the server to flush
the data to disk.
|
static WriteConcern |
WriteConcern.JOURNAL_SAFE
Exceptions are raised for network issues, and server errors; the write operation waits for the server to group commit to the
journal file on disk.
|
static WriteConcern |
WriteConcern.JOURNALED
Exceptions are raised for network issues, and server errors; the write operation waits 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.NONE
Deprecated.
|
static WriteConcern |
WriteConcern.NORMAL
Write operations that use this write concern will return as soon as the message is written to the socket.
|
static WriteConcern |
WriteConcern.REPLICA_ACKNOWLEDGED
Exceptions are raised for network issues, and server errors; waits for at least 2 servers for the write operation.
|
static WriteConcern |
WriteConcern.REPLICAS_SAFE
Exceptions are raised for network issues, and server errors; waits for at least 2 servers for the write operation.
|
static WriteConcern |
WriteConcern.SAFE
Write operations that use this write concern will wait for acknowledgement from the primary server before returning.
|
static WriteConcern |
WriteConcern.UNACKNOWLEDGED
Write operations that use this write concern will return as soon as the message is written to the socket.
|
private WriteConcern |
BulkWriteBatchCombiner.writeConcern |
private WriteConcern |
BaseWriteCommandMessage.writeConcern |
private WriteConcern |
InsertOptions.writeConcern |
private WriteConcern |
DBCollectionImpl.OrderedRunGenerator.writeConcern |
private WriteConcern |
DBCollectionImpl.UnorderedRunGenerator.writeConcern |
private WriteConcern |
DBCollectionImpl.Run.writeConcern |
WriteConcern |
MongoOptions.writeConcern
Deprecated.
Sets the write concern.
|
private WriteConcern |
MongoClientOptions.writeConcern |
private WriteConcern |
MongoClientOptions.Builder.writeConcern |
| Modifier and Type | Field and Description |
|---|---|
private static java.util.Map<java.lang.String,WriteConcern> |
WriteConcern._namedConcerns |
| Modifier and Type | Method and Description |
|---|---|
private WriteConcern |
MongoClientURI.buildWriteConcern(java.lang.Boolean safe,
java.lang.String w,
int wTimeout,
boolean fsync,
boolean journal) |
WriteConcern |
WriteConcern.continueOnError(boolean continueOnError)
Deprecated.
the preferred way to specify this is to use write methods that explicitly specify the value of this property
|
WriteConcern |
WriteConcern.continueOnErrorForInsert(boolean continueOnErrorForInsert)
Deprecated.
the preferred way to specify this is to use write methods that explicitly specify the value of this property
|
private WriteConcern |
MongoClientURI.createWriteConcern(java.util.Map<java.lang.String,java.util.List<java.lang.String>> optionsMap) |
WriteConcern |
WriteResult.getLastConcern()
Deprecated.
there is no replacement for this method
|
WriteConcern |
Mongo.getWriteConcern()
Gets the default write concern
|
WriteConcern |
BaseWriteCommandMessage.getWriteConcern() |
WriteConcern |
InsertOptions.getWriteConcern()
The write concern to use for the insertion.
|
WriteConcern |
DBCollection.getWriteConcern()
Get the
WriteConcern for this collection. |
WriteConcern |
MongoOptions.getWriteConcern()
Deprecated.
Helper method to return the appropriate WriteConcern instance based on the current related options settings.
|
WriteConcern |
DB.getWriteConcern()
Gets the write concern for this database.
|
WriteConcern |
MongoClientOptions.getWriteConcern()
The write concern to use.
|
static WriteConcern |
WriteConcern.valueOf(java.lang.String name)
Gets the WriteConcern constants by name (matching is done case insensitively).
|
| Modifier and Type | Method and Description |
|---|---|
private WriteResult |
DBTCPConnector._checkWriteError(DB db,
DBPort port,
WriteConcern concern)
Deprecated.
|
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> requests,
WriteConcern writeConcern) |
(package private) abstract BulkWriteResult |
DBCollection.executeBulkWriteOperation(boolean ordered,
java.lang.Boolean bypassDocumentValidation,
java.util.List<WriteRequest> requests,
WriteConcern writeConcern,
DBEncoder encoder) |
(package private) BulkWriteResult |
DBCollectionImpl.executeBulkWriteOperation(boolean ordered,
java.lang.Boolean bypassDocumentValidation,
java.util.List<WriteRequest> writeRequests,
WriteConcern writeConcern,
DBEncoder encoder) |
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.
|
protected abstract DBObject |
DBCollection.findAndModifyImpl(DBObject query,
DBObject fields,
DBObject sort,
boolean remove,
DBObject update,
boolean returnNew,
boolean upsert,
java.lang.Boolean bypassDocumentValidation,
long maxTime,
java.util.concurrent.TimeUnit maxTimeUnit,
WriteConcern writeConcern)
Atomically modify and return a single document.
|
protected DBObject |
DBCollectionImpl.findAndModifyImpl(DBObject query,
DBObject fields,
DBObject sort,
boolean remove,
DBObject update,
boolean returnNew,
boolean upsert,
java.lang.Boolean bypassDocumentValidation,
long maxTime,
java.util.concurrent.TimeUnit maxTimeUnit,
WriteConcern writeConcern) |
(package private) CommandResult |
DBPort.getLastError(DB db,
WriteConcern concern)
Deprecated.
|
CommandResult |
WriteResult.getLastError(WriteConcern concern)
Deprecated.
Use the appropriate
WriteConcern and rely on the write operation to throw an exception on failure. For
successful writes, use the helper methods to retrieve specific values from the write response. |
CommandResult |
DB.getLastError(WriteConcern concern)
Deprecated.
The getlasterror command will not be supported in future versions of MongoDB. Use acknowledged writes instead.
|
private java.lang.Iterable<DBCollectionImpl.Run> |
DBCollectionImpl.getRunGenerator(boolean ordered,
java.lang.Boolean bypassDocumentValidation,
java.util.List<WriteRequest> writeRequests,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
static OutMessage |
OutMessage.insert(DBCollection collection,
DBEncoder encoder,
WriteConcern concern) |
WriteResult |
DBCollection.insert(DBObject[] arr,
WriteConcern concern)
Insert documents into a collection.
|
WriteResult |
DBCollection.insert(DBObject[] arr,
WriteConcern concern,
DBEncoder encoder)
Insert documents into a collection.
|
WriteResult |
DBCollection.insert(DBObject o,
WriteConcern concern)
Insert a document into a collection.
|
WriteResult |
DBCollection.insert(java.util.List<DBObject> list,
WriteConcern concern)
Insert documents into a collection.
|
WriteResult |
DBCollection.insert(java.util.List<DBObject> list,
WriteConcern concern,
DBEncoder encoder)
Insert documents into a collection.
|
WriteResult |
DBCollection.insert(WriteConcern concern,
DBObject... arr)
Insert documents into a collection.
|
protected abstract WriteResult |
DBCollection.insertImpl(java.util.List<DBObject> list,
WriteConcern concern,
DBEncoder encoder,
java.lang.Boolean bypassDocumentValidation)
Insert documents into a collection.
|
protected WriteResult |
DBCollectionImpl.insertImpl(java.util.List<DBObject> list,
WriteConcern concern,
DBEncoder encoder,
java.lang.Boolean bypassDocumentValidation) |
private BulkWriteResult |
DBCollectionImpl.insertWithCommandProtocol(java.util.List<DBObject> list,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port,
java.lang.Boolean bypassDocumentValidation) |
private WriteResult |
DBCollectionImpl.insertWithWriteProtocol(java.util.List<DBObject> list,
WriteConcern concern,
DBEncoder encoder,
DBPort port,
boolean shouldApply) |
private BasicDBObject |
DBCollectionImpl.prepareFindAndModifyCommand(DBObject query,
DBObject fields,
DBObject sort,
boolean remove,
DBObject update,
boolean returnNew,
boolean upsert,
java.lang.Boolean bypassDocumentValidation,
long maxTime,
java.util.concurrent.TimeUnit maxTimeUnit,
WriteConcern writeConcern,
ServerVersion serverVersion) |
WriteResult |
DBCollectionImpl.remove(DBObject query,
boolean multi,
WriteConcern concern,
DBEncoder encoder) |
WriteResult |
DBCollection.remove(DBObject o,
WriteConcern concern)
Remove documents from a collection.
|
abstract WriteResult |
DBCollection.remove(DBObject o,
WriteConcern concern,
DBEncoder encoder)
Remove documents from a collection.
|
WriteResult |
DBCollectionImpl.remove(DBObject query,
WriteConcern concern,
DBEncoder encoder) |
private BulkWriteResult |
DBCollectionImpl.removeWithCommandProtocol(java.util.List<RemoveRequest> removeList,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
WriteResult |
DBCollection.save(DBObject jo,
WriteConcern concern)
Update an existing document or insert a document depending on the parameter.
|
WriteResult |
DBConnector.say(DB db,
OutMessage m,
WriteConcern concern)
Deprecated.
does a write operation
|
WriteResult |
DBTCPConnector.say(DB db,
OutMessage m,
WriteConcern concern)
Deprecated.
|
(package private) WriteResult |
DBTCPConnector.say(DB db,
OutMessage m,
WriteConcern concern,
DBPort port)
Deprecated.
|
WriteResult |
DBConnector.say(DB db,
OutMessage m,
WriteConcern concern,
ServerAddress hostNeeded)
Deprecated.
does a write operation
|
WriteResult |
DBTCPConnector.say(DB db,
OutMessage m,
WriteConcern concern,
ServerAddress hostNeeded)
Deprecated.
|
void |
Mongo.setWriteConcern(WriteConcern concern)
Sets the write concern for this database.
|
void |
DBCollection.setWriteConcern(WriteConcern writeConcern)
Set the
WriteConcern for this collection. |
void |
MongoOptions.setWriteConcern(WriteConcern writeConcern)
Deprecated.
|
void |
DB.setWriteConcern(WriteConcern writeConcern)
Sets the write concern for this database.
|
private void |
DBCollectionImpl.throwIfBypassDocumentValidationNotSupported(WriteConcern concern,
java.lang.Boolean bypassDocumentValidation,
DBPort port) |
private WriteResult |
DBCollectionImpl.translateBulkWriteResult(BulkWriteResult bulkWriteResult,
WriteRequest.Type type,
WriteConcern writeConcern,
ServerAddress serverAddress) |
(package private) CommandResult |
DBPort.tryGetLastError(DB db,
long last,
WriteConcern concern)
Deprecated.
|
WriteResult |
DBCollection.update(DBObject q,
DBObject o,
boolean upsert,
boolean multi,
WriteConcern concern)
Modify an existing document or documents in collection.
|
WriteResult |
DBCollection.update(DBObject q,
DBObject o,
boolean upsert,
boolean multi,
WriteConcern concern,
boolean bypassDocumentValidation,
DBEncoder encoder)
Modify an existing document or documents in collection.
|
WriteResult |
DBCollection.update(DBObject q,
DBObject o,
boolean upsert,
boolean multi,
WriteConcern concern,
DBEncoder encoder)
Modify an existing document or documents in collection.
|
protected abstract WriteResult |
DBCollection.updateImpl(DBObject q,
DBObject o,
boolean upsert,
boolean multi,
WriteConcern concern,
java.lang.Boolean bypassDocumentValidation,
DBEncoder encoder)
Modify an existing document or documents in collection.
|
protected WriteResult |
DBCollectionImpl.updateImpl(DBObject query,
DBObject o,
boolean upsert,
boolean multi,
WriteConcern concern,
java.lang.Boolean bypassDocumentValidation,
DBEncoder encoder) |
private BulkWriteResult |
DBCollectionImpl.updateWithCommandProtocol(java.util.List<ModifyRequest> updates,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
DBEncoder encoder,
DBPort port) |
private boolean |
DBCollectionImpl.useWriteCommands(WriteConcern concern,
DBPort port) |
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.
|
private void |
OutMessage.writeInsertPrologue(WriteConcern concern) |
private BulkWriteResult |
DBCollectionImpl.writeWithCommandProtocol(DBPort port,
WriteRequest.Type type,
BaseWriteCommandMessage message,
WriteConcern writeConcern) |
| Constructor and Description |
|---|
BaseWriteCommandMessage(MongoNamespace writeNamespace,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
DBEncoder commandEncoder,
MessageSettings settings) |
BulkWriteBatchCombiner(ServerAddress serverAddress,
WriteConcern writeConcern) |
DeleteCommandMessage(MongoNamespace namespace,
WriteConcern writeConcern,
java.util.List<RemoveRequest> deletes,
DBEncoder commandEncoder,
DBEncoder queryEncoder,
MessageSettings settings) |
InsertCommandMessage(MongoNamespace namespace,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<DBObject> documents,
DBEncoder commandEncoder,
DBEncoder encoder,
MessageSettings settings) |
OrderedRunGenerator(java.util.List<WriteRequest> writeRequests,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
Run(WriteRequest.Type type,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
DBEncoder encoder) |
UnorderedRunGenerator(java.util.List<WriteRequest> writeRequests,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
UpdateCommandMessage(MongoNamespace writeNamespace,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<ModifyRequest> updates,
DBEncoder commandEncoder,
DBEncoder encoder,
MessageSettings settings) |
WriteResult(CommandResult o,
WriteConcern concern) |
WriteResult(DB db,
DBPort p,
WriteConcern concern) |