Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.client |
This package contains classes for the new client api for MongoDatabase and MongoCollection
|
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 MongoNamespace |
MongoCollectionImpl.namespace |
private MongoNamespace |
DistinctIterableImpl.namespace |
private MongoNamespace |
FindIterableImpl.namespace |
private MongoNamespace |
ListIndexesIterableImpl.namespace |
private MongoNamespace |
Mongo.ServerCursorAndNamespace.namespace |
private MongoNamespace |
AggregateIterableImpl.namespace |
private MongoNamespace |
DBCursor.OptionalFinalizer.namespace |
private MongoNamespace |
MapReduceIterableImpl.namespace |
Modifier and Type | Method and Description |
---|---|
MongoNamespace |
MongoCollectionImpl.getNamespace() |
(package private) MongoNamespace |
DBCollection.getNamespace() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
Mongo.addOrphanedCursor(ServerCursor serverCursor,
MongoNamespace namespace) |
void |
MongoCollectionImpl.renameCollection(MongoNamespace newCollectionNamespace) |
void |
MongoCollectionImpl.renameCollection(MongoNamespace newCollectionNamespace,
RenameCollectionOptions renameCollectionOptions) |
(package private) GroupOperation<DBObject> |
GroupCommand.toOperation(MongoNamespace namespace,
DBObjectCodec codec) |
Constructor and Description |
---|
AggregateIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
OperationExecutor executor,
java.util.List<? extends Bson> pipeline) |
DistinctIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
OperationExecutor executor,
java.lang.String fieldName,
Bson filter) |
FindIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
OperationExecutor executor,
Bson filter,
FindOptions findOptions) |
ListIndexesIterableImpl(MongoNamespace namespace,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
OperationExecutor executor) |
MapReduceIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
OperationExecutor executor,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
MongoCollectionImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
OperationExecutor executor) |
OptionalFinalizer(Mongo mongo,
MongoNamespace namespace) |
ServerCursorAndNamespace(ServerCursor serverCursor,
MongoNamespace namespace) |
Modifier and Type | Field and Description |
---|---|
private MongoNamespace |
MongoCollectionImpl.namespace |
private MongoNamespace |
DistinctIterableImpl.namespace |
private MongoNamespace |
FindIterableImpl.namespace |
private MongoNamespace |
ListIndexesIterableImpl.namespace |
private MongoNamespace |
AggregateIterableImpl.namespace |
private MongoNamespace |
MapReduceIterableImpl.namespace |
Modifier and Type | Method and Description |
---|---|
MongoNamespace |
MongoCollectionImpl.getNamespace() |
MongoNamespace |
MongoCollection.getNamespace()
Gets the namespace of this collection.
|
Modifier and Type | Method and Description |
---|---|
void |
MongoCollectionImpl.renameCollection(MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<java.lang.Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollectionImpl.renameCollection(MongoNamespace newCollectionNamespace,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace,
SingleResultCallback<java.lang.Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
Constructor and Description |
---|
AggregateIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
AsyncOperationExecutor executor,
java.util.List<? extends Bson> pipeline) |
DistinctIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
AsyncOperationExecutor executor,
java.lang.String fieldName,
Bson filter) |
FindIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
AsyncOperationExecutor executor,
Bson filter,
FindOptions findOptions) |
ListIndexesIterableImpl(MongoNamespace namespace,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
MapReduceIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
AsyncOperationExecutor executor,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
MongoCollectionImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
AsyncOperationExecutor executor) |
Modifier and Type | Method and Description |
---|---|
MongoNamespace |
MongoCollection.getNamespace()
Gets the namespace of this collection.
|
Modifier and Type | Method and Description |
---|---|
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace,
RenameCollectionOptions renameCollectionOptions)
Rename the collection with oldCollectionName to the newCollectionName.
|
Modifier and Type | Field and Description |
---|---|
private MongoNamespace |
CommandProtocol.namespace |
private MongoNamespace |
QueryResult.namespace |
private MongoNamespace |
WriteCommandProtocol.namespace |
private MongoNamespace |
QueryProtocol.namespace |
private MongoNamespace |
WriteProtocol.namespace |
private MongoNamespace |
KillCursorProtocol.namespace |
private MongoNamespace |
GetMoreProtocol.namespace |
private MongoNamespace |
BaseWriteCommandMessage.writeNamespace |
Modifier and Type | Method and Description |
---|---|
MongoNamespace |
QueryResult.getNamespace()
Gets the namespace.
|
MongoNamespace |
WriteCommandProtocol.getNamespace()
Gets the namespace to execute the protocol in.
|
protected MongoNamespace |
WriteProtocol.getNamespace()
Gets the namespace.
|
MongoNamespace |
BaseWriteCommandMessage.getWriteNamespace()
Gets the namespace to write to.
|
Modifier and Type | Method and Description |
---|---|
WriteConcernResult |
Connection.delete(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Delete the documents using the delete wire protocol and apply the write concern.
|
WriteConcernResult |
DefaultServerConnection.delete(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes) |
void |
AsyncConnection.deleteAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<WriteConcernResult> callback)
Delete the documents using the delete wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.deleteAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<WriteConcernResult> callback) |
BulkWriteResult |
Connection.deleteCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Delete the documents using the delete command.
|
BulkWriteResult |
DefaultServerConnection.deleteCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes) |
void |
AsyncConnection.deleteCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<BulkWriteResult> callback)
Delete the documents using the delete command asynchronously.
|
void |
DefaultServerConnection.deleteCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<BulkWriteResult> callback) |
<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.getMore(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder) |
<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) |
WriteConcernResult |
Connection.insert(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts)
Insert the documents using the insert wire protocol and apply the write concern.
|
WriteConcernResult |
DefaultServerConnection.insert(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts) |
void |
AsyncConnection.insertAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<WriteConcernResult> callback)
Insert the documents using the insert wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.insertAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<WriteConcernResult> callback) |
BulkWriteResult |
Connection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts)
Insert the documents using the insert command.
|
BulkWriteResult |
DefaultServerConnection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts) |
BulkWriteResult |
Connection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts)
Deprecated.
|
BulkWriteResult |
DefaultServerConnection.insertCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts) |
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
Insert the documents using the insert command asynchronously.
|
void |
DefaultServerConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback) |
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
|
void |
DefaultServerConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback) |
void |
Connection.killCursor(MongoNamespace namespace,
java.util.List<java.lang.Long> cursors)
Kills the given list of cursors.
|
void |
DefaultServerConnection.killCursor(MongoNamespace namespace,
java.util.List<java.lang.Long> cursors) |
void |
AsyncConnection.killCursorAsync(MongoNamespace namespace,
java.util.List<java.lang.Long> cursors,
SingleResultCallback<java.lang.Void> callback)
Asynchronously Kills the given list of cursors.
|
void |
DefaultServerConnection.killCursorAsync(MongoNamespace namespace,
java.util.List<java.lang.Long> cursors,
SingleResultCallback<java.lang.Void> callback) |
<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 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 skip,
int limit,
int batchSize,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder)
Execute the query.
|
<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> 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) |
WriteConcernResult |
Connection.update(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Update the documents using the update wire protocol and apply the write concern.
|
WriteConcernResult |
DefaultServerConnection.update(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates) |
void |
AsyncConnection.updateAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<WriteConcernResult> callback)
Update the documents using the update wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.updateAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<WriteConcernResult> callback) |
BulkWriteResult |
Connection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates)
Update the documents using the update command.
|
BulkWriteResult |
DefaultServerConnection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates) |
BulkWriteResult |
Connection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Deprecated.
|
BulkWriteResult |
DefaultServerConnection.updateCommand(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates) |
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
Update the documents using the update command asynchronously.
|
void |
DefaultServerConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback) |
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
|
void |
DefaultServerConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback) |
Constructor and Description |
---|
BaseWriteCommandMessage(MongoNamespace writeNamespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
MessageSettings settings)
Construct an instance.
|
DeleteCommandMessage(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
MessageSettings settings,
java.util.List<DeleteRequest> deletes)
Construct an instance.
|
DeleteCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Construct an instance.
|
DeleteProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes)
Construct an instance.
|
GetMoreProtocol(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder)
Construct an instance.
|
InsertCommandMessage(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
MessageSettings settings,
java.util.List<InsertRequest> insertRequestList)
Construct a new instance.
|
InsertCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> insertRequests)
Construct an instance.
|
InsertProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> insertRequestList)
Construct a new instance.
|
KillCursorProtocol(MongoNamespace namespace,
java.util.List<java.lang.Long> cursors)
Construct an instance.
|
QueryProtocol(MongoNamespace namespace,
int skip,
int numberToReturn,
BsonDocument queryDocument,
BsonDocument fields,
Decoder<T> resultDecoder)
Construct an instance.
|
QueryProtocol(MongoNamespace namespace,
int skip,
int limit,
int batchSize,
BsonDocument queryDocument,
BsonDocument fields,
Decoder<T> resultDecoder) |
QueryResult(MongoNamespace namespace,
java.util.List<T> results,
long cursorId,
ServerAddress serverAddress)
Construct an instance.
|
QueryResult(MongoNamespace namespace,
ReplyMessage<T> replyMessage,
ServerAddress address)
Construct an instance.
|
UpdateCommandMessage(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
MessageSettings settings,
java.util.List<UpdateRequest> updates)
Construct an instance.
|
UpdateCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates)
Construct an instance.
|
UpdateProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Construct an instance.
|
WriteCommandProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation)
Construct an instance.
|
WriteProtocol(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern)
Construct a new instance.
|
Modifier and Type | Field and Description |
---|---|
private MongoNamespace |
BaseWriteOperation.namespace |
private MongoNamespace |
FindAndDeleteOperation.namespace |
private MongoNamespace |
MapReduceToCollectionOperation.namespace |
private MongoNamespace |
FindAndReplaceOperation.namespace |
private MongoNamespace |
ParallelCollectionScanOperation.namespace |
private MongoNamespace |
CreateIndexesOperation.namespace |
private MongoNamespace |
QueryBatchCursor.namespace |
private MongoNamespace |
DropCollectionOperation.namespace |
private MongoNamespace |
DropIndexOperation.namespace |
private MongoNamespace |
AsyncQueryBatchCursor.namespace |
private MongoNamespace |
ListIndexesOperation.namespace |
private MongoNamespace |
DistinctOperation.namespace |
private MongoNamespace |
AggregateOperation.namespace |
private MongoNamespace |
AggregateExplainOperation.namespace |
private MongoNamespace |
MapReduceWithInlineResultsOperation.namespace |
private MongoNamespace |
FindAndUpdateOperation.namespace |
private MongoNamespace |
FindOperation.namespace |
private MongoNamespace |
MixedBulkWriteOperation.namespace |
private MongoNamespace |
CountOperation.namespace |
private MongoNamespace |
GroupOperation.namespace |
private MongoNamespace |
AggregateToCollectionOperation.namespace |
private MongoNamespace |
RenameCollectionOperation.newNamespace |
private MongoNamespace |
RenameCollectionOperation.originalNamespace |
private MongoNamespace |
CreateIndexesOperation.systemIndexes |
Modifier and Type | Method and Description |
---|---|
private MongoNamespace |
ListCollectionsOperation.createNamespace() |
private MongoNamespace |
ListIndexesOperation.getIndexNamespace() |
MongoNamespace |
BaseWriteOperation.getNamespace()
Gets the namespace of the collection to write to.
|
MongoNamespace |
FindAndDeleteOperation.getNamespace()
Gets the namespace.
|
MongoNamespace |
MapReduceToCollectionOperation.getNamespace()
Gets the namespace.
|
MongoNamespace |
FindAndReplaceOperation.getNamespace()
Gets the namespace.
|
private MongoNamespace |
ListCollectionsOperation.getNamespace() |
private MongoNamespace |
UpdateUserOperation.getNamespace() |
private MongoNamespace |
DropUserOperation.getNamespace() |
MongoNamespace |
MapReduceWithInlineResultsOperation.getNamespace()
Gets the namespace.
|
MongoNamespace |
FindAndUpdateOperation.getNamespace()
Gets the namespace.
|
MongoNamespace |
FindOperation.getNamespace()
Gets the namespace.
|
MongoNamespace |
MixedBulkWriteOperation.getNamespace()
Gets the namespace of the collection to write to.
|
private MongoNamespace |
CreateUserOperation.getNamespace() |
MongoNamespace |
GroupOperation.getNamespace()
Gets the namespace.
|
Modifier and Type | Method and Description |
---|---|
(package private) static <T> AsyncBatchCursor<T> |
OperationHelper.createEmptyAsyncBatchCursor(MongoNamespace namespace,
Decoder<T> decoder,
ServerAddress serverAddress,
int batchSize) |
(package private) static <T> QueryBatchCursor<T> |
OperationHelper.createEmptyBatchCursor(MongoNamespace namespace,
Decoder<T> decoder,
ServerAddress serverAddress,
int batchSize) |
Constructor and Description |
---|
AggregateExplainOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline)
Construct a new instance.
|
AggregateOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline,
Decoder<T> decoder)
Construct a new instance.
|
AggregateToCollectionOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline)
|
AggregateToCollectionOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline,
WriteConcern writeConcern)
Construct a new instance.
|
BaseWriteOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern)
Construct an instance
|
CountOperation(MongoNamespace namespace)
Construct a new instance.
|
CreateIndexesOperation(MongoNamespace namespace,
java.util.List<IndexRequest> requests)
|
CreateIndexesOperation(MongoNamespace namespace,
java.util.List<IndexRequest> requests,
WriteConcern writeConcern)
Construct a new instance.
|
DeleteOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deleteRequests)
Construct an instance.
|
DistinctOperation(MongoNamespace namespace,
java.lang.String fieldName,
Decoder<T> decoder)
Construct an instance.
|
DropCollectionOperation(MongoNamespace namespace)
|
DropCollectionOperation(MongoNamespace namespace,
WriteConcern writeConcern)
Construct a new instance.
|
DropIndexOperation(MongoNamespace namespace,
BsonDocument keys)
|
DropIndexOperation(MongoNamespace namespace,
BsonDocument keys,
WriteConcern writeConcern)
Construct a new instance.
|
DropIndexOperation(MongoNamespace namespace,
java.lang.String indexName)
Deprecated.
|
DropIndexOperation(MongoNamespace namespace,
java.lang.String indexName,
WriteConcern writeConcern)
Construct a new instance.
|
FindAndDeleteOperation(MongoNamespace namespace,
Decoder<T> decoder)
Deprecated.
|
FindAndDeleteOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder)
Construct a new instance.
|
FindAndReplaceOperation(MongoNamespace namespace,
Decoder<T> decoder,
BsonDocument replacement)
|
FindAndReplaceOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument replacement)
Construct a new instance.
|
FindAndUpdateOperation(MongoNamespace namespace,
Decoder<T> decoder,
BsonDocument update)
|
FindAndUpdateOperation(MongoNamespace namespace,
WriteConcern writeConcern,
Decoder<T> decoder,
BsonDocument update)
Construct a new instance.
|
FindOperation(MongoNamespace namespace,
Decoder<T> decoder)
Construct a new instance.
|
GroupOperation(MongoNamespace namespace,
BsonJavaScript reduceFunction,
BsonDocument initial,
Decoder<T> decoder)
Create an operation that will perform a Group on a given collection.
|
InsertOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> insertRequests)
Construct an instance.
|
ListIndexesOperation(MongoNamespace namespace,
Decoder<T> decoder)
Construct a new instance.
|
MapReduceToCollectionOperation(MongoNamespace namespace,
BsonJavaScript mapFunction,
BsonJavaScript reduceFunction,
java.lang.String collectionName)
Construct a MapReduceOperation with all the criteria it needs to execute
|
MapReduceToCollectionOperation(MongoNamespace namespace,
BsonJavaScript mapFunction,
BsonJavaScript reduceFunction,
java.lang.String collectionName,
WriteConcern writeConcern)
Construct a MapReduceOperation with all the criteria it needs to execute
|
MapReduceWithInlineResultsOperation(MongoNamespace namespace,
BsonJavaScript mapFunction,
BsonJavaScript reduceFunction,
Decoder<T> decoder)
Construct a MapReduceOperation with all the criteria it needs to execute.
|
MixedBulkWriteOperation(MongoNamespace namespace,
java.util.List<? extends WriteRequest> writeRequests,
boolean ordered,
WriteConcern writeConcern)
Construct a new instance.
|
ParallelCollectionScanOperation(MongoNamespace namespace,
int numCursors,
Decoder<T> decoder)
Construct a new instance.
|
RenameCollectionOperation(MongoNamespace originalNamespace,
MongoNamespace newNamespace)
|
RenameCollectionOperation(MongoNamespace originalNamespace,
MongoNamespace newNamespace,
WriteConcern writeConcern) |
UpdateOperation(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates)
Construct an instance.
|