Package | Description |
---|---|
com.mongodb.assertions |
Contains design by contract assertions
|
com.mongodb.async |
This package contains async interfaces
|
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.binding |
This package contains classes that manage binding to MongoDB servers for various operations.
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.internal.async | |
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Method and Description |
---|---|
static void |
Assertions.isTrue(String name,
boolean condition,
SingleResultCallback<?> callback)
Throw IllegalStateException if the condition if false.
|
static <T> T |
Assertions.notNull(String name,
T value,
SingleResultCallback<?> callback)
Throw IllegalArgumentException if the value is null.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncBatchCursor.next(SingleResultCallback<List<T>> callback)
Returns the next batch of results.
|
void |
AsyncBatchCursor.tryNext(SingleResultCallback<List<T>> callback)
A special
next() case that returns the next batch if available or null. |
Modifier and Type | Method and Description |
---|---|
void |
MongoIterable.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback)
Provide the underlying
AsyncBatchCursor allowing fine grained control of the cursor. |
void |
MongoCollection.bulkWrite(ClientSession clientSession,
List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollection.bulkWrite(ClientSession clientSession,
List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollection.bulkWrite(List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollection.bulkWrite(List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollection.count(Bson filter,
CountOptions options,
SingleResultCallback<Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollection.count(Bson filter,
SingleResultCallback<Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollection.count(ClientSession clientSession,
Bson filter,
CountOptions options,
SingleResultCallback<Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollection.count(ClientSession clientSession,
Bson filter,
SingleResultCallback<Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollection.count(ClientSession clientSession,
SingleResultCallback<Long> callback)
Counts the number of documents in the collection.
|
void |
MongoCollection.count(SingleResultCallback<Long> callback)
Counts the number of documents in the collection.
|
void |
MongoDatabase.createCollection(ClientSession clientSession,
String collectionName,
CreateCollectionOptions options,
SingleResultCallback<Void> callback)
Create a new collection with the selected options
|
void |
MongoDatabase.createCollection(ClientSession clientSession,
String collectionName,
SingleResultCallback<Void> callback)
Create a new collection with the given name.
|
void |
MongoDatabase.createCollection(String collectionName,
CreateCollectionOptions options,
SingleResultCallback<Void> callback)
Create a new collection with the selected options
|
void |
MongoDatabase.createCollection(String collectionName,
SingleResultCallback<Void> callback)
Create a new collection with the given name.
|
void |
MongoCollection.createIndex(Bson key,
IndexOptions options,
SingleResultCallback<String> callback)
Creates an index.
|
void |
MongoCollection.createIndex(Bson key,
SingleResultCallback<String> callback)
Creates an index.
|
void |
MongoCollection.createIndex(ClientSession clientSession,
Bson key,
IndexOptions options,
SingleResultCallback<String> callback)
Creates an index.
|
void |
MongoCollection.createIndex(ClientSession clientSession,
Bson key,
SingleResultCallback<String> callback)
Creates an index.
|
void |
MongoCollection.createIndexes(ClientSession clientSession,
List<IndexModel> indexes,
CreateIndexOptions createIndexOptions,
SingleResultCallback<List<String>> callback)
Create multiple indexes.
|
void |
MongoCollection.createIndexes(ClientSession clientSession,
List<IndexModel> indexes,
SingleResultCallback<List<String>> callback)
Create multiple indexes.
|
void |
MongoCollection.createIndexes(List<IndexModel> indexes,
CreateIndexOptions createIndexOptions,
SingleResultCallback<List<String>> callback)
Create multiple indexes.
|
void |
MongoCollection.createIndexes(List<IndexModel> indexes,
SingleResultCallback<List<String>> callback)
Create multiple indexes.
|
void |
MongoDatabase.createView(ClientSession clientSession,
String viewName,
String viewOn,
List<? extends Bson> pipeline,
CreateViewOptions createViewOptions,
SingleResultCallback<Void> callback)
Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
|
void |
MongoDatabase.createView(ClientSession clientSession,
String viewName,
String viewOn,
List<? extends Bson> pipeline,
SingleResultCallback<Void> callback)
Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
|
void |
MongoDatabase.createView(String viewName,
String viewOn,
List<? extends Bson> pipeline,
CreateViewOptions createViewOptions,
SingleResultCallback<Void> callback)
Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
|
void |
MongoDatabase.createView(String viewName,
String viewOn,
List<? extends Bson> pipeline,
SingleResultCallback<Void> callback)
Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
|
void |
MongoCollection.deleteMany(Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback)
Removes all documents from the collection that match the given query filter.
|
void |
MongoCollection.deleteMany(Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes all documents from the collection that match the given query filter.
|
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 |
MongoCollection.deleteMany(ClientSession clientSession,
Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes all documents from the collection that match the given query filter.
|
void |
MongoCollection.deleteOne(Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback)
Removes at most one document from the collection that matches the given filter.
|
void |
MongoCollection.deleteOne(Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes at most one document from the collection that matches the given filter.
|
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 |
MongoCollection.deleteOne(ClientSession clientSession,
Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes at most one document from the collection that matches the given filter.
|
void |
MongoCollection.drop(ClientSession clientSession,
SingleResultCallback<Void> callback)
Drops this collection from the Database.
|
void |
MongoDatabase.drop(ClientSession clientSession,
SingleResultCallback<Void> callback)
Drops this database.
|
void |
MongoCollection.drop(SingleResultCallback<Void> callback)
Drops this collection from the Database.
|
void |
MongoDatabase.drop(SingleResultCallback<Void> callback)
Drops this database.
|
void |
MongoCollection.dropIndex(Bson keys,
DropIndexOptions dropIndexOptions,
SingleResultCallback<Void> callback)
Drops the index given the keys used to create it.
|
void |
MongoCollection.dropIndex(Bson keys,
SingleResultCallback<Void> callback)
Drops the index given the keys used to create it.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
Bson keys,
DropIndexOptions dropIndexOptions,
SingleResultCallback<Void> callback)
Drops the index given the keys used to create it.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
Bson keys,
SingleResultCallback<Void> callback)
Drops the index given the keys used to create it.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
String indexName,
DropIndexOptions dropIndexOptions,
SingleResultCallback<Void> callback)
Drops the index given its name.
|
void |
MongoCollection.dropIndex(ClientSession clientSession,
String indexName,
SingleResultCallback<Void> callback)
Drops the index given its name.
|
void |
MongoCollection.dropIndex(String indexName,
DropIndexOptions dropIndexOptions,
SingleResultCallback<Void> callback)
Drops the index given its name.
|
void |
MongoCollection.dropIndex(String indexName,
SingleResultCallback<Void> callback)
Drops the index given its name.
|
void |
MongoCollection.dropIndexes(ClientSession clientSession,
DropIndexOptions dropIndexOptions,
SingleResultCallback<Void> callback)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollection.dropIndexes(ClientSession clientSession,
SingleResultCallback<Void> callback)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollection.dropIndexes(DropIndexOptions dropIndexOptions,
SingleResultCallback<Void> callback)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollection.dropIndexes(SingleResultCallback<Void> callback)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollection.findOneAndDelete(Bson filter,
FindOneAndDeleteOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollection.findOneAndDelete(Bson filter,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollection.findOneAndDelete(ClientSession clientSession,
Bson filter,
FindOneAndDeleteOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollection.findOneAndDelete(ClientSession clientSession,
Bson filter,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollection.findOneAndReplace(Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollection.findOneAndReplace(Bson filter,
TDocument replacement,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollection.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollection.findOneAndReplace(ClientSession clientSession,
Bson filter,
TDocument replacement,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollection.findOneAndUpdate(Bson filter,
Bson update,
FindOneAndUpdateOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoCollection.findOneAndUpdate(Bson filter,
Bson update,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoCollection.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
FindOneAndUpdateOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoCollection.findOneAndUpdate(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoIterable.first(SingleResultCallback<TResult> callback)
Helper to return the first item in the iterator or null.
|
void |
MongoIterable.forEach(Block<? super TResult> block,
SingleResultCallback<Void> callback)
Iterates over all documents in the view, applying the given block to each, and completing the returned future after all documents
have been iterated, or an exception has occurred.
|
void |
MongoCollection.insertMany(ClientSession clientSession,
List<? extends TDocument> documents,
InsertManyOptions options,
SingleResultCallback<Void> callback)
Inserts one or more documents.
|
void |
MongoCollection.insertMany(ClientSession clientSession,
List<? extends TDocument> documents,
SingleResultCallback<Void> callback)
Inserts one or more documents.
|
void |
MongoCollection.insertMany(List<? extends TDocument> documents,
InsertManyOptions options,
SingleResultCallback<Void> callback)
Inserts one or more documents.
|
void |
MongoCollection.insertMany(List<? extends TDocument> documents,
SingleResultCallback<Void> callback)
Inserts one or more documents.
|
void |
MongoCollection.insertOne(ClientSession clientSession,
TDocument document,
InsertOneOptions options,
SingleResultCallback<Void> callback)
Inserts the provided document.
|
void |
MongoCollection.insertOne(ClientSession clientSession,
TDocument document,
SingleResultCallback<Void> callback)
Inserts the provided document.
|
void |
MongoCollection.insertOne(TDocument document,
InsertOneOptions options,
SingleResultCallback<Void> callback)
Inserts the provided document.
|
void |
MongoCollection.insertOne(TDocument document,
SingleResultCallback<Void> callback)
Inserts the provided document.
|
<A extends Collection<? super TResult>> |
MongoIterable.into(A target,
SingleResultCallback<A> callback)
Iterates over all the documents, adding each to the given target.
|
void |
MongoCollection.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollection.renameCollection(ClientSession clientSession,
MongoNamespace newCollectionNamespace,
SingleResultCallback<Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace,
SingleResultCallback<Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollection.replaceOne(Bson filter,
TDocument replacement,
SingleResultCallback<UpdateResult> callback)
Replace a document in the collection according to the specified arguments.
|
void |
MongoCollection.replaceOne(Bson filter,
TDocument replacement,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Replace a document in the collection according to the specified arguments.
|
void |
MongoCollection.replaceOne(ClientSession clientSession,
Bson filter,
TDocument replacement,
SingleResultCallback<UpdateResult> callback)
Replace a document in the collection according to the specified arguments.
|
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.
|
<TResult> void |
MongoDatabase.runCommand(Bson command,
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 |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference,
Class<TResult> resultClass,
SingleResultCallback<TResult> callback)
Executes the given command in the context of the current database with the given read preference.
|
void |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference,
SingleResultCallback<Document> callback)
Executes the given command in the context of the current database with the given read preference.
|
void |
MongoDatabase.runCommand(Bson command,
SingleResultCallback<Document> callback)
Executes the given command in the context of the current database with a read preference of
ReadPreference.primary() . |
<TResult> void |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
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 |
MongoDatabase.runCommand(ClientSession clientSession,
Bson command,
ReadPreference readPreference,
Class<TResult> resultClass,
SingleResultCallback<TResult> callback)
Executes the given command in the context of the current database with the given read preference.
|
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 |
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 |
MongoClient.startSession(ClientSessionOptions options,
SingleResultCallback<ClientSession> callback)
Creates a client session.
|
void |
MapReduceIterable.toCollection(SingleResultCallback<Void> callback)
Aggregates documents to a collection according to the specified map-reduce function with the given options, which must specify a
non-inline result.
|
void |
AggregateIterable.toCollection(SingleResultCallback<Void> callback)
Aggregates documents according to the specified aggregation pipeline, which must end with a $out stage.
|
void |
MongoCollection.updateMany(Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback)
Update all documents in the collection according to the specified arguments.
|
void |
MongoCollection.updateMany(Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Update all documents in the collection according to the specified arguments.
|
void |
MongoCollection.updateMany(ClientSession clientSession,
Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback)
Update all documents in the collection according to the specified arguments.
|
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 |
MongoCollection.updateOne(Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback)
Update a single document in the collection according to the specified arguments.
|
void |
MongoCollection.updateOne(Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Update a single document in the collection according to the specified arguments.
|
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 |
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.
|
Modifier and Type | Method and Description |
---|---|
static <TResult> Observable<TResult> |
Observables.observe(Block<SingleResultCallback<TResult>> operation)
Allows the conversion of
SingleResultCallback based operations into an Observable |
static <TResult> Observable<TResult> |
Observables.observeAndFlatten(Block<SingleResultCallback<List<TResult>>> operation)
Allows the conversion of
SingleResultCallback based operations and flattens the results in an Observable . |
Modifier and Type | Method and Description |
---|---|
void |
GridFSUploadStream.abort(SingleResultCallback<Void> callback)
Aborts the upload and deletes any data.
|
void |
AsyncOutputStream.close(SingleResultCallback<Void> callback)
Closes the output stream
|
void |
AsyncInputStream.close(SingleResultCallback<Void> callback)
Closes the input stream
|
void |
GridFSBucket.delete(BsonValue id,
SingleResultCallback<Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucket.delete(ClientSession clientSession,
BsonValue id,
SingleResultCallback<Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucket.delete(ClientSession clientSession,
ObjectId id,
SingleResultCallback<Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucket.delete(ObjectId id,
SingleResultCallback<Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucket.downloadToStream(BsonValue id,
AsyncOutputStream destination,
SingleResultCallback<Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
BsonValue id,
AsyncOutputStream destination,
SingleResultCallback<Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
ObjectId id,
AsyncOutputStream destination,
SingleResultCallback<Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucket.downloadToStream(ClientSession clientSession,
String filename,
AsyncOutputStream destination,
GridFSDownloadOptions options,
SingleResultCallback<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 |
GridFSBucket.downloadToStream(ClientSession clientSession,
String filename,
AsyncOutputStream destination,
SingleResultCallback<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 |
GridFSBucket.downloadToStream(ObjectId id,
AsyncOutputStream destination,
SingleResultCallback<Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucket.downloadToStream(String filename,
AsyncOutputStream destination,
GridFSDownloadOptions options,
SingleResultCallback<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 |
GridFSBucket.downloadToStream(String filename,
AsyncOutputStream destination,
SingleResultCallback<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 |
GridFSBucket.drop(ClientSession clientSession,
SingleResultCallback<Void> callback)
Drops the data associated with this bucket from the database.
|
void |
GridFSBucket.drop(SingleResultCallback<Void> callback)
Drops the data associated with this bucket from the database.
|
void |
GridFSDownloadStream.getGridFSFile(SingleResultCallback<GridFSFile> callback)
Gets the corresponding
GridFSFile for the file being downloaded |
void |
AsyncInputStream.read(ByteBuffer dst,
SingleResultCallback<Integer> callback)
Reads a sequence of bytes from this stream into the given buffer.
|
void |
GridFSBucket.rename(BsonValue id,
String newFilename,
SingleResultCallback<Void> callback)
Renames the stored file with the specified
id . |
void |
GridFSBucket.rename(ClientSession clientSession,
BsonValue id,
String newFilename,
SingleResultCallback<Void> callback)
Renames the stored file with the specified
id . |
void |
GridFSBucket.rename(ClientSession clientSession,
ObjectId id,
String newFilename,
SingleResultCallback<Void> callback)
Renames the stored file with the specified
id . |
void |
GridFSBucket.rename(ObjectId id,
String newFilename,
SingleResultCallback<Void> callback)
Renames the stored file with the specified
id . |
void |
GridFSBucket.uploadFromStream(BsonValue id,
String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucket.uploadFromStream(BsonValue id,
String filename,
AsyncInputStream source,
SingleResultCallback<Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
BsonValue id,
String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
BsonValue id,
String filename,
AsyncInputStream source,
SingleResultCallback<Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucket.uploadFromStream(ClientSession clientSession,
String filename,
AsyncInputStream source,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucket.uploadFromStream(String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucket.uploadFromStream(String filename,
AsyncInputStream source,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
AsyncOutputStream.write(ByteBuffer src,
SingleResultCallback<Integer> callback)
Writes a sequence of bytes from the given buffer into this stream.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncConnectionSource.getConnection(SingleResultCallback<AsyncConnection> callback)
Gets a connection from this source.
|
void |
AsyncReadBinding.getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
Returns a connection source to a server that satisfies the specified read preference.
|
void |
AsyncSingleConnectionReadBinding.getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback) |
void |
AsyncClusterBinding.getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback) |
void |
AsyncWriteBinding.getWriteConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
Supply a connection source to a server that can be written to
|
void |
AsyncClusterBinding.getWriteConnectionSource(SingleResultCallback<AsyncConnectionSource> callback) |
Modifier and Type | Method and Description |
---|---|
<T> void |
AsyncConnection.commandAsync(String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
SingleResultCallback<T> callback)
|
<T> void |
AsyncConnection.commandAsync(String database,
BsonDocument command,
FieldNameValidator commandFieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext,
boolean responseExpected,
SplittablePayload payload,
FieldNameValidator payloadFieldNameValidator,
SingleResultCallback<T> callback)
Executes the command, consuming as much of the
SplittablePayload as possible. |
<T> void |
AsyncConnection.commandAsync(String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
ReadPreference readPreference,
Decoder<T> commandResultDecoder,
SessionContext sessionContext,
SingleResultCallback<T> callback)
Execute the command.
|
void |
AsyncConnection.deleteAsync(MongoNamespace namespace,
boolean ordered,
DeleteRequest deleteRequest,
SingleResultCallback<WriteConcernResult> callback)
Delete the documents using the delete wire protocol and apply the write concern asynchronously.
|
void |
Server.getConnectionAsync(SingleResultCallback<AsyncConnection> callback)
Gets a connection to this server asynchronously.
|
<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.
|
void |
AsyncConnection.insertAsync(MongoNamespace namespace,
boolean ordered,
InsertRequest insertRequest,
SingleResultCallback<WriteConcernResult> callback)
Insert the documents using the insert wire protocol and apply the write concern asynchronously.
|
void |
AsyncConnection.killCursorAsync(List<Long> cursors,
SingleResultCallback<Void> callback)
Deprecated.
|
void |
AsyncConnection.killCursorAsync(MongoNamespace namespace,
List<Long> cursors,
SingleResultCallback<Void> callback)
Asynchronously Kills the given list of cursors.
|
<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 |
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.
|
void |
Cluster.selectServerAsync(ServerSelector serverSelector,
SingleResultCallback<Server> callback)
Asynchronously gets a MongoDB server that matches the criteria defined by the serverSelector.
|
void |
AsyncConnection.updateAsync(MongoNamespace namespace,
boolean ordered,
UpdateRequest updateRequest,
SingleResultCallback<WriteConcernResult> callback)
Update the documents using the update wire protocol and apply the write concern asynchronously.
|
Modifier and Type | Class and Description |
---|---|
class |
ErrorHandlingResultCallback<T>
This class is not part of the public API and may be removed or changed at any time.
|
Modifier and Type | Method and Description |
---|---|
static <T> SingleResultCallback<T> |
ErrorHandlingResultCallback.errorHandlingCallback(SingleResultCallback<T> callback,
Logger logger) |
Modifier and Type | Method and Description |
---|---|
static <T> SingleResultCallback<T> |
ErrorHandlingResultCallback.errorHandlingCallback(SingleResultCallback<T> callback,
Logger logger) |
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(AsyncReadOperation<T> operation,
ReadPreference readPreference,
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.
|
<T> void |
AsyncOperationExecutor.execute(AsyncWriteOperation<T> operation,
SingleResultCallback<T> callback)
Execute the write operation.
|
void |
ChangeStreamOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
FindOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
DistinctOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
GroupOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListIndexesOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
AggregateOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListDatabasesOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListCollectionsOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
UserExistsOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<Boolean> callback) |
void |
ParallelCollectionScanOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<List<AsyncBatchCursor<T>>> callback) |
void |
CountOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<Long> callback) |
void |
MapReduceWithInlineResultsOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<MapReduceAsyncBatchCursor<T>> callback) |
void |
CommandReadOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<T> callback) |
void |
AsyncReadOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<T> callback)
General execute which can return anything of type T
|
void |
MixedBulkWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<BulkWriteResult> callback) |
void |
MapReduceToCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<MapReduceStatistics> callback) |
void |
AsyncWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback)
General execute which can return anything of type T
|
void |
CommandWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback) |
void |
DropCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
AggregateToCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
CreateUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
UpdateUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
DropDatabaseOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
DropUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
CreateIndexesOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
RenameCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
CreateViewOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
CreateCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
DropIndexOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<Void> callback) |
void |
BaseWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<WriteConcernResult> callback) |
Copyright © 2018. All rights reserved.