Package | Description |
---|---|
com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
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.client.connection |
Provides interfaces for managing connections to different MongoDB server configurations.
|
com.allanbank.mongodb.client.connection.auth |
Wraps a connection and ensures that all requests are properly authenticated.
|
com.allanbank.mongodb.client.connection.proxy |
Support for connection that delegate to a lower level connection.
|
com.allanbank.mongodb.client.connection.rs |
Support for connections to Replica Sets.
|
com.allanbank.mongodb.client.connection.sharded |
Support for connections to Sharded Configurations.
|
com.allanbank.mongodb.client.connection.socket |
Low level socket connection to a single MongoDB server.
|
com.allanbank.mongodb.error |
Exceptions for common MongoDB error conditions.
|
Modifier and Type | Method and Description |
---|---|
MongoIterator<Document> |
MongoCollection.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
MongoIterator<Document> |
MongoCollection.aggregate(Aggregate command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
BatchedAsyncMongoCollection.cancel()
Cancels the pending batch of operations without sending them to the
server.
|
void |
BatchedAsyncMongoCollection.close()
Flushes the pending batch and submits all of the pending requests to the
server.
|
long |
MongoCollection.count()
Counts the set of documents in the collection.
|
long |
MongoCollection.count(Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
long |
MongoCollection.count(Count count)
Counts the set of documents matching the query document in the
collection.
|
long |
MongoCollection.count(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
long |
MongoCollection.count(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
long |
MongoCollection.count(ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync()
Counts the set of documents in the collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results)
Counts the set of documents in the collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
Count count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(Count count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results)
Counts the set of documents in the collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(ReadPreference readPreference)
Counts the set of documents in the collection.
|
boolean |
MongoDatabase.createCappedCollection(String name,
long size)
Creates the capped collection with the specified name and size on the
server.
|
boolean |
MongoDatabase.createCollection(String name,
DocumentAssignable options)
Creates the collection with the specified name on the server.
|
void |
MongoCollection.createIndex(boolean unique,
Element... keys)
Creates an index with a generated name, across the keys specified and if
unique is true ensuring entries are unique.
|
void |
MongoCollection.createIndex(DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
MongoCollection.createIndex(Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
MongoCollection.createIndex(String name,
boolean unique,
Element... keys)
Creates an index with the specified name, across the keys specified and
if unique is true ensuring entries are unique.
|
void |
MongoCollection.createIndex(String name,
DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
long |
MongoCollection.delete(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
long |
MongoCollection.delete(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
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)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete)
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)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete)
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)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete)
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.
|
MongoIterator<Element> |
MongoCollection.distinct(Distinct.Builder command)
Invokes a distinct command on the server.
|
MongoIterator<Element> |
MongoCollection.distinct(Distinct command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct command)
Invokes a distinct command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.distinctAsync(Distinct.Builder command)
Invokes a distinct command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.distinctAsync(Distinct command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct command)
Invokes a distinct command on the server.
|
boolean |
MongoDatabase.drop()
Drops the database.
|
boolean |
MongoCollection.drop()
Drops the collection from the database.
|
boolean |
MongoCollection.dropIndex(IntegerElement... keys)
Deletes the indexes matching the keys specified.
|
boolean |
MongoCollection.dropIndex(String name)
Deletes the indexes with the provided name.
|
boolean |
MongoDatabase.exists()
Returns true if this database already exists on the server.
|
boolean |
MongoCollection.exists()
Returns true if this collection already exists on the server.
|
Document |
MongoCollection.explain(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
Document |
MongoCollection.explain(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
Document |
MongoCollection.explain(DocumentAssignable query)
Explains the way that the query will be performed.
|
Document |
MongoCollection.explain(Find.Builder query)
Explains the way that the query will be performed.
|
Document |
MongoCollection.explain(Find query)
Explains the way that the query will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Find query)
Explains the way that the query will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Find.Builder query)
Explains the way that the document will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Find query)
Explains the way that the document will be performed.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find query)
Explains the way that the query will be performed.
|
MongoIterator<Document> |
MongoCollection.find(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
MongoIterator<Document> |
MongoCollection.find(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
MongoIterator<Document> |
MongoCollection.find(Find query)
Finds the set of documents matching the query in the collection.
|
Document |
MongoCollection.findAndModify(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
Document |
MongoCollection.findAndModify(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
ListenableFuture<Document> |
AsyncMongoCollection.findAndModifyAsync(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
ListenableFuture<Document> |
AsyncMongoCollection.findAndModifyAsync(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.findAsync(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.findAsync(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.findAsync(Find query)
Finds the set of documents matching the query in the collection.
|
void |
AsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
Document |
MongoCollection.findOne(DocumentAssignable query)
Finds a single matching document in the collection.
|
Document |
MongoCollection.findOne(Find.Builder query)
Finds a single matching document in the collection.
|
Document |
MongoCollection.findOne(Find query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(Callback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(Callback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(Callback<Document> results,
Find query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AsyncMongoCollection.findOneAsync(DocumentAssignable query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AsyncMongoCollection.findOneAsync(Find.Builder query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AsyncMongoCollection.findOneAsync(Find query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find query)
Finds a single matching document in the collection.
|
void |
BatchedAsyncMongoCollection.flush()
Flushes the pending batch and submits all of the pending requests to the
server.
|
ProfilingStatus |
MongoDatabase.getProfilingStatus()
Retrieves the profiling level for the database.
|
MongoIterator<Element> |
MongoCollection.groupBy(GroupBy.Builder command)
Invokes a group command on the server.
|
MongoIterator<Element> |
MongoCollection.groupBy(GroupBy command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy command)
Invokes a group command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.groupByAsync(GroupBy.Builder command)
Invokes a group command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.groupByAsync(GroupBy command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy command)
Invokes a group command on the server.
|
int |
MongoCollection.insert(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
MongoCollection.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
MongoCollection.insert(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,
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,
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,
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(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,
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,
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.
|
boolean |
MongoCollection.isCapped()
Returns true if the collection
statistics indicate that
the collection is a capped collection. |
List<String> |
MongoDatabase.listCollectionNames()
Returns the list of the collections contained within the database.
|
List<String> |
MongoDatabase.listCollections()
Deprecated.
Use the
MongoDatabase.listCollectionNames() method instead. |
MongoIterator<Document> |
MongoCollection.mapReduce(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
MongoIterator<Document> |
MongoCollection.mapReduce(MapReduce command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.mapReduceAsync(MapReduce command)
Invokes a mapReduce command on the server.
|
Collection<MongoIterator<Document>> |
MongoCollection.parallelScan(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
Collection<MongoIterator<Document>> |
MongoCollection.parallelScan(ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AsyncMongoCollection.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AsyncMongoCollection.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AsyncMongoCollection.parallelScanAsync(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AsyncMongoCollection.parallelScanAsync(ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
Document |
MongoDatabase.runAdminCommand(String command)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabase.runAdminCommand(String command,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabase.runAdminCommand(String commandName,
String commandValue,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabase.runCommand(DocumentAssignable command)
Runs a command against the database.
|
Document |
MongoDatabase.runCommand(String command)
Runs a command against the database.
|
Document |
MongoDatabase.runCommand(String command,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabase.runCommand(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabase.runCommand(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
DocumentAssignable command,
Version requiredServerVersion)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command,
Version requiredServerVersion)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String command)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String command,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
int |
MongoCollection.save(DocumentAssignable document)
Saves the
document to the collection. |
int |
MongoCollection.save(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AsyncMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document)
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)
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)
Saves the
document to the collection. |
void |
AsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
boolean |
MongoDatabase.setProfilingStatus(ProfilingStatus profileLevel)
Sets the profiling level for the database.
|
Document |
MongoDatabase.stats()
Returns the statistics for the database.
|
Document |
MongoCollection.stats()
Returns the statistics for the collection.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(Callback<Document> results,
DocumentAssignable query)
Deprecated.
Use the
AsyncMongoCollection.streamingFind(StreamCallback, DocumentAssignable)
method instead. This method will be removed after the 1.3.0
release. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find) method instead.
This method will be removed after the 1.3.0 release. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(LambdaCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find.Builder) method
instead. This method will be removed after the 1.4.0 release. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find) method instead.
This method will be removed after the 1.4.0 release. |
MongoIterator<TextResult> |
MongoCollection.textSearch(Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
MongoIterator<TextResult> |
MongoCollection.textSearch(Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AsyncMongoCollection.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AsyncMongoCollection.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<MongoIterator<TextResult>> |
AsyncMongoCollection.textSearchAsync(Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<MongoIterator<TextResult>> |
AsyncMongoCollection.textSearchAsync(Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
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)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
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)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
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)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
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.
|
Document |
MongoCollection.updateOptions(DocumentAssignable options)
Updates the collection's options or flags using the
collMod
command. |
Document |
MongoCollection.validate(MongoCollection.ValidateMode mode)
Validates the collections contents.
|
long |
MongoCollection.write(BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
long |
MongoCollection.write(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
ListenableFuture<Long> |
AsyncMongoCollection.writeAsync(BatchedWrite.Builder 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.Builder 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.Builder 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 |
---|---|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.aggregate(Aggregate command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
void |
AbstractAsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AbstractMongoOperations.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate command)
Constructs a
aggregate command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AbstractAsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
BatchedAsyncMongoCollectionImpl.close()
Flushes the pending batch and submits all of the pending requests to the
server.
|
long |
SynchronousMongoCollectionImpl.count()
Counts the set of documents in the collection.
|
long |
SynchronousMongoCollectionImpl.count(Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
long |
SynchronousMongoCollectionImpl.count(Count count)
Counts the set of documents matching the query document in the
collection.
|
long |
SynchronousMongoCollectionImpl.count(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
long |
SynchronousMongoCollectionImpl.count(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
long |
SynchronousMongoCollectionImpl.count(ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync()
Counts the set of documents in the collection.
|
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results)
Counts the set of documents in the collection.
|
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractMongoOperations.countAsync(Callback<Long> results,
Count count)
Constructs a
count command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(Count count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results)
Counts the set of documents in the collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count count)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(ReadPreference readPreference)
Counts the set of documents in the collection.
|
boolean |
MongoDatabaseImpl.createCappedCollection(String name,
long size)
Creates the capped collection with the specified name and size on the
server.
|
boolean |
MongoDatabaseImpl.createCollection(String name,
DocumentAssignable options)
Creates the collection with the specified name on the server.
|
void |
SynchronousMongoCollectionImpl.createIndex(boolean unique,
Element... keys)
Creates an index with a generated name, across the keys specified and if
unique is true ensuring entries are unique.
|
void |
SynchronousMongoCollectionImpl.createIndex(DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
SynchronousMongoCollectionImpl.createIndex(Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
SynchronousMongoCollectionImpl.createIndex(String name,
boolean unique,
Element... keys)
Creates an index with the specified name, across the keys specified and
if unique is true ensuring entries are unique.
|
void |
SynchronousMongoCollectionImpl.createIndex(String name,
DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
long |
SynchronousMongoCollectionImpl.delete(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
long |
SynchronousMongoCollectionImpl.delete(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
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 |
AbstractAsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete)
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)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete)
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)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete)
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.
|
MongoIterator<Element> |
SynchronousMongoCollectionImpl.distinct(Distinct.Builder command)
Invokes a distinct command on the server.
|
MongoIterator<Element> |
SynchronousMongoCollectionImpl.distinct(Distinct command)
Invokes a distinct command on the server.
|
void |
AbstractAsyncMongoCollection.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AbstractMongoOperations.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct command)
Constructs a
distinct command and sends it to the server via the
Client . |
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.distinctAsync(Distinct.Builder command)
Invokes a distinct command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.distinctAsync(Distinct command)
Invokes a distinct command on the server.
|
void |
AbstractAsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AbstractAsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct command)
Invokes a distinct command on the server.
|
protected void |
AbstractMongoOperations.doInsertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
Version requiredServerVersion,
DocumentAssignable... documents)
Sends an
Insert message to the server. |
boolean |
SynchronousMongoCollectionImpl.dropIndex(IntegerElement... keys)
Deletes the indexes matching the keys specified.
|
boolean |
SynchronousMongoCollectionImpl.dropIndex(String name)
Deletes the indexes with the provided name.
|
boolean |
SynchronousMongoCollectionImpl.exists()
Returns true if this collection already exists on the server.
|
Document |
SynchronousMongoCollectionImpl.explain(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
Document |
SynchronousMongoCollectionImpl.explain(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
Document |
SynchronousMongoCollectionImpl.explain(DocumentAssignable query)
Explains the way that the query will be performed.
|
Document |
SynchronousMongoCollectionImpl.explain(Find.Builder query)
Explains the way that the query will be performed.
|
Document |
SynchronousMongoCollectionImpl.explain(Find query)
Explains the way that the query will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractMongoOperations.explainAsync(Callback<Document> results,
Aggregate aggregation)
Constructs a
AggregateCommand and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.explainAsync(Callback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AbstractMongoOperations.explainAsync(Callback<Document> results,
Find query)
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Find.Builder query)
Explains the way that the document will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Find query)
Explains the way that the document will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find query)
Explains the way that the query will be performed.
|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.find(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.find(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.find(Find query)
Finds the set of documents matching the query in the collection.
|
Document |
SynchronousMongoCollectionImpl.findAndModify(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
Document |
SynchronousMongoCollectionImpl.findAndModify(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AbstractAsyncMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AbstractMongoOperations.findAndModifyAsync(Callback<Document> results,
FindAndModify command)
Constructs a
findAndModify command and sends it to the server via
the Client . |
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findAndModifyAsync(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findAndModifyAsync(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AbstractAsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AbstractAsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AbstractAsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AbstractAsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AbstractMongoOperations.findAsync(Callback<MongoIterator<Document>> results,
Find query)
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.findAsync(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.findAsync(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.findAsync(Find query)
Finds the set of documents matching the query in the collection.
|
void |
AbstractAsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AbstractAsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AbstractAsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
protected Connection |
SerialClientImpl.findConnection(Message message1,
Message message2)
Tries to reuse the last connection used.
|
protected abstract Connection |
AbstractClient.findConnection(Message message1,
Message message2)
Locates a
Connection to send a message on. |
protected Connection |
ClientImpl.findConnection(Message message1,
Message message2)
Locates a
Connection to send a message on. |
Document |
SynchronousMongoCollectionImpl.findOne(DocumentAssignable query)
Finds a single matching document in the collection.
|
Document |
SynchronousMongoCollectionImpl.findOne(Find.Builder query)
Finds a single matching document in the collection.
|
Document |
SynchronousMongoCollectionImpl.findOne(Find query)
Overridden to call the
AbstractMongoOperations.findOneAsync(com.allanbank.mongodb.Callback, Find) . |
void |
AbstractAsyncMongoCollection.findOneAsync(Callback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(Callback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AbstractMongoOperations.findOneAsync(Callback<Document> results,
Find query)
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findOneAsync(DocumentAssignable query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findOneAsync(Find.Builder query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findOneAsync(Find query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find query)
Finds a single matching document in the collection.
|
void |
BatchedAsyncMongoCollectionImpl.flush()
Flushes the pending batch and submits all of the pending requests to the
server.
|
ProfilingStatus |
MongoDatabaseImpl.getProfilingStatus()
Retrieves the profiling level for the database.
|
MongoIterator<Element> |
SynchronousMongoCollectionImpl.groupBy(GroupBy.Builder command)
Invokes a group command on the server.
|
MongoIterator<Element> |
SynchronousMongoCollectionImpl.groupBy(GroupBy command)
Invokes a group command on the server.
|
void |
AbstractAsyncMongoCollection.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AbstractMongoOperations.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy command)
Constructs a
group command and sends it to the server via the
Client . |
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.groupByAsync(GroupBy.Builder command)
Invokes a group command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.groupByAsync(GroupBy command)
Invokes a group command on the server.
|
void |
AbstractAsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AbstractAsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy command)
Invokes a group command on the server.
|
int |
SynchronousMongoCollectionImpl.insert(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
SynchronousMongoCollectionImpl.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
SynchronousMongoCollectionImpl.insert(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,
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 |
AbstractAsyncMongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
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,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.insertAsync(Callback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.insertAsync(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,
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,
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.
|
boolean |
SynchronousMongoCollectionImpl.isCapped()
Returns true if the collection
statistics indicate that
the collection is a capped collection. |
MongoIterator<Document> |
SynchronousMongoCollectionImpl.mapReduce(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.mapReduce(MapReduce command)
Invokes a mapReduce command on the server.
|
void |
AbstractAsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AbstractMongoOperations.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce command)
Constructs a
mapreduce command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AbstractAsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.mapReduceAsync(MapReduce command)
Invokes a mapReduce command on the server.
|
Collection<MongoIterator<Document>> |
SynchronousMongoCollectionImpl.parallelScan(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
Collection<MongoIterator<Document>> |
SynchronousMongoCollectionImpl.parallelScan(ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AbstractAsyncMongoCollection.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AbstractMongoOperations.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Constructs a
parallelCollectionScan command and sends it to the
server via the Client . |
void |
AbstractAsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AbstractAsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AbstractAsyncMongoCollection.parallelScanAsync(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AbstractAsyncMongoCollection.parallelScanAsync(ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
MongoIteratorImpl.restart()
Restarts the iterator by sending a request for more documents.
|
Document |
MongoDatabaseImpl.runAdminCommand(String command)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabaseImpl.runAdminCommand(String command,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabaseImpl.runAdminCommand(String commandName,
String commandValue,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabaseImpl.runCommand(DocumentAssignable command)
Runs a command against the database.
|
Document |
MongoDatabaseImpl.runCommand(String command)
Runs a command against the database.
|
Document |
MongoDatabaseImpl.runCommand(String command,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabaseImpl.runCommand(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabaseImpl.runCommand(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
DocumentAssignable command,
Version requireServerVersion)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command,
Version requiredServerVersion)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String command)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String command,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
int |
SynchronousMongoCollectionImpl.save(DocumentAssignable document)
Saves the
document to the collection. |
int |
SynchronousMongoCollectionImpl.save(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AbstractAsyncMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document)
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)
Saves the
document to the collection. |
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.saveAsync(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AbstractAsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document)
Saves the
document to the collection. |
void |
AbstractAsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
protected Connection |
ClientImpl.searchConnection(Message message1,
Message message2,
boolean waitForReconnect)
Searches for a connection to use.
|
void |
AbstractClient.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
Client.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractClient.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
Client.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
protected void |
MongoIteratorImpl.sendRequest()
Sends a request for more documents.
|
boolean |
MongoDatabaseImpl.setProfilingStatus(ProfilingStatus profileLevel)
Sets the profiling level for the database.
|
Document |
MongoDatabaseImpl.stats()
Returns the statistics for the database.
|
Document |
SynchronousMongoCollectionImpl.stats()
Returns the statistics for the collection.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Find.Builder aggregation)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AbstractMongoOperations.stream(StreamCallback<Document> results,
Aggregate aggregation)
Constructs a
aggregate command and sends it to the server via the
Client . |
MongoCursorControl |
AbstractAsyncMongoCollection.stream(StreamCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractMongoOperations.stream(StreamCallback<Document> results,
Find query)
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(Callback<Document> results,
DocumentAssignable query)
Deprecated.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(LambdaCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Deprecated.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Deprecated.
|
MongoIterator<TextResult> |
SynchronousMongoCollectionImpl.textSearch(Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
MongoIterator<TextResult> |
SynchronousMongoCollectionImpl.textSearch(Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AbstractAsyncMongoCollection.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AbstractMongoOperations.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<MongoIterator<TextResult>> |
AbstractAsyncMongoCollection.textSearchAsync(Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<MongoIterator<TextResult>> |
AbstractAsyncMongoCollection.textSearchAsync(Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
long |
SynchronousMongoCollectionImpl.update(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
long |
SynchronousMongoCollectionImpl.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
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 |
AbstractAsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
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)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
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)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
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.
|
Document |
SynchronousMongoCollectionImpl.updateOptions(DocumentAssignable options)
Updates the collection's options or flags using the
collMod
command. |
Document |
SynchronousMongoCollectionImpl.validate(MongoCollection.ValidateMode mode)
Validates the collections contents.
|
long |
SynchronousMongoCollectionImpl.write(BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
long |
SynchronousMongoCollectionImpl.write(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.writeAsync(BatchedWrite.Builder 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 |
AbstractAsyncMongoCollection.writeAsync(Callback<Long> results,
BatchedWrite.Builder 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.Builder 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.
|
Modifier and Type | Method and Description |
---|---|
protected MongoDbException |
ReplyIntegerCallback.asError(Reply reply)
Creates an exception from the
Reply . |
protected MongoDbException |
ReplyLongCallback.asError(Reply reply)
Creates an exception from the
Reply . |
protected MongoDbException |
ReplyCommandCallback.asError(Reply reply)
Creates an exception from the
Reply . |
protected MongoDbException |
SingleDocumentReplyCallback.asError(Reply reply)
Creates an exception from the
Reply . |
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply)
Creates an exception from the
Reply . |
protected MongoDbException |
ReplyDocumentCallback.asError(Reply reply)
Creates an exception from the
Reply . |
protected MongoDbException |
ReplyArrayCallback.asError(Reply reply)
Creates an exception from the
Reply . |
protected MongoDbException |
ReplyCommandCallback.asError(Reply reply,
boolean knownError)
Creates an exception from the
Reply . |
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply,
boolean knownError)
Creates an exception from the
Reply . |
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply,
int okValue,
int errorNumber,
boolean knownDurabilityError,
String errorMessage,
Message message)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
CursorCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
MultipleCursorCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
CursorStreamingCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractValidatingReplyCallback.checkForError(Reply reply)
Checks for a non-flag error in the reply.
|
protected Integer |
ReplyIntegerCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected MongoIterator<Document> |
CursorCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Long |
ReplyLongCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Collection<MongoIterator<Document>> |
MultipleCursorCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
ReplyCommandCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
SingleDocumentReplyCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected abstract F |
AbstractReplyCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Reply |
ValidatingReplyCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
SingleDocumentCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
ReplyDocumentCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected MongoIterator<Element> |
ReplyArrayCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected MongoIterator<Document> |
ReplyResultCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected void |
CursorStreamingCallback.handle(Reply reply)
Called once the
Reply has been validated. |
protected void |
CursorStreamingCallback.sendKill()
Sends a
KillCursors message if there is an active cursor. |
protected void |
CursorStreamingCallback.sendRequest()
Sends a request to start the next match of documents.
|
protected void |
AbstractValidatingReplyCallback.verify(Reply reply)
Checks the reply for an error message.
|
Modifier and Type | Method and Description |
---|---|
void |
Connection.raiseErrors(MongoDbException exception)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
Modifier and Type | Method and Description |
---|---|
void |
Connection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
Connection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthenticatingConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AuthenticatingConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
protected MongoDbException |
AbstractProxyMultipleConnection.createReconnectFailure(Message message1,
Message message2)
Creates a exception for a reconnect failure.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractProxyConnection.onExceptin(MongoDbException exception)
Provides the ability for derived classes to intercept any exceptions from
the underlying proxied connection.
|
void |
AbstractProxyConnection.raiseErrors(MongoDbException exception)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
void |
AbstractProxyMultipleConnection.raiseErrors(MongoDbException exception)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
Modifier and Type | Method and Description |
---|---|
protected abstract List<K> |
AbstractProxyMultipleConnection.findPotentialKeys(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
void |
AbstractProxyConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractProxyMultipleConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractProxyConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractProxyMultipleConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
protected List<Server> |
ReplicaSetConnection.findPotentialKeys(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
Modifier and Type | Method and Description |
---|---|
protected List<Server> |
ShardedConnection.findPotentialKeys(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
Modifier and Type | Method and Description |
---|---|
void |
TwoThreadSocketConnection.raiseErrors(MongoDbException exception)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
void |
AbstractSocketConnection.raiseErrors(MongoDbException exception)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
protected void |
AbstractSocketConnection.shutdown(MongoDbException error,
boolean receiveError)
Shutsdown the connection on an error.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
AbstractSocketConnection.doReceive()
Receives a single message from the connection.
|
void |
SocketConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
TwoThreadSocketConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
SocketConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
TwoThreadSocketConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
Modifier and Type | Class and Description |
---|---|
class |
BatchedWriteException
BatchedWriteException provides a single exception containing the aggregated
errors across the batched writes.
|
class |
CannotConnectException
CannotConnectException is thrown to report a failure when attempting to
connect to MongoDB.
|
class |
ConnectionLostException
ConnectionLostException provides a exception thrown when the connection to
the MongoDB server is lost.
|
class |
CursorNotFoundException
Exception raised when a get_more request is issued for an unknown cursor.
|
class |
DocumentToLargeException
DocumentToLargeException is thrown to report that an attempt was made to
serialize a Document that is over the maximum size limit.
|
class |
DuplicateKeyException
Exception raised when an insert encounters a duplicate key error.
|
class |
DurabilityException
Exception raised when a write encounters a durability violation.
|
class |
JsonException
JsonException provides an exception to throw when processing JSON documents
fail.
|
class |
JsonParseException
JsonParseException provides an exception to throw when parsing a JSON
document fails.
|
class |
MaximumTimeLimitExceededException
Exception raised when a request to the server exceeds the maximum allowed
time.
|
class |
MongoClientClosedException
MongoClientClosedException is thrown when there is an attempt to send a
message on a closed
MongoClient . |
class |
MongoDbAuthenticationException
MongoDbAuthenticationException is thrown to report a failure to authenticate
with a MongoDB database.
|
class |
QueryFailedException
Exception raised when a query fails.
|
class |
ReplyException
Base class exception for all reply errors.
|
class |
ServerVersionException
ServerVersionException is thrown to report that an attempt was made to send a
request to a server that required a more recent version of the server.
|
class |
ShardConfigStaleException
Exception raised when a a request to a shard server is based on an invalid or
stale configuration.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.