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.message |
Low level messages to be sent to the MongoDB server.
|
Modifier and Type | Field and Description |
---|---|
static Durability |
Durability.ACK
The durability that says no durability is required.
|
static Durability |
Durability.NONE
The durability that says no durability is required.
|
Modifier and Type | Method and Description |
---|---|
static Durability |
Durability.fsyncDurable(int waitTimeoutMillis)
Creates an fsync() durability.
|
Durability |
MongoClientConfiguration.getDefaultDurability()
Returns the default durability for write operations on the server.
|
Durability |
MongoDatabase.getDurability()
Returns the durability for write operations sent to the server from this
MongoDatabase instance. |
Durability |
MongoCollection.getDurability()
Returns the durability for write operations sent to the server from this
MongoCollection instance. |
static Durability |
Durability.journalDurable(int waitTimeoutMillis)
Creates an journal durability.
|
static Durability |
Durability.replicaDurable(boolean ensureJournaled,
int minimumReplicas,
int waitTimeoutMillis)
Creates a multiple replica durability.
|
static Durability |
Durability.replicaDurable(boolean ensureJournaled,
String waitForReplicasByMode,
int waitTimeoutMillis)
Creates a multiple replica durability.
|
static Durability |
Durability.replicaDurable(int waitTimeoutMillis)
Creates a single replica durability.
|
static Durability |
Durability.replicaDurable(int minimumReplicas,
int waitTimeoutMillis)
Creates a multiple replica durability.
|
static Durability |
Durability.replicaDurable(String waitForReplicasByMode,
int waitTimeoutMillis)
Creates a multiple replica durability.
|
static Durability |
Durability.valueOf(String value)
Converts a string into a Durability, if possible.
|
Modifier and Type | Method and Description |
---|---|
long |
MongoCollection.delete(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
long |
MongoCollection.delete(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.deleteAsync(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
int |
MongoCollection.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
MongoCollection.insert(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AsyncMongoCollection.insertAsync(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(Callback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AsyncMongoCollection.insertAsync(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
MongoCollection.save(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AsyncMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
ListenableFuture<Integer> |
AsyncMongoCollection.saveAsync(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
MongoClientConfiguration.setDefaultDurability(Durability defaultDurability)
Sets the default durability for write operations on the server to the new
value.
|
void |
MongoDatabase.setDurability(Durability durability)
Sets the durability for write operations from this
MongoDatabase
instance. |
void |
MongoCollection.setDurability(Durability durability)
Sets the durability for write operations from this
MongoCollection instance. |
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
Constructor and Description |
---|
MongoClientConfiguration(MongoDbUri mongoDbUri,
Durability defaultDurability)
Creates a new
MongoClientConfiguration instance using a MongoDB
style URL to initialize its state. |
Modifier and Type | Field and Description |
---|---|
protected Durability |
BatchedWrite.Builder.myDurability
The durability for the writes.
|
Modifier and Type | Method and Description |
---|---|
Durability |
BatchedWrite.getDurability()
Returns the durability for the writes.
|
Durability |
BatchedWrite.Builder.getDurability()
Returns the durability for the write.
|
Modifier and Type | Method and Description |
---|---|
static BatchedWrite |
BatchedWrite.delete(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Create a batched write with a single delete operation.
|
BatchedWrite.Builder |
BatchedWrite.Builder.durability(Durability durability)
Sets the durability for the writes.
|
static BatchedWrite |
BatchedWrite.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Create a batched write with a single inserts operation.
|
BatchedWrite.Builder |
BatchedWrite.Builder.setDurability(Durability durability)
Sets the durability for the writes.
|
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 |
---|---|
Durability |
SerialClientImpl.getDefaultDurability()
Returns the
Durability from the MongoClientConfiguration . |
Durability |
ClientImpl.getDefaultDurability()
Returns the
Durability from the MongoClientConfiguration . |
Durability |
Client.getDefaultDurability()
Returns the
Durability from the MongoClientConfiguration . |
Durability |
MongoDatabaseImpl.getDurability()
Returns the durability for write operations sent to the server from this
MongoDatabase instance. |
Durability |
AbstractMongoOperations.getDurability()
Returns the durability to use when no durability is specified for the
write operation.
|
Modifier and Type | Method and Description |
---|---|
protected GetLastError |
AbstractMongoOperations.asGetLastError(Durability durability)
Converts the
Durability into a GetLastError command. |
long |
SynchronousMongoCollectionImpl.delete(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
long |
SynchronousMongoCollectionImpl.delete(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractMongoOperations.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
|
void |
AbstractAsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.deleteAsync(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
protected void |
AbstractMongoOperations.doInsertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
Version requiredServerVersion,
DocumentAssignable... documents)
Sends an
Insert message to the server. |
int |
SynchronousMongoCollectionImpl.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
SynchronousMongoCollectionImpl.insert(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.insertAsync(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractMongoOperations.insertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
|
void |
AbstractAsyncMongoCollection.insertAsync(Callback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.insertAsync(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
SynchronousMongoCollectionImpl.save(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AbstractMongoOperations.saveAsync(Callback<Integer> results,
DocumentAssignable document,
Durability durability)
Constructs a
Insert of Update message based on if the
document contains a AbstractMongoOperations.ID_FIELD_NAME and sends it to the server via
the Client . |
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.saveAsync(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AbstractAsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
MongoDatabaseImpl.setDurability(Durability durability)
Sets the durability for write operations from this
MongoDatabase
instance. |
void |
AbstractMongoOperations.setDurability(Durability durability)
Sets the durability to use when no durability is specified for the write
operation.
|
long |
SynchronousMongoCollectionImpl.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
long |
SynchronousMongoCollectionImpl.update(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AbstractMongoOperations.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
|
void |
AbstractAsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
Constructor and Description |
---|
GetLastError(String dbName,
Durability durability)
Create a new GetLastError.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.