Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<QueryResult<T>> |
QueryProtocol.QueryResultCallback.callback |
private SingleResultCallback<QueryResult<T>> |
GetMoreProtocol.GetMoreResultCallback.callback |
Modifier and Type | Method and Description |
---|---|
QueryResult<T> |
QueryProtocol.execute(InternalConnection connection) |
QueryResult<T> |
GetMoreProtocol.execute(InternalConnection connection) |
<T> QueryResult<T> |
DefaultServerConnection.getMore(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder) |
<T> QueryResult<T> |
Connection.getMore(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder)
Get more result documents from a cursor.
|
<T> QueryResult<T> |
DefaultServerConnection.query(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int numberToReturn,
int skip,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder) |
<T> QueryResult<T> |
Connection.query(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int numberToReturn,
int skip,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder)
|
<T> QueryResult<T> |
DefaultServerConnection.query(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int skip,
int limit,
int batchSize,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder) |
<T> QueryResult<T> |
Connection.query(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int skip,
int limit,
int batchSize,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder)
Execute the query.
|
Modifier and Type | Method and Description |
---|---|
private BsonDocument |
QueryProtocol.asFindCommandResponseDocument(ResponseBuffers responseBuffers,
QueryResult<T> queryResult,
boolean isExplain) |
private BsonDocument |
GetMoreProtocol.asGetMoreCommandResponseDocument(QueryResult<T> queryResult,
ResponseBuffers responseBuffers) |
private void |
QueryProtocol.sendQuerySucceededEvent(ConnectionDescription connectionDescription,
long startTimeNanos,
QueryMessage message,
boolean isExplainEvent,
ResponseBuffers responseBuffers,
QueryResult<T> queryResult) |
Modifier and Type | Method and Description |
---|---|
void |
QueryProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
void |
GetMoreProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
<T> void |
AsyncConnection.getMoreAsync(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback)
Get more result documents from a cursor asynchronously.
|
<T> void |
DefaultServerConnection.getMoreAsync(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback) |
<T> void |
AsyncConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int numberToReturn,
int skip,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback)
|
<T> void |
DefaultServerConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int numberToReturn,
int skip,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback) |
<T> void |
AsyncConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int skip,
int limit,
int batchSize,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback)
Execute the query asynchronously.
|
<T> void |
DefaultServerConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int skip,
int limit,
int batchSize,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback) |
Constructor and Description |
---|
GetMoreResultCallback(SingleResultCallback<QueryResult<T>> callback,
long cursorId,
GetMoreMessage message,
ConnectionDescription connectionDescription,
CommandListener commandListener,
long startTimeNanos) |
QueryResultCallback(SingleResultCallback<QueryResult<T>> callback,
int requestId,
long startTimeNanos,
QueryMessage message,
boolean isExplainEvent,
ConnectionDescription connectionDescription) |
Modifier and Type | Field and Description |
---|---|
private QueryResult<T> |
AsyncQueryBatchCursor.firstBatch |
private QueryResult<T> |
AsyncSingleBatchQueryCursor.firstBatch |
Modifier and Type | Method and Description |
---|---|
private QueryResult<T> |
AggregateOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
MapReduceWithInlineResultsOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
ListDatabasesOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
DistinctOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
GroupOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
ParallelCollectionScanOperation.createQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress) |
(package private) static <T> QueryResult<T> |
OperationHelper.cursorDocumentToQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress) |
private static <T> QueryResult<T> |
OperationHelper.cursorDocumentToQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress,
java.lang.String fieldNameContainingBatch) |
private QueryResult<T> |
FindOperation.documentToQueryResult(BsonDocument result,
ServerAddress serverAddress) |
(package private) static <T> QueryResult<T> |
OperationHelper.getMoreCursorDocumentToQueryResult(BsonDocument cursorDocument,
ServerAddress serverAddress) |
Modifier and Type | Method and Description |
---|---|
private CommandOperationHelper.CommandTransformer<QueryResult<BsonDocument>,java.lang.Boolean> |
UserExistsOperation.transformQueryResult() |
Modifier and Type | Method and Description |
---|---|
private void |
AsyncQueryBatchCursor.handleGetMoreQueryResult(AsyncConnection connection,
SingleResultCallback<java.util.List<T>> callback,
QueryResult<T> result) |
private void |
QueryBatchCursor.initFromQueryResult(QueryResult<T> queryResult) |
void |
AsyncQueryBatchCursor.QueryResultSingleResultCallback.onResult(QueryResult<T> result,
java.lang.Throwable t) |
Constructor and Description |
---|
AsyncQueryBatchCursor(QueryResult<T> firstBatch,
int limit,
int batchSize,
long maxTimeMS,
Decoder<T> decoder,
AsyncConnectionSource connectionSource,
AsyncConnection connection) |
AsyncSingleBatchQueryCursor(QueryResult<T> firstBatch) |
MapReduceInlineResultsAsyncCursor(QueryResult<T> queryResult,
MapReduceStatistics statistics) |
MapReduceInlineResultsCursor(QueryResult<T> queryResult,
Decoder<T> decoder,
ConnectionSource connectionSource,
MapReduceStatistics statistics) |
QueryBatchCursor(QueryResult<T> firstQueryResult,
int limit,
int batchSize,
Decoder<T> decoder) |
QueryBatchCursor(QueryResult<T> firstQueryResult,
int limit,
int batchSize,
Decoder<T> decoder,
ConnectionSource connectionSource) |
QueryBatchCursor(QueryResult<T> firstQueryResult,
int limit,
int batchSize,
long maxTimeMS,
Decoder<T> decoder,
ConnectionSource connectionSource,
Connection connection) |