Package | Description |
---|---|
com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
com.allanbank.mongodb.builder |
Provides domain classes and builders for queries and the common MongoDB commands.
|
com.allanbank.mongodb.client |
Provides implementations of the main client interfaces and classes to translate the
Reply (s) from the server. |
com.allanbank.mongodb.client.callback |
Provides implementation for various transformations, implemented in the form of
Callback s, that are used by the driver. |
com.allanbank.mongodb.error |
Exceptions for common MongoDB error conditions.
|
Modifier and Type | Method and Description |
---|---|
long |
MongoCollection.write(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
ListenableFuture<Long> |
AsyncMongoCollection.writeAsync(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AsyncMongoCollection.writeAsync(Callback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AsyncMongoCollection.writeAsync(LambdaCallback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
Modifier and Type | Method and Description |
---|---|
BatchedWrite |
BatchedWrite.Builder.build()
Constructs a new
BatchedWrite object from the state of the
builder. |
static BatchedWrite |
BatchedWrite.delete(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Create a batched write with a single delete operation.
|
static BatchedWrite |
BatchedWrite.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Create a batched write with a single inserts operation.
|
static BatchedWrite |
BatchedWrite.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Create a batched write with a single update operation.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMongoOperations.doWriteAsync(ClusterStats stats,
Callback<Long> results,
BatchedWrite write)
Performs a async write operation.
|
long |
SynchronousMongoCollectionImpl.write(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.writeAsync(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AbstractMongoOperations.writeAsync(Callback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AbstractAsyncMongoCollection.writeAsync(LambdaCallback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
Constructor and Description |
---|
BatchedNativeWriteCallback(Callback<Long> results,
BatchedWrite write,
AbstractMongoOperations collection,
List<WriteOperation> operations)
Creates a new BatchedWriteCallback.
|
BatchedWriteCallback(String databaseName,
String collectionName,
Callback<Long> results,
BatchedWrite write,
Client client,
List<BatchedWrite.Bundle> bundles)
Creates a new BatchedWriteCallback.
|
BatchedWriteCallback(String databaseName,
String collectionName,
List<Callback<Reply>> realCallbacks,
BatchedWrite write,
List<BatchedWrite.Bundle> bundles)
Creates a new BatchedWriteCallback.
|
Modifier and Type | Method and Description |
---|---|
BatchedWrite |
BatchedWriteException.getWrite()
Returns the write that caused the errors.
|
Constructor and Description |
---|
BatchedWriteException(BatchedWrite write,
long n,
List<WriteOperation> skipped,
Map<WriteOperation,Throwable> errors)
Creates a new BatchedWriteException.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.