Package | Description |
---|---|
com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
com.allanbank.mongodb.bson |
Strongly typed, immutable implementation of the
BSON Specification.
|
com.allanbank.mongodb.bson.builder |
Provides the interfaces for builders to aid in constructing BSON
Document s. |
com.allanbank.mongodb.bson.builder.impl |
Provides the implementations for builders to aid in constructing BSON
Document s. |
com.allanbank.mongodb.bson.element | |
com.allanbank.mongodb.bson.impl |
Provides the implementation of a top level BSON
Document . |
com.allanbank.mongodb.bson.io |
Provides the ability to serialize and deserialize BSON
Document s. |
com.allanbank.mongodb.bson.json |
Contains a parser of JSON documents based on a JavaCC grammer.
|
com.allanbank.mongodb.builder |
Provides domain classes and builders for queries and the common MongoDB commands.
|
com.allanbank.mongodb.builder.write |
Provides containers for the basic write operations.
|
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.message |
Low level messages to be sent to the MongoDB server.
|
com.allanbank.mongodb.client.state |
Support for tracking the state of a set of MongoDB servers.
|
com.allanbank.mongodb.error |
Exceptions for common MongoDB error conditions.
|
com.allanbank.mongodb.gridfs |
Provides an implementation of the GridFS Specification.
|
Modifier and Type | Field and Description |
---|---|
static Document |
AsyncMongoCollection.ALL
An (empty) query document to find all documents.
|
static Document |
MongoCollection.ALL
An (empty) query document to find all documents.
|
static Document |
AsyncMongoCollection.NONE
An (empty) update document to perform no actual modifications.
|
static Document |
MongoCollection.NONE
An (empty) update document to perform no actual modifications.
|
Modifier and Type | Method and Description |
---|---|
Document |
MongoCursorControl.asDocument()
Returns a
Document that can be used to restart the
cursor/iterator. |
Document |
Durability.asDocument()
Returns a suitable getlasterror command's document.
|
Document |
ReadPreference.asDocument()
Converts the object into a document.
|
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.
|
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.
|
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.
|
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.
|
Document |
MongoDatabase.stats()
Returns the statistics for the database.
|
Document |
MongoCollection.stats()
Returns the statistics for 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.
|
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.
|
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.
|
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.
|
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.
|
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.
|
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.
|
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.
|
List<Document> |
ReadPreference.getTagMatchingDocuments()
Returns the list of tag matching documents to control the secondaries
used.
|
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.
|
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. |
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. |
MongoIterator<Document> |
MongoClient.restart(DocumentAssignable cursorDocument)
Restarts an iterator that was previously saved.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(DocumentAssignable command)
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.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ReadPreference.matches(Document tags)
Returns true if this
ReadPreference matches the tags
document. |
Modifier and Type | Method and Description |
---|---|
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 |
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.
|
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.
|
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.
|
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.
|
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.
|
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.
|
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 |
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.
|
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. |
MongoCursorControl |
MongoClient.restart(LambdaCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
MongoClient.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
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.
|
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.
|
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. |
Modifier and Type | Method and Description |
---|---|
Document |
DocumentReference.asDocument()
Converts the object into a document.
|
Document |
DocumentAssignable.asDocument()
Converts the object into a document.
|
Modifier and Type | Method and Description |
---|---|
void |
VisitorAdapter.visitJavaScript(String name,
String code,
Document scope)
Visits a JavaScript with Scope element.
|
void |
Visitor.visitJavaScript(String name,
String code,
Document scope)
Visits a JavaScript with Scope element.
|
Modifier and Type | Method and Description |
---|---|
Document |
DocumentBuilder.build()
Returns the
Document being constructed. |
Modifier and Type | Method and Description |
---|---|
Document |
DocumentBuilderImpl.asDocument()
Converts the object into a document.
|
Document |
DocumentBuilderImpl.build()
Returns the
Document being constructed. |
Modifier and Type | Class and Description |
---|---|
class |
DocumentElement
Wraps a single BSON document that may contain nested documents.
|
Modifier and Type | Method and Description |
---|---|
Document |
DocumentElement.asDocument()
Converts the object into a document.
|
Document |
DocumentElement.getDocument()
Returns the element's document.
|
Document |
JavaScriptWithScopeElement.getScope()
Returns the BSON JavaScript scope.
|
Document |
JavaScriptWithScopeElement.getValueAsObject()
Returns the value for BSON element as a Java
Object type. |
Document |
DocumentElement.getValueAsObject()
Returns the value for BSON element as a Java
Object type. |
Modifier and Type | Method and Description |
---|---|
void |
JsonSerializationVisitor.visitJavaScript(String name,
String code,
Document scope)
Visits a JavaScript with Scope element.
|
Constructor and Description |
---|
DocumentElement(String name,
Document value)
Constructs a new
DocumentElement . |
JavaScriptWithScopeElement(String name,
String javaScript,
Document scope)
Constructs a new
JavaScriptWithScopeElement . |
JavaScriptWithScopeElement(String name,
String javaScript,
Document scope,
long size)
Constructs a new
JavaScriptWithScopeElement . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDocument
AbstractDocument provides a base class for all document implementations with
the common functionality.
|
class |
EmptyDocument
An immutable empty document.
|
class |
ImmutableDocument
A root level document that is truly immutable.
|
class |
RootDocument
A root level document that can inject a _id value.
|
Modifier and Type | Method and Description |
---|---|
Document |
AbstractDocument.asDocument()
Converts the object into a document.
|
Modifier and Type | Method and Description |
---|---|
Document |
BsonInputStream.readDocument()
Reads a BSON document element:
|
Modifier and Type | Method and Description |
---|---|
int |
BsonOutputStream.sizeOf(Document document)
Returns the size of the writing the
Document as a BSON document. |
void |
SizeOfVisitor.visitJavaScript(String name,
String code,
Document scope)
Visits a JavaScript with Scope element.
|
long |
BufferingBsonOutputStream.write(Document doc)
Writes the Document in BSON format to the underlying stream.
|
void |
BsonOutputStream.writeDocument(Document document)
Writes a BSON
Document to the stream. |
void |
BufferingBsonOutputStream.writeDocument(Document doc)
Writes the Document in BSON format to the underlying stream.
|
Modifier and Type | Method and Description |
---|---|
static Document |
Json.parse(Reader input)
Parses the document from the reader into a BSON
Document . |
static Document |
Json.parse(String input)
Parses the document from the reader into a BSON
Document . |
Modifier and Type | Field and Description |
---|---|
static Document |
Count.ALL
An (empty) query document to find all documents.
|
static Document |
Find.ALL
An (empty) query document to find all documents.
|
static Document |
FindAndModify.ALL
An (empty) query document to find all documents.
|
protected Document |
FindAndModify.Builder.myFields
Retrieve a subset of fields from the matched document.
|
protected Document |
Find.Builder.myHint
The hint for which index to use.
|
protected Document |
GroupBy.Builder.myInitialValue
The initial value for the group.
|
protected Document |
Find.Builder.myMaximumRange
If set then controls the maximum value for the range within the used
index.
|
protected Document |
Find.Builder.myMinimumRange
If set then controls the minimum value for the range within the used
index.
|
protected Document |
Find.Builder.myProjection
The fields to be returned from the matching documents.
|
protected Document |
Count.Builder.myQuery
The query document.
|
protected Document |
AggregationGeoNear.Builder.myQuery
The optional query for further refining the documents to add to the
pipeline.
|
protected Document |
Find.Builder.myQuery
The query document.
|
protected Document |
Distinct.Builder.myQuery
The query to select document to perform a distinct query across.
|
protected Document |
Text.Builder.myQuery
Deprecated.
A standard MongoDB query document to limit the final results.
|
protected Document |
GroupBy.Builder.myQuery
The query to select the documents to run the group against.
|
protected Document |
MapReduce.Builder.myQuery
The query to select the document to run the map/reduce against.
|
protected Document |
FindAndModify.Builder.myQuery
A query to locate the document to update.
|
protected Document |
Text.Builder.myReturnFields
Deprecated.
The fields to return from the query.
|
protected Document |
MapReduce.Builder.myScope
The scoped values to expose to the map/reduce/finalize functions.
|
protected Document |
Find.Builder.mySort
The fields to order the document on.
|
protected Document |
MapReduce.Builder.mySort
The sort to apply to the input objects.
|
protected Document |
FindAndModify.Builder.mySort
If multiple docs match, choose the first one in the specified sort
order as the object to manipulate.
|
protected Document |
FindAndModify.Builder.myUpdate
Updates to be applied to the document.
|
static Document |
FindAndModify.NONE
An (empty) update document to perform no actual modifications.
|
Modifier and Type | Method and Description |
---|---|
static Document |
QueryBuilder.and(DocumentAssignable... criteria)
Creates a single document that is the conjunction of the criteria
provided.
|
Document |
ConditionBuilder.asDocument()
Converts the object into a document.
|
Document |
QueryBuilder.asDocument()
Converts the object into a document.
|
Document |
AggregationGeoNear.asDocument()
Converts the object into a document.
|
Document |
ConditionBuilder.build()
Returns the results of building the parent
QueryBuilder . |
Document |
QueryBuilder.build()
Construct the final query document.
|
Document |
BatchedWrite.Bundle.getCommand()
Returns the command containing the bundled write operations.
|
Document |
TextResult.getDocument()
Deprecated.
Returns the document.
|
Document |
FindAndModify.getFields()
Returns the subset of fields to retrieve from the matched document.
|
Document |
Find.getHint()
Returns the hint for which index to use.
|
Document |
GroupBy.getInitialValue()
Returns the initial value for each group.
|
Document |
Find.getMaximumRange()
Returns a non-null value to controls the maximum value for the range
within the used index.
|
Document |
Find.getMinimumRange()
Returns a non-null value to controls the minimum value for the range
within the used index.
|
Document |
Find.getProjection()
Returns the fields to be projected or returned from the matching
documents.
|
Document |
Count.getQuery()
Returns the query document.
|
Document |
AggregationGeoNear.getQuery()
If set returns the optional query for further refining the documents to
add to the pipeline.
|
Document |
Find.getQuery()
Returns the query document.
|
Document |
Distinct.getQuery()
Returns the query to select the documents to run the distinct against.
|
Document |
Text.getQuery()
Deprecated.
Returns the query document to limit the final results.
|
Document |
GroupBy.getQuery()
Returns the query to select the documents to run the group against.
|
Document |
MapReduce.getQuery()
Returns the query to select the documents to run the map/reduce against.
|
Document |
FindAndModify.getQuery()
Returns the query to locate the document to update.
|
Document |
TextResult.getRawDocument()
Deprecated.
Returns the un-processed result document.
|
Document |
Find.getReturnFields()
Deprecated.
Replaced with the MongoDB standardized name:
projection . This method will be
removed on or after the 1.4 release. |
Document |
Text.getReturnFields()
Deprecated.
Returns the fields to return from the query.
|
Document |
MapReduce.getScope()
Returns the scoped values to expose to the map/reduce/finalize functions.
|
Document |
Find.getSort()
Returns the fields to order document by.
|
Document |
MapReduce.getSort()
Returns the sort to apply to the input objects.
|
Document |
FindAndModify.getSort()
Returns the sort to apply if multiple docs match, choose the first one as
the object to manipulate.
|
Document |
FindAndModify.getUpdate()
Returns the updates to be applied to the document.
|
static Document |
GeoJson.lineString(List<? extends Point2D> points)
Constructs a GeoJSON 'LineString' document from the coordinates provided.
|
static Document |
GeoJson.lineString(Point2D p1,
Point2D p2,
Point2D... remaining)
Constructs a GeoJSON 'LineString' document from the coordinates provided.
|
static Document |
GeoJson.multiLineString(List<? extends Point2D> firstLineString,
List<? extends Point2D>... additionalLineStrings)
Constructs a GeoJSON 'MultiLineString' document from the coordinates
provided.
|
static Document |
GeoJson.multiPoint(List<? extends Point2D> positions)
Constructs a GeoJSON 'MultiPoint' document from the positions provided.
|
static Document |
GeoJson.multiPoint(Point2D firstPosition,
Point2D... additionalPositions)
Constructs a GeoJSON 'MultiPoint' document from the positions provided.
|
static Document |
QueryBuilder.nor(DocumentAssignable... criteria)
Creates a single document that is the disjunction of the criteria
provided.
|
static Document |
QueryBuilder.not(DocumentAssignable... criteria)
Negate a set of criteria.
|
static Document |
QueryBuilder.or(DocumentAssignable... criteria)
Creates a single document that is the disjunction of the criteria
provided.
|
static Document |
GeoJson.point(Point2D position)
Constructs a GeoJSON 'Point' document from the coordinates provided.
|
static Document |
GeoJson.polygon(List<? extends Point2D> boundary)
Constructs a GeoJSON 'Polygon' document from the coordinates provided.
|
static Document |
GeoJson.polygon(List<? extends Point2D> boundary,
List<? extends Point2D>... holes)
Constructs a GeoJSON 'Polygon' document from the coordinates provided.
|
Document |
Find.toQueryRequest(boolean explain)
This method is not intended for applications to use.
|
Document |
Find.toQueryRequest(boolean explain,
ReadPreference readPreference)
This method is not intended for applications to use.
|
Constructor and Description |
---|
BatchedWrite.Bundle(Document command,
List<WriteOperation> writes)
Creates a new Bundle.
|
Modifier and Type | Method and Description |
---|---|
Document |
InsertOperation.getDocument()
Returns the document to insert.
|
Document |
UpdateOperation.getQuery()
Returns the query to find the documents to update.
|
Document |
DeleteOperation.getQuery()
Returns the query to find the documents to delete.
|
Document |
UpdateOperation.getRoutingDocument()
Returns the document that should be used to route the write operation.
|
Document |
InsertOperation.getRoutingDocument()
Returns the document that should be used to route the write operation.
|
Document |
DeleteOperation.getRoutingDocument()
Returns the document that should be used to route the write operation.
|
Document |
WriteOperation.getRoutingDocument()
Returns the document that should be used to route the write operation.
|
Document |
UpdateOperation.getUpdate()
Returns the update specification.
|
Modifier and Type | Field and Description |
---|---|
static Document |
AbstractMongoOperations.EMPTY_INDEX_OPTIONS
The default empty index options.
|
static Document |
MongoDatabaseImpl.EMPTY_QUERY
An empty query document.
|
static Document |
AbstractMongoOperations.UNIQUE_INDEX_OPTIONS
The default for a UNIQUE index options.
|
Modifier and Type | Method and Description |
---|---|
Document |
SimpleMongoIteratorImpl.asDocument()
Returns a
Document that can be used to restart the
cursor/iterator. |
Document |
MongoIteratorImpl.asDocument()
Returns a
Document that can be used to restart the
cursor/iterator. |
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.
|
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.
|
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) . |
Document |
MongoIteratorImpl.next() |
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.
|
Document |
MongoDatabaseImpl.stats()
Returns the statistics for the database.
|
Document |
SynchronousMongoCollectionImpl.stats()
Returns the statistics for 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.
|
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.
|
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.
|
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.
|
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.
|
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.
|
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.
|
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.
|
Iterator<Document> |
MongoIteratorImpl.iterator() |
protected List<Document> |
MongoIteratorImpl.loadDocuments(boolean blockForTailable)
Loads more documents into the iterator.
|
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.
|
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. |
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. |
MongoIterator<Document> |
SerialClientImpl.restart(DocumentAssignable cursorDocument)
Restarts an iterator that was previously saved.
|
MongoIterator<Document> |
MongoClientImpl.restart(DocumentAssignable cursorDocument)
Restarts an iterator that was previously saved.
|
MongoIterator<Document> |
ClientImpl.restart(DocumentAssignable cursorDocument)
Restarts an iterator that was previously saved.
|
MongoIterator<Document> |
Client.restart(DocumentAssignable cursorDocument)
Restarts an iterator that was previously saved.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(DocumentAssignable command)
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.
|
List<Document> |
MongoIteratorImpl.toList()
Consumes all of the elements in the iterator and returns them in a single
mutable list.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ClientImpl.isCursorDocument(Document doc)
Returns true if the document looks like a cursor restart document.
|
Modifier and Type | Method and Description |
---|---|
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 |
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)
|
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.
|
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 . |
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)
|
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.
|
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)
|
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 |
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.
|
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. |
MongoCursorControl |
MongoClientImpl.restart(LambdaCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
SerialClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
MongoClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
ClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
Client.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
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.
|
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.
|
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.
|
Constructor and Description |
---|
MongoIteratorImpl(Document cursorDocument,
Client client)
Create a new MongoIteratorImpl from a cursor document.
|
Modifier and Type | Method and Description |
---|---|
Document |
CursorStreamingCallback.asDocument()
Returns a
Document that can be used to restart the
cursor/iterator. |
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 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. |
Modifier and Type | Method and Description |
---|---|
protected MongoIterator<Document> |
CursorCallback.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 MongoIterator<Document> |
ReplyResultCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected List<Document> |
CursorStreamingCallback.loadDocuments(Reply reply)
Loads more documents.
|
Modifier and Type | Method and Description |
---|---|
void |
LegacyStreamCallbackAdapter.callback(Document result)
Deprecated.
Called when the MongoDB operation has completed with the result of the
operation.
|
Modifier and Type | Method and Description |
---|---|
void |
IteratorToListCallbackAdapter.callback(MongoIterator<Document> result)
Called when the MongoDB operation has completed with the result of the
operation.
|
void |
TextCallback.callback(MongoIterator<Document> result)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This class 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). |
Constructor and Description |
---|
CursorStreamingCallback(Client client,
Document cursorDocument,
StreamCallback<Document> results)
Create a new CursorCallback from a cursor document.
|
Constructor and Description |
---|
CursorCallback(Client client,
CursorableMessage message,
boolean command,
Callback<MongoIterator<Document>> results)
Create a new CursorCallback.
|
CursorStreamingCallback(Client client,
CursorableMessage originalMessage,
boolean command,
StreamCallback<Document> results)
Create a new CursorCallback.
|
CursorStreamingCallback(Client client,
Document cursorDocument,
StreamCallback<Document> results)
Create a new CursorCallback from a cursor document.
|
IteratorToListCallbackAdapter(Callback<List<Document>> delegate)
Creates a new IteratorToListCallbackAdapter.
|
LegacyStreamCallbackAdapter(Callback<Document> delegate)
Deprecated.
Creates a new LegacyStreamCallbackAdapter.
|
MultipleCursorCallback(Client client,
CursorableMessage message,
Callback<Collection<MongoIterator<Document>>> results)
Create a new CursorCallback.
|
ReplyCommandCallback(Callback<Document> results)
Create a new ReplyDocumentCallback.
|
ReplyDocumentCallback(Callback<Document> results)
Create a new ReplyDocumentCallback.
|
ReplyDocumentCallback(String name,
Callback<Document> results)
Create a new ReplyDocumentCallback.
|
ReplyResultCallback(Callback<MongoIterator<Document>> forwardCallback)
Create a new ReplyResultCallback.
|
ReplyResultCallback(String field,
Callback<MongoIterator<Document>> forwardCallback)
Create a new ReplyResultCallback.
|
SingleDocumentCallback(Callback<Document> results)
Create a new CursorCallback.
|
SingleDocumentReplyCallback(Callback<Document> results)
Create a new SingleDocumentReplyCallback.
|
Modifier and Type | Field and Description |
---|---|
static Document |
BuildInfo.BUILD_INFO
The ismaster "query" document.
|
static Document |
IsMaster.IS_MASTER
The ismaster "query" document.
|
static Document |
ReplicaSetStatus.REPLICA_SET_STATUS
The serverStatus "query" document.
|
static Document |
ServerStatus.SERVER_STATUS
The serverStatus "query" document.
|
Modifier and Type | Method and Description |
---|---|
Document |
Command.getCommand()
Returns the command's document.
|
Document |
Delete.getQuery()
Returns the query
Document . |
Document |
Query.getQuery()
Returns the query document containing the expression to select documents
from the collection.
|
Document |
Update.getQuery()
Returns the query to select the document to update.
|
Document |
Query.getReturnFields()
Returns the optional document containing the fields to be returned.
|
Document |
Command.getRoutingDocument()
Returns the routingDocument value.
|
Document |
Update.getUpdate()
Returns the updates to apply to the selected document(s).
|
Modifier and Type | Method and Description |
---|---|
List<Document> |
Insert.getDocuments()
Returns the documents to insert.
|
List<Document> |
Reply.getResults()
Returns the query results.
|
Modifier and Type | Method and Description |
---|---|
static VersionRange |
QueryVersionVisitor.version(Document query)
Helper to returns the required server version to support the query
operators.
|
Constructor and Description |
---|
AdminCommand(Document commandDocument)
Create a new Command.
|
AggregateCommand(Aggregate aggregation,
String databaseName,
String collectionName,
Document commandDocument,
ReadPreference readPreference,
VersionRange requiredServerVersion)
Create a new AggregateCommand.
|
BatchedWriteCommand(String databaseName,
String collectionName,
Document commandDocument)
Creates a new BatchedWriteCommand.
|
Command(String databaseName,
String collectionName,
Document commandDocument)
Create a new Command.
|
Command(String databaseName,
String collectionName,
Document commandDocument,
Document routingDocument,
ReadPreference readPreference,
VersionRange requiredServerVersion)
Create a new Command.
|
Command(String databaseName,
String collectionName,
Document commandDocument,
ReadPreference readPreference)
Create a new Command.
|
Command(String databaseName,
String collectionName,
Document commandDocument,
ReadPreference readPreference,
VersionRange requiredServerVersion)
Create a new Command.
|
Delete(String databaseName,
String collectionName,
Document query,
boolean singleDelete)
Create a new Delete message.
|
ParallelScanCommand(ParallelScan command,
String databaseName,
String collectionName,
Document commandDocument,
ReadPreference readPreference)
Create a new ParallelScanCommand.
|
Query(String databaseName,
String collectionName,
Document query,
Document returnFields,
int batchSize,
int limit,
int numberToSkip,
boolean tailable,
ReadPreference readPreference,
boolean noCursorTimeout,
boolean awaitData,
boolean exhaust,
boolean partial)
Creates a new Query.
|
Update(String databaseName,
String collectionName,
Document query,
Document update,
boolean multiUpdate,
boolean upsert)
Creates a new Update.
|
Constructor and Description |
---|
Insert(String databaseName,
String collectionName,
List<Document> documents,
boolean continueOnError)
Creates a new Insert.
|
Insert(String databaseName,
String collectionName,
List<Document> documents,
boolean continueOnError,
VersionRange requiredServerVersion)
Creates a new Insert.
|
Reply(int responseToId,
long cursorId,
int cursorOffset,
List<Document> results,
boolean awaitCapable,
boolean cursorNotFound,
boolean queryFailed,
boolean shardConfigStale)
Creates a new Reply.
|
Modifier and Type | Method and Description |
---|---|
Document |
Server.getTags()
Returns the tags for the server.
|
Modifier and Type | Method and Description |
---|---|
void |
Server.update(Document document)
Updates the state of the server based on the document provided.
|
Modifier and Type | Method and Description |
---|---|
Document |
DocumentToLargeException.getDocument()
Returns the document that was too big.
|
Constructor and Description |
---|
DocumentToLargeException(int size,
int maximum,
Document document)
Creates a new DocumentToLargeException.
|
Modifier and Type | Method and Description |
---|---|
protected void |
GridFs.doRead(Document fileDoc,
OutputStream sink)
Reads a file from the GridFS collections and writes the contents to the
sink |
protected void |
GridFs.doTryAndRepair(Document fileDoc,
Map<Object,List<String>> faults)
Tries to repair the file.
|
protected boolean |
GridFs.doUnlink(Document fileDoc)
Unlinks (deletes) the file from the GridFS collections.
|
protected boolean |
GridFs.doValidate(Document fileDoc)
Validates the file from the GridFS collections using the
filemd5
command. |
protected boolean |
GridFs.doVerifyFileMd5(Map<Object,List<String>> faults,
Document fileDoc,
Document cmdResult)
Verifies the MD5 result for the filemd5 command.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.