Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.bulk |
Contains classes for representing the result of a bulk write operation.
|
com.mongodb.client |
This package contains classes for the new client api for MongoDatabase and MongoCollection
|
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 | Field and Description |
---|---|
private BulkWriteResult |
MongoBulkWriteException.writeResult |
Modifier and Type | Method and Description |
---|---|
BulkWriteResult |
MongoCollectionImpl.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests) |
BulkWriteResult |
MongoCollectionImpl.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options) |
private BulkWriteResult |
MongoCollectionImpl.executeSingleWriteRequest(WriteRequest request,
java.lang.Boolean bypassDocumentValidation) |
BulkWriteResult |
MongoBulkWriteException.getWriteResult()
The result of all successfully processed write operations.
|
Modifier and Type | Method and Description |
---|---|
private UpdateResult |
MongoCollectionImpl.toUpdateResult(BulkWriteResult result) |
(package private) static BulkWriteResult |
BulkWriteHelper.translateBulkWriteResult(BulkWriteResult bulkWriteResult,
Decoder<DBObject> decoder) |
private WriteConcernResult |
MongoCollectionImpl.translateBulkWriteResult(WriteRequest request,
BulkWriteResult writeResult) |
Constructor and Description |
---|
MongoBulkWriteException(BulkWriteResult writeResult,
java.util.List<BulkWriteError> writeErrors,
WriteConcernError writeConcernError,
ServerAddress serverAddress)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
private UpdateResult |
MongoCollectionImpl.toUpdateResult(BulkWriteResult result) |
private WriteConcernResult |
MongoCollectionImpl.translateBulkWriteResult(WriteRequest request,
BulkWriteResult writeResult) |
Modifier and Type | Method and Description |
---|---|
void |
MongoCollection.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollectionImpl.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback) |
void |
MongoCollection.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollectionImpl.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback) |
private void |
MongoCollectionImpl.executeSingleWriteRequest(WriteRequest request,
java.lang.Boolean bypassDocumentValidation,
SingleResultCallback<BulkWriteResult> callback) |
Modifier and Type | Method and Description |
---|---|
static BulkWriteResult |
BulkWriteResult.acknowledged(int insertedCount,
int matchedCount,
int removedCount,
java.lang.Integer modifiedCount,
java.util.List<BulkWriteUpsert> upserts)
Create an acknowledged BulkWriteResult
|
static BulkWriteResult |
BulkWriteResult.acknowledged(WriteRequest.Type type,
int count,
java.lang.Integer modifiedCount,
java.util.List<BulkWriteUpsert> upserts)
Create an acknowledged BulkWriteResult
|
static BulkWriteResult |
BulkWriteResult.acknowledged(WriteRequest.Type type,
int count,
java.util.List<BulkWriteUpsert> upserts)
Create an acknowledged BulkWriteResult
|
static BulkWriteResult |
BulkWriteResult.unacknowledged()
Create an unacknowledged BulkWriteResult
|
Modifier and Type | Method and Description |
---|---|
BulkWriteResult |
MongoCollection.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests)
Executes a mix of inserts, updates, replaces, and deletes.
|
BulkWriteResult |
MongoCollection.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options)
Executes a mix of inserts, updates, replaces, and deletes.
|
Modifier and Type | Method and Description |
---|---|
private BulkWriteResult |
BulkWriteBatchCombiner.createResult() |
BulkWriteResult |
DefaultServerConnection.deleteCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes) |
BulkWriteResult |
Connection.deleteCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Delete the documents using the delete command.
|
BulkWriteResult |
DeleteCommandProtocol.execute(InternalConnection connection) |
BulkWriteResult |
InsertCommandProtocol.execute(InternalConnection connection) |
BulkWriteResult |
UpdateCommandProtocol.execute(InternalConnection connection) |
BulkWriteResult |
WriteCommandProtocol.execute(InternalConnection connection) |
(package private) static BulkWriteResult |
WriteCommandResultHelper.getBulkWriteResult(WriteRequest.Type type,
BsonDocument result) |
BulkWriteResult |
BulkWriteBatchCombiner.getResult()
Gets the combined result.
|
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.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.util.List<InsertRequest> inserts) |
BulkWriteResult |
Connection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts)
Deprecated.
|
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.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.util.List<UpdateRequest> updates) |
BulkWriteResult |
Connection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
BulkWriteBatchCombiner.addResult(BulkWriteResult result,
IndexMap indexMap)
Add a result
|
Modifier and Type | Method and Description |
---|---|
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) |
void |
DeleteCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
InsertCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
UpdateCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
WriteCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
private void |
WriteCommandProtocol.executeBatchesAsync(InternalConnection connection,
BaseWriteCommandMessage message,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
int batchNum,
int currentRangeStartIndex,
SingleResultCallback<BulkWriteResult> callback) |
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) |
private void |
WriteCommandProtocol.sendMessageAsync(InternalConnection connection,
ByteBufferBsonOutput buffer,
BaseWriteCommandMessage message,
long startTimeNanos,
SingleResultCallback<BulkWriteResult> clientCallback,
SingleResultCallback<BsonDocument> callback) |
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) |
Modifier and Type | Method and Description |
---|---|
(package private) BulkWriteResult |
MixedBulkWriteOperation.Run.RunExecutor.execute() |
(package private) BulkWriteResult |
MixedBulkWriteOperation.Run.execute(Connection connection) |
BulkWriteResult |
MixedBulkWriteOperation.execute(WriteBinding binding)
Executes a bulk write operation.
|
protected BulkWriteResult |
DeleteOperation.executeCommandProtocol(Connection connection) |
protected BulkWriteResult |
InsertOperation.executeCommandProtocol(Connection connection) |
protected BulkWriteResult |
UpdateOperation.executeCommandProtocol(Connection connection) |
protected abstract BulkWriteResult |
BaseWriteOperation.executeCommandProtocol(Connection connection)
Executes the write command protocol.
|
(package private) abstract BulkWriteResult |
MixedBulkWriteOperation.Run.RunExecutor.executeWriteCommandProtocol() |
(package private) BulkWriteResult |
MixedBulkWriteOperation.Run.BaseRunExecutor.getResult(WriteConcernResult writeConcernResult) |
(package private) BulkWriteResult |
MixedBulkWriteOperation.Run.BaseRunExecutor.getResult(WriteConcernResult writeConcernResult,
java.util.List<BulkWriteUpsert> upsertedItems) |
(package private) BulkWriteResult |
MixedBulkWriteOperation.Run.BaseRunExecutor.getResult(WriteConcernResult writeConcernResult,
UpdateRequest updateRequest) |
Modifier and Type | Method and Description |
---|---|
private void |
BaseWriteOperation.addBulkWriteResultToResponse(BulkWriteResult bulkWriteResult,
BsonDocument response) |
protected int |
DeleteOperation.getCount(BulkWriteResult bulkWriteResult) |
protected int |
InsertOperation.getCount(BulkWriteResult bulkWriteResult) |
protected int |
UpdateOperation.getCount(BulkWriteResult bulkWriteResult) |
protected abstract int |
BaseWriteOperation.getCount(BulkWriteResult bulkWriteResult) |
protected boolean |
UpdateOperation.getUpdatedExisting(BulkWriteResult bulkWriteResult) |
protected boolean |
BaseWriteOperation.getUpdatedExisting(BulkWriteResult bulkWriteResult) |
private WriteConcernResult |
BaseWriteOperation.translateBulkWriteResult(BulkWriteResult bulkWriteResult) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
MixedBulkWriteOperation.Run.executeAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
MixedBulkWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<BulkWriteResult> callback) |
(package private) void |
MixedBulkWriteOperation.Run.AsyncRunExecutor.executeAsync(SingleResultCallback<BulkWriteResult> callback) |
protected void |
DeleteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
InsertOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
UpdateOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected abstract void |
BaseWriteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback)
Asynchronously executes the write command protocol.
|
private void |
MixedBulkWriteOperation.executeRunsAsync(java.util.Iterator<MixedBulkWriteOperation.Run> runs,
AsyncConnection connection,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
SingleResultCallback<BulkWriteResult> callback) |
private void |
MixedBulkWriteOperation.Run.AsyncRunExecutor.executeRunWritesAsync(int numberOfRuns,
int currentPosition,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
SingleResultCallback<BulkWriteResult> callback) |
(package private) abstract void |
MixedBulkWriteOperation.Run.AsyncRunExecutor.executeWriteCommandProtocolAsync(SingleResultCallback<BulkWriteResult> callback) |