Package | Description |
---|---|
com.mongodb |
This package is the main entry point to the MongoDB Java Driver, and it contains the classes for the existing API from 2.x versions.
|
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 client interfaces
|
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 | Method and Description |
---|---|
BulkWriteResult |
MongoBulkWriteException.getWriteResult()
The result of all successfully processed write operations.
|
Constructor and Description |
---|
MongoBulkWriteException(BulkWriteResult writeResult,
List<BulkWriteError> writeErrors,
WriteConcernError writeConcernError,
ServerAddress serverAddress)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
MongoCollection.bulkWrite(List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollection.bulkWrite(List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
Modifier and Type | Method and Description |
---|---|
static BulkWriteResult |
BulkWriteResult.acknowledged(int insertedCount,
int matchedCount,
int removedCount,
Integer modifiedCount,
List<BulkWriteUpsert> upserts)
Create an acknowledged BulkWriteResult
|
static BulkWriteResult |
BulkWriteResult.acknowledged(WriteRequest.Type type,
int count,
Integer modifiedCount,
List<BulkWriteUpsert> upserts)
Create an acknowledged BulkWriteResult
|
static BulkWriteResult |
BulkWriteResult.acknowledged(WriteRequest.Type type,
int count,
List<BulkWriteUpsert> upserts)
Create an acknowledged BulkWriteResult
|
static BulkWriteResult |
BulkWriteResult.unacknowledged()
Create an unacknowledged BulkWriteResult
|
Modifier and Type | Method and Description |
---|---|
BulkWriteResult |
MongoCollection.bulkWrite(List<? extends WriteModel<? extends TDocument>> requests)
Executes a mix of inserts, updates, replaces, and deletes.
|
BulkWriteResult |
MongoCollection.bulkWrite(List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options)
Executes a mix of inserts, updates, replaces, and deletes.
|
Modifier and Type | Method and Description |
---|---|
BulkWriteResult |
Connection.deleteCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
List<DeleteRequest> deletes)
Delete the documents using the delete command.
|
BulkWriteResult |
BulkWriteBatchCombiner.getResult()
Gets the combined result.
|
BulkWriteResult |
Connection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
Boolean bypassDocumentValidation,
List<InsertRequest> inserts)
Insert the documents using the insert command.
|
BulkWriteResult |
Connection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
List<InsertRequest> inserts)
Deprecated.
|
BulkWriteResult |
Connection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
Boolean bypassDocumentValidation,
List<UpdateRequest> updates)
Update the documents using the update command.
|
BulkWriteResult |
Connection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
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,
List<DeleteRequest> deletes,
SingleResultCallback<BulkWriteResult> callback)
Delete the documents using the delete command asynchronously.
|
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
Boolean bypassDocumentValidation,
List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
Insert the documents using the insert command asynchronously.
|
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
|
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
Boolean bypassDocumentValidation,
List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
Update the documents using the update command asynchronously.
|
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
|
Modifier and Type | Method and Description |
---|---|
BulkWriteResult |
MixedBulkWriteOperation.execute(WriteBinding binding)
Executes a bulk write operation.
|
protected abstract BulkWriteResult |
BaseWriteOperation.executeCommandProtocol(Connection connection)
Executes the write command protocol.
|
protected BulkWriteResult |
UpdateOperation.executeCommandProtocol(Connection connection) |
protected BulkWriteResult |
DeleteOperation.executeCommandProtocol(Connection connection) |
protected BulkWriteResult |
InsertOperation.executeCommandProtocol(Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected abstract int |
BaseWriteOperation.getCount(BulkWriteResult bulkWriteResult) |
protected int |
UpdateOperation.getCount(BulkWriteResult bulkWriteResult) |
protected int |
DeleteOperation.getCount(BulkWriteResult bulkWriteResult) |
protected int |
InsertOperation.getCount(BulkWriteResult bulkWriteResult) |
protected boolean |
BaseWriteOperation.getUpdatedExisting(BulkWriteResult bulkWriteResult) |
protected boolean |
UpdateOperation.getUpdatedExisting(BulkWriteResult bulkWriteResult) |
Modifier and Type | Method and Description |
---|---|
void |
MixedBulkWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<BulkWriteResult> callback) |
protected abstract void |
BaseWriteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback)
Asynchronously executes the write command protocol.
|
protected void |
UpdateOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
DeleteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
InsertOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
Copyright © 2016. All Rights Reserved.