Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.async.client.gridfs |
Contains the classes for supporting MongoDB's specification for storing very large files, GridFS.
|
com.mongodb.client |
This package contains classes for the new client api for MongoDatabase and MongoCollection
|
com.mongodb.client.gridfs |
This package contains the new GridFS implementation
|
com.mongodb.internal.session | |
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Field and Description |
---|---|
private ClientSession |
MongoIterableImpl.clientSession |
private ClientSession |
ClientSessionBinding.session |
Modifier and Type | Method and Description |
---|---|
(package private) ClientSession |
Mongo.createClientSession(ClientSessionOptions options) |
(package private) ClientSession |
MongoIterableImpl.getClientSession() |
ClientSession |
MongoClient.startSession(ClientSessionOptions options)
Creates a client session.
|
Modifier and Type | Method and Description |
---|---|
AggregateIterable<TDocument> |
MongoCollectionImpl.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline) |
<TResult> AggregateIterable<TResult> |
MongoCollectionImpl.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
BulkWriteResult |
MongoCollectionImpl.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests) |
BulkWriteResult |
MongoCollectionImpl.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options) |
long |
MongoCollectionImpl.count(ClientSession clientSession) |
long |
MongoCollectionImpl.count(ClientSession clientSession,
Bson filter) |
long |
MongoCollectionImpl.count(ClientSession clientSession,
Bson filter,
CountOptions options) |
private <TResult> AggregateIterable<TResult> |
MongoCollectionImpl.createAggregateIterable(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
private <TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.createChangeStreamIterable(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
void |
MongoDatabaseImpl.createCollection(ClientSession clientSession,
java.lang.String collectionName) |
void |
MongoDatabaseImpl.createCollection(ClientSession clientSession,
java.lang.String collectionName,
CreateCollectionOptions createCollectionOptions) |
private <TResult> DistinctIterable<TResult> |
MongoCollectionImpl.createDistinctIterable(ClientSession clientSession,
java.lang.String fieldName,
Bson filter,
java.lang.Class<TResult> resultClass) |
private <TResult> FindIterable<TResult> |
MongoCollectionImpl.createFindIterable(ClientSession clientSession,
Bson filter,
java.lang.Class<TResult> resultClass) |
java.lang.String |
MongoCollectionImpl.createIndex(ClientSession clientSession,
Bson keys) |
java.lang.String |
MongoCollectionImpl.createIndex(ClientSession clientSession,
Bson keys,
IndexOptions indexOptions) |
java.util.List<java.lang.String> |
MongoCollectionImpl.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes) |
java.util.List<java.lang.String> |
MongoCollectionImpl.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
CreateIndexOptions createIndexOptions) |
private MongoIterable<java.lang.String> |
MongoDatabaseImpl.createListCollectionNamesIterable(ClientSession clientSession) |
private <TResult> ListCollectionsIterable<TResult> |
MongoDatabaseImpl.createListCollectionsIterable(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
private MongoIterable<java.lang.String> |
MongoClient.createListDatabaseNamesIterable(ClientSession clientSession) |
private <T> ListDatabasesIterable<T> |
MongoClient.createListDatabasesIterable(ClientSession clientSession,
java.lang.Class<T> clazz) |
private <TResult> ListIndexesIterable<TResult> |
MongoCollectionImpl.createListIndexesIterable(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
private <TResult> MapReduceIterable<TResult> |
MongoCollectionImpl.createMapReduceIterable(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction,
java.lang.Class<TResult> resultClass) |
void |
MongoDatabaseImpl.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline) |
void |
MongoDatabaseImpl.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions) |
DeleteResult |
MongoCollectionImpl.deleteMany(ClientSession clientSession,
Bson filter) |
DeleteResult |
MongoCollectionImpl.deleteMany(ClientSession clientSession,
Bson filter,
DeleteOptions options) |
DeleteResult |
MongoCollectionImpl.deleteOne(ClientSession clientSession,
Bson filter) |
DeleteResult |
MongoCollectionImpl.deleteOne(ClientSession clientSession,
Bson filter,
DeleteOptions options) |
<TResult> DistinctIterable<TResult> |
MongoCollectionImpl.distinct(ClientSession clientSession,
java.lang.String fieldName,
Bson filter,
java.lang.Class<TResult> resultClass) |
<TResult> DistinctIterable<TResult> |
MongoCollectionImpl.distinct(ClientSession clientSession,
java.lang.String fieldName,
java.lang.Class<TResult> resultClass) |
void |
MongoDatabaseImpl.drop(ClientSession clientSession) |
void |
MongoCollectionImpl.drop(ClientSession clientSession) |
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
Bson keys) |
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
Bson keys,
DropIndexOptions dropIndexOptions) |
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
java.lang.String indexName) |
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
java.lang.String indexName,
DropIndexOptions dropIndexOptions) |
void |
MongoCollectionImpl.dropIndexes(ClientSession clientSession) |
void |
MongoCollectionImpl.dropIndexes(ClientSession clientSession,
DropIndexOptions dropIndexOptions) |
<T> T |
OperationExecutor.execute(ReadOperation<T> operation,
ReadPreference readPreference,
ClientSession session)
Execute the read operation with the given read preference.
|
<T> T |
OperationExecutor.execute(WriteOperation<T> operation,
ClientSession session)
Execute the write operation.
|
private BulkWriteResult |
MongoCollectionImpl.executeBulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options) |
private <TResult> TResult |
MongoDatabaseImpl.executeCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass) |
private long |
MongoCollectionImpl.executeCount(ClientSession clientSession,
Bson filter,
CountOptions options) |
private void |
MongoDatabaseImpl.executeCreateCollection(ClientSession clientSession,
java.lang.String collectionName,
CreateCollectionOptions createCollectionOptions) |
private java.util.List<java.lang.String> |
MongoCollectionImpl.executeCreateIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
CreateIndexOptions createIndexOptions) |
private void |
MongoDatabaseImpl.executeCreateView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions) |
private DeleteResult |
MongoCollectionImpl.executeDelete(ClientSession clientSession,
Bson filter,
DeleteOptions deleteOptions,
boolean multi) |
private void |
MongoDatabaseImpl.executeDrop(ClientSession clientSession) |
private void |
MongoCollectionImpl.executeDrop(ClientSession clientSession) |
private void |
MongoCollectionImpl.executeDropIndex(ClientSession clientSession,
Bson keys,
DropIndexOptions dropIndexOptions) |
private void |
MongoCollectionImpl.executeDropIndex(ClientSession clientSession,
java.lang.String indexName,
DropIndexOptions dropIndexOptions) |
private TDocument |
MongoCollectionImpl.executeFindOneAndDelete(ClientSession clientSession,
Bson filter,
FindOneAndDeleteOptions options) |
private TDocument |
MongoCollectionImpl.executeFindOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options) |
private TDocument |
MongoCollectionImpl.executeFindOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
FindOneAndUpdateOptions options) |
private void |
MongoCollectionImpl.executeInsertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
InsertManyOptions options) |
private void |
MongoCollectionImpl.executeInsertOne(ClientSession clientSession,
TDocument document,
InsertOneOptions options) |
private void |
MongoCollectionImpl.executeRenameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
RenameCollectionOptions renameCollectionOptions) |
private UpdateResult |
MongoCollectionImpl.executeReplaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
UpdateOptions updateOptions) |
private BulkWriteResult |
MongoCollectionImpl.executeSingleWriteRequest(ClientSession clientSession,
WriteRequest request,
java.lang.Boolean bypassDocumentValidation) |
private UpdateResult |
MongoCollectionImpl.executeUpdate(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions updateOptions,
boolean multi) |
FindIterable<TDocument> |
MongoCollectionImpl.find(ClientSession clientSession) |
FindIterable<TDocument> |
MongoCollectionImpl.find(ClientSession clientSession,
Bson filter) |
<TResult> FindIterable<TResult> |
MongoCollectionImpl.find(ClientSession clientSession,
Bson filter,
java.lang.Class<TResult> resultClass) |
<TResult> FindIterable<TResult> |
MongoCollectionImpl.find(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
TDocument |
MongoCollectionImpl.findOneAndDelete(ClientSession clientSession,
Bson filter) |
TDocument |
MongoCollectionImpl.findOneAndDelete(ClientSession clientSession,
Bson filter,
FindOneAndDeleteOptions options) |
TDocument |
MongoCollectionImpl.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement) |
TDocument |
MongoCollectionImpl.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options) |
TDocument |
MongoCollectionImpl.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update) |
TDocument |
MongoCollectionImpl.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
FindOneAndUpdateOptions options) |
void |
MongoCollectionImpl.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents) |
void |
MongoCollectionImpl.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
InsertManyOptions options) |
void |
MongoCollectionImpl.insertOne(ClientSession clientSession,
TDocument document) |
void |
MongoCollectionImpl.insertOne(ClientSession clientSession,
TDocument document,
InsertOneOptions options) |
MongoIterable<java.lang.String> |
MongoDatabaseImpl.listCollectionNames(ClientSession clientSession) |
ListCollectionsIterable<Document> |
MongoDatabaseImpl.listCollections(ClientSession clientSession) |
<TResult> ListCollectionsIterable<TResult> |
MongoDatabaseImpl.listCollections(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
MongoIterable<java.lang.String> |
MongoClient.listDatabaseNames(ClientSession clientSession)
Get a list of the database names
|
ListDatabasesIterable<Document> |
MongoClient.listDatabases(ClientSession clientSession)
Gets the list of databases
|
<T> ListDatabasesIterable<T> |
MongoClient.listDatabases(ClientSession clientSession,
java.lang.Class<T> clazz)
Gets the list of databases
|
ListIndexesIterable<Document> |
MongoCollectionImpl.listIndexes(ClientSession clientSession) |
<TResult> ListIndexesIterable<TResult> |
MongoCollectionImpl.listIndexes(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
MapReduceIterable<TDocument> |
MongoCollectionImpl.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
<TResult> MapReduceIterable<TResult> |
MongoCollectionImpl.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction,
java.lang.Class<TResult> resultClass) |
void |
MongoCollectionImpl.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace) |
void |
MongoCollectionImpl.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
RenameCollectionOptions renameCollectionOptions) |
UpdateResult |
MongoCollectionImpl.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement) |
UpdateResult |
MongoCollectionImpl.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
UpdateOptions updateOptions) |
Document |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command) |
<TResult> TResult |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command,
java.lang.Class<TResult> resultClass) |
Document |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference) |
<TResult> TResult |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass) |
UpdateResult |
MongoCollectionImpl.updateMany(ClientSession clientSession,
Bson filter,
Bson update) |
UpdateResult |
MongoCollectionImpl.updateMany(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions updateOptions) |
UpdateResult |
MongoCollectionImpl.updateOne(ClientSession clientSession,
Bson filter,
Bson update) |
UpdateResult |
MongoCollectionImpl.updateOne(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions updateOptions) |
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch(ClientSession clientSession) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
Constructor and Description |
---|
AggregateIterableImpl(ClientSession clientSession,
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) |
ChangeStreamIterableImpl(ClientSession clientSession,
MongoNamespace namespace,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
OperationExecutor executor,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
ClientSessionBinding(ClientSession session,
boolean ownsSession,
ReadWriteBinding wrapped) |
DistinctIterableImpl(ClientSession clientSession,
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(ClientSession clientSession,
MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
OperationExecutor executor,
Bson filter,
FindOptions findOptions) |
ListCollectionsIterableImpl(ClientSession clientSession,
java.lang.String databaseName,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
OperationExecutor executor) |
ListDatabasesIterableImpl(ClientSession clientSession,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
OperationExecutor executor) |
ListIndexesIterableImpl(ClientSession clientSession,
MongoNamespace namespace,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
OperationExecutor executor) |
MapReduceIterableImpl(ClientSession clientSession,
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) |
MongoIterableImpl(ClientSession clientSession,
OperationExecutor executor,
ReadConcern readConcern,
ReadPreference readPreference) |
Modifier and Type | Field and Description |
---|---|
private ClientSession |
MongoIterableImpl.clientSession |
private ClientSession |
ClientSessionBinding.session |
Modifier and Type | Method and Description |
---|---|
ClientSession |
MongoIterableImpl.getClientSession() |
Modifier and Type | Method and Description |
---|---|
AggregateIterable<TDocument> |
MongoCollection.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline)
Aggregates documents according to the specified aggregation pipeline.
|
AggregateIterable<TDocument> |
MongoCollectionImpl.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline) |
<TResult> AggregateIterable<TResult> |
MongoCollection.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass)
Aggregates documents according to the specified aggregation pipeline.
|
<TResult> AggregateIterable<TResult> |
MongoCollectionImpl.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
void |
MongoCollection.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollectionImpl.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback) |
void |
MongoCollection.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollectionImpl.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback) |
void |
MongoCollection.count(ClientSession clientSession,
Bson filter,
CountOptions options,
SingleResultCallback<java.lang.Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollectionImpl.count(ClientSession clientSession,
Bson filter,
CountOptions options,
SingleResultCallback<java.lang.Long> callback) |
void |
MongoCollection.count(ClientSession clientSession,
Bson filter,
SingleResultCallback<java.lang.Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollectionImpl.count(ClientSession clientSession,
Bson filter,
SingleResultCallback<java.lang.Long> callback) |
void |
MongoCollection.count(ClientSession clientSession,
SingleResultCallback<java.lang.Long> callback)
Counts the number of documents in the collection.
|
void |
MongoCollectionImpl.count(ClientSession clientSession,
SingleResultCallback<java.lang.Long> callback) |
private <TResult> AggregateIterable<TResult> |
MongoCollectionImpl.createAggregateIterable(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
private <TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.createChangeStreamIterable(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
void |
MongoDatabaseImpl.createCollection(ClientSession clientSession,
java.lang.String collectionName,
CreateCollectionOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabase.createCollection(ClientSession clientSession,
java.lang.String collectionName,
CreateCollectionOptions options,
SingleResultCallback<java.lang.Void> callback)
Create a new collection with the selected options
|
void |
MongoDatabaseImpl.createCollection(ClientSession clientSession,
java.lang.String collectionName,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabase.createCollection(ClientSession clientSession,
java.lang.String collectionName,
SingleResultCallback<java.lang.Void> callback)
Create a new collection with the given name.
|
private <TResult> DistinctIterable<TResult> |
MongoCollectionImpl.createDistinctIterable(ClientSession clientSession,
java.lang.String fieldName,
Bson filter,
java.lang.Class<TResult> resultClass) |
private <TResult> FindIterable<TResult> |
MongoCollectionImpl.createFindIterable(ClientSession clientSession,
Bson filter,
java.lang.Class<TResult> resultClass) |
void |
MongoCollection.createIndex(ClientSession clientSession,
Bson key,
IndexOptions options,
SingleResultCallback<java.lang.String> callback)
Creates an index.
|
void |
MongoCollectionImpl.createIndex(ClientSession clientSession,
Bson key,
IndexOptions indexOptions,
SingleResultCallback<java.lang.String> callback) |
void |
MongoCollection.createIndex(ClientSession clientSession,
Bson key,
SingleResultCallback<java.lang.String> callback)
Creates an index.
|
void |
MongoCollectionImpl.createIndex(ClientSession clientSession,
Bson key,
SingleResultCallback<java.lang.String> callback) |
void |
MongoCollection.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
CreateIndexOptions createIndexOptions,
SingleResultCallback<java.util.List<java.lang.String>> callback)
Create multiple indexes.
|
void |
MongoCollectionImpl.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
CreateIndexOptions createIndexOptions,
SingleResultCallback<java.util.List<java.lang.String>> callback) |
void |
MongoCollection.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
SingleResultCallback<java.util.List<java.lang.String>> callback)
Create multiple indexes.
|
void |
MongoCollectionImpl.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
SingleResultCallback<java.util.List<java.lang.String>> callback) |
private MongoIterable<java.lang.String> |
MongoDatabaseImpl.createListCollectionNamesIterable(ClientSession clientSession) |
private <TResult> ListCollectionsIterable<TResult> |
MongoDatabaseImpl.createListCollectionsIterable(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
private MongoIterable<java.lang.String> |
MongoClientImpl.createListDatabaseNamesIterable(ClientSession clientSession) |
private <T> ListDatabasesIterable<T> |
MongoClientImpl.createListDatabasesIterable(ClientSession clientSession,
java.lang.Class<T> clazz) |
private <TResult> ListIndexesIterable<TResult> |
MongoCollectionImpl.createListIndexesIterable(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
private <TResult> MapReduceIterable<TResult> |
MongoCollectionImpl.createMapReduceIterable(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction,
java.lang.Class<TResult> resultClass) |
void |
MongoDatabaseImpl.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabase.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions,
SingleResultCallback<java.lang.Void> callback)
Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
|
void |
MongoDatabaseImpl.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabase.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
SingleResultCallback<java.lang.Void> callback)
Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
|
void |
MongoCollection.deleteMany(ClientSession clientSession,
Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback)
Removes all documents from the collection that match the given query filter.
|
void |
MongoCollectionImpl.deleteMany(ClientSession clientSession,
Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.deleteMany(ClientSession clientSession,
Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes all documents from the collection that match the given query filter.
|
void |
MongoCollectionImpl.deleteMany(ClientSession clientSession,
Bson filter,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.deleteOne(ClientSession clientSession,
Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback)
Removes at most one document from the collection that matches the given filter.
|
void |
MongoCollectionImpl.deleteOne(ClientSession clientSession,
Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.deleteOne(ClientSession clientSession,
Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes at most one document from the collection that matches the given filter.
|
void |
MongoCollectionImpl.deleteOne(ClientSession clientSession,
Bson filter,
SingleResultCallback<DeleteResult> callback) |
<TResult> DistinctIterable<TResult> |
MongoCollection.distinct(ClientSession clientSession,
java.lang.String fieldName,
Bson filter,
java.lang.Class<TResult> resultClass)
Gets the distinct values of the specified field name.
|
<TResult> DistinctIterable<TResult> |
MongoCollectionImpl.distinct(ClientSession clientSession,
java.lang.String fieldName,
Bson filter,
java.lang.Class<TResult> resultClass) |
<TResult> DistinctIterable<TResult> |
MongoCollection.distinct(ClientSession clientSession,
java.lang.String fieldName,
java.lang.Class<TResult> resultClass)
Gets the distinct values of the specified field name.
|
<TResult> DistinctIterable<TResult> |
MongoCollectionImpl.distinct(ClientSession clientSession,
java.lang.String fieldName,
java.lang.Class<TResult> resultClass) |
void |
MongoCollection.drop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback)
Drops this collection from the Database.
|
void |
MongoDatabaseImpl.drop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollectionImpl.drop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabase.drop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback)
Drops this database.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
Bson keys,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback)
Drops the index given the keys used to create it.
|
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
Bson keys,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndex(ClientSession clientSession,
Bson keys,
SingleResultCallback<java.lang.Void> callback)
Drops the index given the keys used to create it.
|
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
Bson keys,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndex(ClientSession clientSession,
java.lang.String indexName,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback)
Drops the index given its name.
|
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
java.lang.String indexName,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndex(ClientSession clientSession,
java.lang.String indexName,
SingleResultCallback<java.lang.Void> callback)
Drops the index given its name.
|
void |
MongoCollectionImpl.dropIndex(ClientSession clientSession,
java.lang.String indexName,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndexes(ClientSession clientSession,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollectionImpl.dropIndexes(ClientSession clientSession,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndexes(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollectionImpl.dropIndexes(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback) |
<T> void |
AsyncOperationExecutorImpl.execute(AsyncReadOperation<T> operation,
ReadPreference readPreference,
ClientSession session,
SingleResultCallback<T> callback) |
<T> void |
AsyncOperationExecutorImpl.execute(AsyncWriteOperation<T> operation,
ClientSession session,
SingleResultCallback<T> callback) |
private void |
MongoCollectionImpl.executeBulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback) |
private <TResult> void |
MongoDatabaseImpl.executeCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback) |
private void |
MongoCollectionImpl.executeCount(ClientSession clientSession,
Bson filter,
CountOptions options,
SingleResultCallback<java.lang.Long> callback) |
private void |
MongoDatabaseImpl.executeCreateCollection(ClientSession clientSession,
java.lang.String collectionName,
CreateCollectionOptions options,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeCreateIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
CreateIndexOptions createIndexOptions,
SingleResultCallback<java.util.List<java.lang.String>> callback) |
private void |
MongoDatabaseImpl.executeCreateView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeDelete(ClientSession clientSession,
Bson filter,
DeleteOptions options,
boolean multi,
SingleResultCallback<DeleteResult> callback) |
private void |
MongoDatabaseImpl.executeDrop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeDrop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeDropIndex(ClientSession clientSession,
Bson keys,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeDropIndex(ClientSession clientSession,
java.lang.String indexName,
DropIndexOptions dropIndexOptions,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeFindOneAndDelete(ClientSession clientSession,
Bson filter,
FindOneAndDeleteOptions options,
SingleResultCallback<TDocument> callback) |
private void |
MongoCollectionImpl.executeFindOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options,
SingleResultCallback<TDocument> callback) |
private void |
MongoCollectionImpl.executeFindOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
FindOneAndUpdateOptions options,
SingleResultCallback<TDocument> callback) |
private void |
MongoCollectionImpl.executeInsertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
InsertManyOptions options,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeInsertOne(ClientSession clientSession,
TDocument document,
InsertOneOptions options,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeRenameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeReplaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback) |
private void |
MongoCollectionImpl.executeSingleWriteRequest(ClientSession clientSession,
WriteRequest request,
java.lang.Boolean bypassDocumentValidation,
SingleResultCallback<BulkWriteResult> callback) |
private void |
MongoCollectionImpl.executeUpdate(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions options,
boolean multi,
SingleResultCallback<UpdateResult> callback) |
FindIterable<TDocument> |
MongoCollection.find(ClientSession clientSession)
Finds all documents in the collection.
|
FindIterable<TDocument> |
MongoCollectionImpl.find(ClientSession clientSession) |
FindIterable<TDocument> |
MongoCollection.find(ClientSession clientSession,
Bson filter)
Finds all documents in the collection.
|
FindIterable<TDocument> |
MongoCollectionImpl.find(ClientSession clientSession,
Bson filter) |
<TResult> FindIterable<TResult> |
MongoCollection.find(ClientSession clientSession,
Bson filter,
java.lang.Class<TResult> resultClass)
Finds all documents in the collection.
|
<TResult> FindIterable<TResult> |
MongoCollectionImpl.find(ClientSession clientSession,
Bson filter,
java.lang.Class<TResult> resultClass) |
<TResult> FindIterable<TResult> |
MongoCollection.find(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Finds all documents in the collection.
|
<TResult> FindIterable<TResult> |
MongoCollectionImpl.find(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
void |
MongoCollection.findOneAndDelete(ClientSession clientSession,
Bson filter,
FindOneAndDeleteOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollectionImpl.findOneAndDelete(ClientSession clientSession,
Bson filter,
FindOneAndDeleteOptions options,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndDelete(ClientSession clientSession,
Bson filter,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollectionImpl.findOneAndDelete(ClientSession clientSession,
Bson filter,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollectionImpl.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollectionImpl.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
FindOneAndUpdateOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoCollectionImpl.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
FindOneAndUpdateOptions options,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoCollectionImpl.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<TDocument> callback) |
private AsyncReadWriteBinding |
AsyncOperationExecutorImpl.getReadWriteBinding(ReadPreference readPreference,
ClientSession session,
boolean ownsSession) |
void |
MongoCollection.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
InsertManyOptions options,
SingleResultCallback<java.lang.Void> callback)
Inserts one or more documents.
|
void |
MongoCollectionImpl.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
InsertManyOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
SingleResultCallback<java.lang.Void> callback)
Inserts one or more documents.
|
void |
MongoCollectionImpl.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.insertOne(ClientSession clientSession,
TDocument document,
InsertOneOptions options,
SingleResultCallback<java.lang.Void> callback)
Inserts the provided document.
|
void |
MongoCollectionImpl.insertOne(ClientSession clientSession,
TDocument document,
InsertOneOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.insertOne(ClientSession clientSession,
TDocument document,
SingleResultCallback<java.lang.Void> callback)
Inserts the provided document.
|
void |
MongoCollectionImpl.insertOne(ClientSession clientSession,
TDocument document,
SingleResultCallback<java.lang.Void> callback) |
MongoIterable<java.lang.String> |
MongoDatabaseImpl.listCollectionNames(ClientSession clientSession) |
MongoIterable<java.lang.String> |
MongoDatabase.listCollectionNames(ClientSession clientSession)
Gets the names of all the collections in this database.
|
ListCollectionsIterable<Document> |
MongoDatabaseImpl.listCollections(ClientSession clientSession) |
ListCollectionsIterable<Document> |
MongoDatabase.listCollections(ClientSession clientSession)
Finds all the collections in this database.
|
<TResult> ListCollectionsIterable<TResult> |
MongoDatabaseImpl.listCollections(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
<TResult> ListCollectionsIterable<TResult> |
MongoDatabase.listCollections(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Finds all the collections in this database.
|
MongoIterable<java.lang.String> |
MongoClient.listDatabaseNames(ClientSession clientSession)
Get a list of the database names
|
MongoIterable<java.lang.String> |
MongoClientImpl.listDatabaseNames(ClientSession clientSession) |
ListDatabasesIterable<Document> |
MongoClient.listDatabases(ClientSession clientSession)
Gets the list of databases
|
ListDatabasesIterable<Document> |
MongoClientImpl.listDatabases(ClientSession clientSession) |
<TResult> ListDatabasesIterable<TResult> |
MongoClient.listDatabases(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Gets the list of databases
|
<TResult> ListDatabasesIterable<TResult> |
MongoClientImpl.listDatabases(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
ListIndexesIterable<Document> |
MongoCollection.listIndexes(ClientSession clientSession)
Get all the indexes in this collection.
|
ListIndexesIterable<Document> |
MongoCollectionImpl.listIndexes(ClientSession clientSession) |
<TResult> ListIndexesIterable<TResult> |
MongoCollection.listIndexes(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Get all the indexes in this collection.
|
<TResult> ListIndexesIterable<TResult> |
MongoCollectionImpl.listIndexes(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
MapReduceIterable<TDocument> |
MongoCollection.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction)
Aggregates documents according to the specified map-reduce function.
|
MapReduceIterable<TDocument> |
MongoCollectionImpl.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
<TResult> MapReduceIterable<TResult> |
MongoCollection.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction,
java.lang.Class<TResult> resultClass)
Aggregates documents according to the specified map-reduce function.
|
<TResult> MapReduceIterable<TResult> |
MongoCollectionImpl.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction,
java.lang.Class<TResult> resultClass) |
void |
MongoCollection.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<java.lang.Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollectionImpl.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
SingleResultCallback<java.lang.Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollectionImpl.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
SingleResultCallback<UpdateResult> callback)
Replace a document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Replace a document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback) |
<TResult> void |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback) |
<TResult> void |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback)
Executes the given command in the context of the current database with a read preference of
ReadPreference.primary() . |
<TResult> void |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback) |
<TResult> void |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback)
Executes the given command in the context of the current database with the given read preference.
|
void |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
SingleResultCallback<Document> callback) |
void |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
SingleResultCallback<Document> callback)
Executes the given command in the context of the current database with the given read preference.
|
void |
MongoDatabaseImpl.runCommand(ClientSession clientSession,
Bson command,
SingleResultCallback<Document> callback) |
void |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
SingleResultCallback<Document> callback)
Executes the given command in the context of the current database with a read preference of
ReadPreference.primary() . |
void |
MongoCollection.updateMany(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback)
Update all documents in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateMany(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.updateMany(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Update all documents in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateMany(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.updateOne(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback)
Update a single document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateOne(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.updateOne(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Update a single document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateOne(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback) |
ChangeStreamIterable<TDocument> |
MongoCollection.watch(ClientSession clientSession)
Creates a change stream for this collection.
|
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch(ClientSession clientSession) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
ChangeStreamIterable<TDocument> |
MongoCollection.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline)
Creates a change stream for this collection.
|
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
(package private) void |
ClientSessionHelper.withClientSession(ClientSession clientSessionFromOperation,
SingleResultCallback<ClientSession> callback) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
ClientSessionHelper.createClientSession(ClientSessionOptions options,
SingleResultCallback<ClientSession> callback) |
void |
MongoClient.startSession(ClientSessionOptions options,
SingleResultCallback<ClientSession> callback)
Creates a client session.
|
void |
MongoClientImpl.startSession(ClientSessionOptions options,
SingleResultCallback<ClientSession> callback) |
(package private) void |
ClientSessionHelper.withClientSession(ClientSession clientSessionFromOperation,
SingleResultCallback<ClientSession> callback) |
Constructor and Description |
---|
AggregateIterableImpl(ClientSession clientSession,
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) |
ChangeStreamIterableImpl(ClientSession clientSession,
MongoNamespace namespace,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
AsyncOperationExecutor executor,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
ClientSessionBinding(ClientSession session,
boolean ownsSession,
AsyncReadWriteBinding wrapped) |
DistinctIterableImpl(ClientSession clientSession,
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(ClientSession clientSession,
MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
AsyncOperationExecutor executor,
Bson filter,
FindOptions findOptions) |
ListCollectionsIterableImpl(ClientSession clientSession,
java.lang.String databaseName,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
ListDatabasesIterableImpl(ClientSession clientSession,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
ListIndexesIterableImpl(ClientSession clientSession,
MongoNamespace namespace,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
MapReduceIterableImpl(ClientSession clientSession,
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) |
MongoIterableImpl(ClientSession clientSession,
AsyncOperationExecutor executor,
ReadConcern readConcern,
ReadPreference readPreference) |
Modifier and Type | Field and Description |
---|---|
private ClientSession |
GridFSUploadStreamImpl.clientSession |
private ClientSession |
GridFSDownloadStreamImpl.clientSession |
private ClientSession |
GridFSIndexCheckImpl.clientSession |
Modifier and Type | Method and Description |
---|---|
private FindIterable<GridFSFile> |
GridFSBucketImpl.createFindIterable(ClientSession clientSession,
Bson filter) |
private GridFSDownloadStream |
GridFSBucketImpl.createGridFSDownloadStream(ClientSession clientSession,
GridFSFindIterable gridFSFindIterable) |
private GridFSFindIterable |
GridFSBucketImpl.createGridFSFindIterable(ClientSession clientSession,
Bson filter) |
private GridFSFindIterable |
GridFSBucketImpl.createGridFSFindIterable(ClientSession clientSession,
java.lang.String filename,
GridFSDownloadOptions options) |
private GridFSUploadStream |
GridFSBucketImpl.createGridFSUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
GridFSUploadOptions options) |
void |
GridFSBucketImpl.delete(ClientSession clientSession,
BsonValue id,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.delete(ClientSession clientSession,
BsonValue id,
SingleResultCallback<java.lang.Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucketImpl.delete(ClientSession clientSession,
ObjectId id,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.delete(ClientSession clientSession,
ObjectId id,
SingleResultCallback<java.lang.Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
BsonValue id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
BsonValue id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
ObjectId id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
ObjectId id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
java.lang.String filename,
AsyncOutputStream destination,
GridFSDownloadOptions options,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
java.lang.String filename,
AsyncOutputStream destination,
GridFSDownloadOptions options,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the stored file specified by
filename and by the revision in options and writes the
contents to the destination Stream. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
java.lang.String filename,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
java.lang.String filename,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the latest version of the stored file specified by
filename and writes the contents to
the destination Stream. |
void |
GridFSBucketImpl.drop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.drop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback)
Drops the data associated with this bucket from the database.
|
private void |
GridFSBucketImpl.executeDelete(ClientSession clientSession,
BsonValue id,
SingleResultCallback<java.lang.Void> callback) |
private void |
GridFSBucketImpl.executeDrop(ClientSession clientSession,
SingleResultCallback<java.lang.Void> callback) |
private void |
GridFSBucketImpl.executeRename(ClientSession clientSession,
BsonValue id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback) |
private void |
GridFSBucketImpl.executeUploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<java.lang.Void> callback) |
GridFSFindIterable |
GridFSBucketImpl.find(ClientSession clientSession) |
GridFSFindIterable |
GridFSBucket.find(ClientSession clientSession)
Finds all documents in the files collection.
|
GridFSFindIterable |
GridFSBucketImpl.find(ClientSession clientSession,
Bson filter) |
GridFSFindIterable |
GridFSBucket.find(ClientSession clientSession,
Bson filter)
Finds all documents in the collection that match the filter.
|
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
BsonValue id) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
BsonValue id)
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by
id . |
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
ObjectId id) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
ObjectId id)
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by
id . |
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
java.lang.String filename) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
java.lang.String filename)
Opens a Stream from which the application can read the contents of the latest version of the stored file specified by the
filename . |
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
java.lang.String filename,
GridFSDownloadOptions options) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
java.lang.String filename,
GridFSDownloadOptions options)
Opens a Stream from which the application can read the contents of the stored file specified by
filename and the revision
in options . |
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename)
Opens a AsyncOutputStream that the application can write the contents of the file to.
|
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
GridFSUploadOptions options) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
GridFSUploadOptions options)
Opens a AsyncOutputStream that the application can write the contents of the file to.
|
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
java.lang.String filename) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
java.lang.String filename)
Opens a AsyncOutputStream that the application can write the contents of the file to.
|
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
java.lang.String filename,
GridFSUploadOptions options) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
java.lang.String filename,
GridFSUploadOptions options)
Opens a AsyncOutputStream that the application can write the contents of the file to.
|
void |
GridFSBucketImpl.rename(ClientSession clientSession,
BsonValue id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.rename(ClientSession clientSession,
BsonValue id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback)
Renames the stored file with the specified
id . |
void |
GridFSBucketImpl.rename(ClientSession clientSession,
ObjectId id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.rename(ClientSession clientSession,
ObjectId id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback)
Renames the stored file with the specified
id . |
void |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<java.lang.Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<java.lang.Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<ObjectId> callback) |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<ObjectId> callback) |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
Constructor and Description |
---|
GridFSDownloadStreamImpl(ClientSession clientSession,
GridFSFindIterable fileInfoIterable,
MongoCollection<Document> chunksCollection) |
GridFSIndexCheckImpl(ClientSession clientSession,
MongoCollection<GridFSFile> filesCollection,
MongoCollection<Document> chunksCollection) |
GridFSUploadStreamImpl(ClientSession clientSession,
MongoCollection<GridFSFile> filesCollection,
MongoCollection<Document> chunksCollection,
BsonValue fileId,
java.lang.String filename,
int chunkSizeBytes,
Document metadata,
GridFSIndexCheck indexCheck) |
Modifier and Type | Method and Description |
---|---|
AggregateIterable<TDocument> |
MongoCollection.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline)
Aggregates documents according to the specified aggregation pipeline.
|
<TResult> AggregateIterable<TResult> |
MongoCollection.aggregate(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass)
Aggregates documents according to the specified aggregation pipeline.
|
BulkWriteResult |
MongoCollection.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests)
Executes a mix of inserts, updates, replaces, and deletes.
|
BulkWriteResult |
MongoCollection.bulkWrite(ClientSession clientSession,
java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options)
Executes a mix of inserts, updates, replaces, and deletes.
|
long |
MongoCollection.count(ClientSession clientSession)
Counts the number of documents in the collection.
|
long |
MongoCollection.count(ClientSession clientSession,
Bson filter)
Counts the number of documents in the collection according to the given options.
|
long |
MongoCollection.count(ClientSession clientSession,
Bson filter,
CountOptions options)
Counts the number of documents in the collection according to the given options.
|
void |
MongoDatabase.createCollection(ClientSession clientSession,
java.lang.String collectionName)
Create a new collection with the given name.
|
void |
MongoDatabase.createCollection(ClientSession clientSession,
java.lang.String collectionName,
CreateCollectionOptions createCollectionOptions)
Create a new collection with the selected options
|
java.lang.String |
MongoCollection.createIndex(ClientSession clientSession,
Bson keys)
Create an index with the given keys.
|
java.lang.String |
MongoCollection.createIndex(ClientSession clientSession,
Bson keys,
IndexOptions indexOptions)
Create an index with the given keys and options.
|
java.util.List<java.lang.String> |
MongoCollection.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes)
Create multiple indexes.
|
java.util.List<java.lang.String> |
MongoCollection.createIndexes(ClientSession clientSession,
java.util.List<IndexModel> indexes,
CreateIndexOptions createIndexOptions)
Create multiple indexes.
|
void |
MongoDatabase.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline)
Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
|
void |
MongoDatabase.createView(ClientSession clientSession,
java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions)
Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
|
DeleteResult |
MongoCollection.deleteMany(ClientSession clientSession,
Bson filter)
Removes all documents from the collection that match the given query filter.
|
DeleteResult |
MongoCollection.deleteMany(ClientSession clientSession,
Bson filter,
DeleteOptions options)
Removes all documents from the collection that match the given query filter.
|
DeleteResult |
MongoCollection.deleteOne(ClientSession clientSession,
Bson filter)
Removes at most one document from the collection that matches the given filter.
|
DeleteResult |
MongoCollection.deleteOne(ClientSession clientSession,
Bson filter,
DeleteOptions options)
Removes at most one document from the collection that matches the given filter.
|
<TResult> DistinctIterable<TResult> |
MongoCollection.distinct(ClientSession clientSession,
java.lang.String fieldName,
Bson filter,
java.lang.Class<TResult> resultClass)
Gets the distinct values of the specified field name.
|
<TResult> DistinctIterable<TResult> |
MongoCollection.distinct(ClientSession clientSession,
java.lang.String fieldName,
java.lang.Class<TResult> resultClass)
Gets the distinct values of the specified field name.
|
void |
MongoCollection.drop(ClientSession clientSession)
Drops this collection from the Database.
|
void |
MongoDatabase.drop(ClientSession clientSession)
Drops this database.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
Bson keys)
Drops the index given the keys used to create it.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
Bson keys,
DropIndexOptions dropIndexOptions)
Drops the index given the keys used to create it.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
java.lang.String indexName)
Drops the index given its name.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
java.lang.String indexName,
DropIndexOptions dropIndexOptions)
Drops the index given its name.
|
void |
MongoCollection.dropIndexes(ClientSession clientSession)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollection.dropIndexes(ClientSession clientSession,
DropIndexOptions dropIndexOptions)
Drop all the indexes on this collection, except for the default on _id.
|
FindIterable<TDocument> |
MongoCollection.find(ClientSession clientSession)
Finds all documents in the collection.
|
FindIterable<TDocument> |
MongoCollection.find(ClientSession clientSession,
Bson filter)
Finds all documents in the collection.
|
<TResult> FindIterable<TResult> |
MongoCollection.find(ClientSession clientSession,
Bson filter,
java.lang.Class<TResult> resultClass)
Finds all documents in the collection.
|
<TResult> FindIterable<TResult> |
MongoCollection.find(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Finds all documents in the collection.
|
TDocument |
MongoCollection.findOneAndDelete(ClientSession clientSession,
Bson filter)
Atomically find a document and remove it.
|
TDocument |
MongoCollection.findOneAndDelete(ClientSession clientSession,
Bson filter,
FindOneAndDeleteOptions options)
Atomically find a document and remove it.
|
TDocument |
MongoCollection.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement)
Atomically find a document and replace it.
|
TDocument |
MongoCollection.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options)
Atomically find a document and replace it.
|
TDocument |
MongoCollection.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update)
Atomically find a document and update it.
|
TDocument |
MongoCollection.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
FindOneAndUpdateOptions options)
Atomically find a document and update it.
|
void |
MongoCollection.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents)
Inserts one or more documents.
|
void |
MongoCollection.insertMany(ClientSession clientSession,
java.util.List<? extends TDocument> documents,
InsertManyOptions options)
Inserts one or more documents.
|
void |
MongoCollection.insertOne(ClientSession clientSession,
TDocument document)
Inserts the provided document.
|
void |
MongoCollection.insertOne(ClientSession clientSession,
TDocument document,
InsertOneOptions options)
Inserts the provided document.
|
MongoIterable<java.lang.String> |
MongoDatabase.listCollectionNames(ClientSession clientSession)
Gets the names of all the collections in this database.
|
ListCollectionsIterable<Document> |
MongoDatabase.listCollections(ClientSession clientSession)
Finds all the collections in this database.
|
<TResult> ListCollectionsIterable<TResult> |
MongoDatabase.listCollections(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Finds all the collections in this database.
|
ListIndexesIterable<Document> |
MongoCollection.listIndexes(ClientSession clientSession)
Get all the indexes in this collection.
|
<TResult> ListIndexesIterable<TResult> |
MongoCollection.listIndexes(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Get all the indexes in this collection.
|
MapReduceIterable<TDocument> |
MongoCollection.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction)
Aggregates documents according to the specified map-reduce function.
|
<TResult> MapReduceIterable<TResult> |
MongoCollection.mapReduce(ClientSession clientSession,
java.lang.String mapFunction,
java.lang.String reduceFunction,
java.lang.Class<TResult> resultClass)
Aggregates documents according to the specified map-reduce function.
|
void |
MongoCollection.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollection.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
RenameCollectionOptions renameCollectionOptions)
Rename the collection with oldCollectionName to the newCollectionName.
|
UpdateResult |
MongoCollection.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement)
Replace a document in the collection according to the specified arguments.
|
UpdateResult |
MongoCollection.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
UpdateOptions updateOptions)
Replace a document in the collection according to the specified arguments.
|
Document |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command)
Executes the given command in the context of the current database with a read preference of
ReadPreference.primary() . |
<TResult> TResult |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
java.lang.Class<TResult> resultClass)
Executes the given command in the context of the current database with a read preference of
ReadPreference.primary() . |
Document |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference)
Executes the given command in the context of the current database with the given read preference.
|
<TResult> TResult |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass)
Executes the given command in the context of the current database with the given read preference.
|
UpdateResult |
MongoCollection.updateMany(ClientSession clientSession,
Bson filter,
Bson update)
Update all documents in the collection according to the specified arguments.
|
UpdateResult |
MongoCollection.updateMany(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions updateOptions)
Update all documents in the collection according to the specified arguments.
|
UpdateResult |
MongoCollection.updateOne(ClientSession clientSession,
Bson filter,
Bson update)
Update a single document in the collection according to the specified arguments.
|
UpdateResult |
MongoCollection.updateOne(ClientSession clientSession,
Bson filter,
Bson update,
UpdateOptions updateOptions)
Update a single document in the collection according to the specified arguments.
|
ChangeStreamIterable<TDocument> |
MongoCollection.watch(ClientSession clientSession)
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|
ChangeStreamIterable<TDocument> |
MongoCollection.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline)
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|
Modifier and Type | Field and Description |
---|---|
private ClientSession |
GridFSUploadStreamImpl.clientSession |
private ClientSession |
GridFSDownloadStreamImpl.clientSession |
Modifier and Type | Method and Description |
---|---|
private void |
GridFSBucketImpl.checkCreateIndex(ClientSession clientSession) |
private <T> boolean |
GridFSBucketImpl.collectionIsEmpty(ClientSession clientSession,
MongoCollection<T> collection) |
private FindIterable<GridFSFile> |
GridFSBucketImpl.createFindIterable(ClientSession clientSession,
Bson filter) |
private GridFSDownloadStream |
GridFSBucketImpl.createGridFSDownloadStream(ClientSession clientSession,
GridFSFile gridFSFile) |
private GridFSFindIterable |
GridFSBucketImpl.createGridFSFindIterable(ClientSession clientSession,
Bson filter) |
private GridFSUploadStream |
GridFSBucketImpl.createGridFSUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
GridFSUploadOptions options) |
private <T> void |
GridFSBucketImpl.createIndex(ClientSession clientSession,
MongoCollection<T> collection,
Document index,
IndexOptions indexOptions) |
void |
GridFSBucketImpl.delete(ClientSession clientSession,
BsonValue id) |
void |
GridFSBucket.delete(ClientSession clientSession,
BsonValue id)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucketImpl.delete(ClientSession clientSession,
ObjectId id) |
void |
GridFSBucket.delete(ClientSession clientSession,
ObjectId id)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
BsonValue id,
java.io.OutputStream destination) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
BsonValue id,
java.io.OutputStream destination)
Downloads the contents of the stored file specified by
id and writes the contents to the destination Stream. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
ObjectId id,
java.io.OutputStream destination) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
ObjectId id,
java.io.OutputStream destination)
Downloads the contents of the stored file specified by
id and writes the contents to the destination Stream. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
java.lang.String filename,
java.io.OutputStream destination) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
java.lang.String filename,
java.io.OutputStream destination)
Downloads the contents of the latest version of the stored file specified by
filename and writes the contents to
the destination Stream. |
void |
GridFSBucketImpl.downloadToStream(ClientSession clientSession,
java.lang.String filename,
java.io.OutputStream destination,
GridFSDownloadOptions options) |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
java.lang.String filename,
java.io.OutputStream destination,
GridFSDownloadOptions options)
Downloads the contents of the stored file specified by
filename and by the revision in options and writes the
contents to the destination Stream. |
void |
GridFSBucketImpl.drop(ClientSession clientSession) |
void |
GridFSBucket.drop(ClientSession clientSession)
Drops the data associated with this bucket from the database.
|
private void |
GridFSBucketImpl.executeDelete(ClientSession clientSession,
BsonValue id) |
private void |
GridFSBucketImpl.executeRename(ClientSession clientSession,
BsonValue id,
java.lang.String newFilename) |
private void |
GridFSBucketImpl.executeUploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
java.io.InputStream source,
GridFSUploadOptions options) |
GridFSFindIterable |
GridFSBucketImpl.find(ClientSession clientSession) |
GridFSFindIterable |
GridFSBucket.find(ClientSession clientSession)
Finds all documents in the files collection.
|
GridFSFindIterable |
GridFSBucketImpl.find(ClientSession clientSession,
Bson filter) |
GridFSFindIterable |
GridFSBucket.find(ClientSession clientSession,
Bson filter)
Finds all documents in the collection that match the filter.
|
private GridFSFile |
GridFSBucketImpl.getFileByName(ClientSession clientSession,
java.lang.String filename,
GridFSDownloadOptions options) |
private GridFSFile |
GridFSBucketImpl.getFileInfoById(ClientSession clientSession,
BsonValue id) |
private <T> boolean |
GridFSBucketImpl.hasIndex(ClientSession clientSession,
MongoCollection<T> collection,
Document index) |
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
BsonValue id) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
BsonValue id)
Opens a Stream from which the application can read the contents of the stored file specified by
id . |
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
ObjectId id) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
ObjectId id)
Opens a Stream from which the application can read the contents of the stored file specified by
id . |
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
java.lang.String filename) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
java.lang.String filename)
Opens a Stream from which the application can read the contents of the latest version of the stored file specified by the
filename . |
GridFSDownloadStream |
GridFSBucketImpl.openDownloadStream(ClientSession clientSession,
java.lang.String filename,
GridFSDownloadOptions options) |
GridFSDownloadStream |
GridFSBucket.openDownloadStream(ClientSession clientSession,
java.lang.String filename,
GridFSDownloadOptions options)
Opens a Stream from which the application can read the contents of the stored file specified by
filename and the revision
in options . |
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename)
Opens a Stream that the application can write the contents of the file to.
|
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
GridFSUploadOptions options) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
GridFSUploadOptions options)
Opens a Stream that the application can write the contents of the file to.
|
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
ObjectId id,
java.lang.String filename) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
ObjectId id,
java.lang.String filename)
Opens a Stream that the application can write the contents of the file to.
|
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
java.lang.String filename) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
java.lang.String filename)
Opens a Stream that the application can write the contents of the file to.
|
GridFSUploadStream |
GridFSBucketImpl.openUploadStream(ClientSession clientSession,
java.lang.String filename,
GridFSUploadOptions options) |
GridFSUploadStream |
GridFSBucket.openUploadStream(ClientSession clientSession,
java.lang.String filename,
GridFSUploadOptions options)
Opens a Stream that the application can write the contents of the file to.
|
void |
GridFSBucketImpl.rename(ClientSession clientSession,
BsonValue id,
java.lang.String newFilename) |
void |
GridFSBucket.rename(ClientSession clientSession,
BsonValue id,
java.lang.String newFilename)
Renames the stored file with the specified
id . |
void |
GridFSBucketImpl.rename(ClientSession clientSession,
ObjectId id,
java.lang.String newFilename) |
void |
GridFSBucket.rename(ClientSession clientSession,
ObjectId id,
java.lang.String newFilename)
Renames the stored file with the specified
id . |
void |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
java.io.InputStream source) |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
java.io.InputStream source)
Uploads the contents of the given
InputStream to a GridFS bucket. |
void |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
java.io.InputStream source,
GridFSUploadOptions options) |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
BsonValue id,
java.lang.String filename,
java.io.InputStream source,
GridFSUploadOptions options)
Uploads the contents of the given
InputStream to a GridFS bucket. |
ObjectId |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
java.io.InputStream source) |
ObjectId |
GridFSBucket.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
java.io.InputStream source)
Uploads the contents of the given
InputStream to a GridFS bucket. |
ObjectId |
GridFSBucketImpl.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
java.io.InputStream source,
GridFSUploadOptions options) |
ObjectId |
GridFSBucket.uploadFromStream(ClientSession clientSession,
java.lang.String filename,
java.io.InputStream source,
GridFSUploadOptions options)
Uploads the contents of the given
InputStream to a GridFS bucket. |
Constructor and Description |
---|
GridFSDownloadStreamImpl(ClientSession clientSession,
GridFSFile fileInfo,
MongoCollection<Document> chunksCollection) |
GridFSUploadStreamImpl(ClientSession clientSession,
MongoCollection<GridFSFile> filesCollection,
MongoCollection<Document> chunksCollection,
BsonValue fileId,
java.lang.String filename,
int chunkSizeBytes,
Document metadata) |
Modifier and Type | Class and Description |
---|---|
class |
ClientSessionImpl |
Modifier and Type | Field and Description |
---|---|
private ClientSession |
ClientSessionContext.clientSession |
Modifier and Type | Method and Description |
---|---|
ClientSession |
ClientSessionContext.getClientSession() |
Constructor and Description |
---|
ClientSessionContext(ClientSession clientSession) |
Modifier and Type | Method and Description |
---|---|
<T> void |
AsyncOperationExecutor.execute(AsyncReadOperation<T> operation,
ReadPreference readPreference,
ClientSession session,
SingleResultCallback<T> callback)
Execute the read operation with the given read preference.
|
<T> void |
AsyncOperationExecutor.execute(AsyncWriteOperation<T> operation,
ClientSession session,
SingleResultCallback<T> callback)
Execute the write operation.
|