com.mongodb.async.client

Class MongoCollectionImpl<TDocument>

java.lang.Object

com.mongodb.async.client.MongoCollectionImpl<TDocument>

All Implemented Interfaces:

MongoCollection<TDocument>

class MongoCollectionImpl<TDocument>
extends java.lang.Object
implements MongoCollection<TDocument>

Field Summary

Fields

Modifier and Type	Field and Description
private CodecRegistry	codecRegistry
private java.lang.Class<TDocument>	documentClass
private AsyncOperationExecutor	executor
private static Logger	LOGGER
private MongoNamespace	namespace
private ReadConcern	readConcern
private ReadPreference	readPreference
private WriteConcern	writeConcern

Constructor Summary

Constructors

Constructor and Description
MongoCollectionImpl(MongoNamespace namespace, java.lang.Class<TDocument> documentClass, CodecRegistry codecRegistry, ReadPreference readPreference, WriteConcern writeConcern, ReadConcern readConcern, AsyncOperationExecutor executor)

Method Summary

Modifier and Type	Method and Description
AggregateIterable<TDocument>	aggregate(java.util.List<? extends Bson> pipeline) Aggregates documents according to the specified aggregation pipeline.
<TResult> AggregateIterable<TResult>	aggregate(java.util.List<? extends Bson> pipeline, java.lang.Class<TResult> resultClass) Aggregates documents according to the specified aggregation pipeline.
void	bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests, BulkWriteOptions options, SingleResultCallback<BulkWriteResult> callback) Executes a mix of inserts, updates, replaces, and deletes.
void	bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests, SingleResultCallback<BulkWriteResult> callback) Executes a mix of inserts, updates, replaces, and deletes.
void	count(Bson filter, CountOptions options, SingleResultCallback<java.lang.Long> callback) Counts the number of documents in the collection according to the given options.
void	count(Bson filter, SingleResultCallback<java.lang.Long> callback) Counts the number of documents in the collection according to the given options.
void	count(SingleResultCallback<java.lang.Long> callback) Counts the number of documents in the collection.
void	createIndex(Bson key, IndexOptions indexOptions, SingleResultCallback<java.lang.String> callback) Creates an index.
void	createIndex(Bson key, SingleResultCallback<java.lang.String> callback) Creates an index.
void	createIndexes(java.util.List<IndexModel> indexes, SingleResultCallback<java.util.List<java.lang.String>> callback) Create multiple indexes.
private void	delete(Bson filter, DeleteOptions options, boolean multi, SingleResultCallback<DeleteResult> callback)
void	deleteMany(Bson filter, DeleteOptions options, SingleResultCallback<DeleteResult> callback) Removes all documents from the collection that match the given query filter.
void	deleteMany(Bson filter, SingleResultCallback<DeleteResult> callback) Removes all documents from the collection that match the given query filter.
void	deleteOne(Bson filter, DeleteOptions options, SingleResultCallback<DeleteResult> callback) Removes at most one document from the collection that matches the given filter.
void	deleteOne(Bson filter, SingleResultCallback<DeleteResult> callback) Removes at most one document from the collection that matches the given filter.
<TResult> DistinctIterable<TResult>	distinct(java.lang.String fieldName, Bson filter, java.lang.Class<TResult> resultClass) Gets the distinct values of the specified field name.
<TResult> DistinctIterable<TResult>	distinct(java.lang.String fieldName, java.lang.Class<TResult> resultClass) Gets the distinct values of the specified field name.
private BsonDocument	documentToBsonDocument(TDocument document)
void	drop(SingleResultCallback<java.lang.Void> callback) Drops this collection from the Database.
void	dropIndex(Bson keys, SingleResultCallback<java.lang.Void> callback) Drops the index given the keys used to create it.
void	dropIndex(java.lang.String indexName, SingleResultCallback<java.lang.Void> callback) Drops the index given its name.
void	dropIndexes(SingleResultCallback<java.lang.Void> callback) Drop all the indexes on this collection, except for the default on _id.
private void	executeSingleWriteRequest(WriteRequest request, java.lang.Boolean bypassDocumentValidation, SingleResultCallback<BulkWriteResult> callback)
FindIterable<TDocument>	find() Finds all documents in the collection.
FindIterable<TDocument>	find(Bson filter) Finds all documents in the collection.
<TResult> FindIterable<TResult>	find(Bson filter, java.lang.Class<TResult> resultClass) Finds all documents in the collection.
<TResult> FindIterable<TResult>	find(java.lang.Class<TResult> resultClass) Finds all documents in the collection.
void	findOneAndDelete(Bson filter, FindOneAndDeleteOptions options, SingleResultCallback<TDocument> callback) Atomically find a document and remove it.
void	findOneAndDelete(Bson filter, SingleResultCallback<TDocument> callback) Atomically find a document and remove it.
void	findOneAndReplace(Bson filter, TDocument replacement, FindOneAndReplaceOptions options, SingleResultCallback<TDocument> callback) Atomically find a document and replace it.
void	findOneAndReplace(Bson filter, TDocument replacement, SingleResultCallback<TDocument> callback) Atomically find a document and replace it.
void	findOneAndUpdate(Bson filter, Bson update, FindOneAndUpdateOptions options, SingleResultCallback<TDocument> callback) Atomically find a document and update it.
void	findOneAndUpdate(Bson filter, Bson update, SingleResultCallback<TDocument> callback) Atomically find a document and update it.
private Codec<TDocument>	getCodec()
private <TResult> Codec<TResult>	getCodec(java.lang.Class<TResult> resultClass)
CodecRegistry	getCodecRegistry() Get the codec registry for the MongoCollection.
java.lang.Class<TDocument>	getDocumentClass() Get the class of documents stored in this collection.
MongoNamespace	getNamespace() Gets the namespace of this collection.
ReadConcern	getReadConcern() Get the read concern for the MongoCollection.
ReadPreference	getReadPreference() Get the read preference for the MongoCollection.
WriteConcern	getWriteConcern() Get the write concern for the MongoCollection.
void	insertMany(java.util.List<? extends TDocument> documents, InsertManyOptions options, SingleResultCallback<java.lang.Void> callback) Inserts one or more documents.
void	insertMany(java.util.List<? extends TDocument> documents, SingleResultCallback<java.lang.Void> callback) Inserts one or more documents.
void	insertOne(TDocument document, InsertOneOptions options, SingleResultCallback<java.lang.Void> callback) Inserts the provided document.
void	insertOne(TDocument document, SingleResultCallback<java.lang.Void> callback) Inserts the provided document.
ListIndexesIterable<Document>	listIndexes() Get all the indexes in this collection.
<TResult> ListIndexesIterable<TResult>	listIndexes(java.lang.Class<TResult> resultClass) Get all the indexes in this collection.
MapReduceIterable<TDocument>	mapReduce(java.lang.String mapFunction, java.lang.String reduceFunction) Aggregates documents according to the specified map-reduce function.
<TResult> MapReduceIterable<TResult>	mapReduce(java.lang.String mapFunction, java.lang.String reduceFunction, java.lang.Class<TResult> resultClass) Aggregates documents according to the specified map-reduce function.
void	renameCollection(MongoNamespace newCollectionNamespace, RenameCollectionOptions options, SingleResultCallback<java.lang.Void> callback) Rename the collection with oldCollectionName to the newCollectionName.
void	renameCollection(MongoNamespace newCollectionNamespace, SingleResultCallback<java.lang.Void> callback) Rename the collection with oldCollectionName to the newCollectionName.
void	replaceOne(Bson filter, TDocument replacement, SingleResultCallback<UpdateResult> callback) Replace a document in the collection according to the specified arguments.
void	replaceOne(Bson filter, TDocument replacement, UpdateOptions options, SingleResultCallback<UpdateResult> callback) Replace a document in the collection according to the specified arguments.
private BsonDocument	toBsonDocument(Bson document)
private UpdateResult	toUpdateResult(BulkWriteResult result)
private WriteConcernResult	translateBulkWriteResult(WriteRequest request, BulkWriteResult writeResult)
private void	update(Bson filter, Bson update, UpdateOptions options, boolean multi, SingleResultCallback<UpdateResult> callback)
void	updateMany(Bson filter, Bson update, SingleResultCallback<UpdateResult> callback) Update all documents in the collection according to the specified arguments.
void	updateMany(Bson filter, Bson update, UpdateOptions options, SingleResultCallback<UpdateResult> callback) Update all documents in the collection according to the specified arguments.
void	updateOne(Bson filter, Bson update, SingleResultCallback<UpdateResult> callback) Update a single document in the collection according to the specified arguments.
void	updateOne(Bson filter, Bson update, UpdateOptions options, SingleResultCallback<UpdateResult> callback) Update a single document in the collection according to the specified arguments.
MongoCollection<TDocument>	withCodecRegistry(CodecRegistry codecRegistry) Create a new MongoCollection instance with a different codec registry.
<NewTDocument> MongoCollection<NewTDocument>	withDocumentClass(java.lang.Class<NewTDocument> newDocumentClass) Create a new MongoCollection instance with a different default class to cast any documents returned from the database into..
MongoCollection<TDocument>	withReadConcern(ReadConcern readConcern) Create a new MongoCollection instance with a different read concern.
MongoCollection<TDocument>	withReadPreference(ReadPreference readPreference) Create a new MongoCollection instance with a different read preference.
MongoCollection<TDocument>	withWriteConcern(WriteConcern writeConcern) Create a new MongoCollection instance with a different write concern.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

private static final Logger LOGGER

namespace

private final MongoNamespace namespace

documentClass

private final java.lang.Class<TDocument> documentClass

readPreference

private final ReadPreference readPreference

codecRegistry

private final CodecRegistry codecRegistry

writeConcern

private final WriteConcern writeConcern

readConcern

private final ReadConcern readConcern

executor

private final AsyncOperationExecutor executor

Constructor Detail

MongoCollectionImpl

MongoCollectionImpl(MongoNamespace namespace,
                    java.lang.Class<TDocument> documentClass,
                    CodecRegistry codecRegistry,
                    ReadPreference readPreference,
                    WriteConcern writeConcern,
                    ReadConcern readConcern,
                    AsyncOperationExecutor executor)

Method Detail

getNamespace

public MongoNamespace getNamespace()

Description copied from interface: MongoCollection

Gets the namespace of this collection.

Specified by:

getNamespace in interface MongoCollection<TDocument>

Returns:

the namespace

getDocumentClass

public java.lang.Class<TDocument> getDocumentClass()

Description copied from interface: MongoCollection

Get the class of documents stored in this collection.

Specified by:

getDocumentClass in interface MongoCollection<TDocument>

Returns:

the class

getCodecRegistry

public CodecRegistry getCodecRegistry()

Description copied from interface: MongoCollection

Get the codec registry for the MongoCollection.

Specified by:

getCodecRegistry in interface MongoCollection<TDocument>

Returns:

the CodecRegistry

getReadPreference

public ReadPreference getReadPreference()

Description copied from interface: MongoCollection

Get the read preference for the MongoCollection.

Specified by:

getReadPreference in interface MongoCollection<TDocument>

Returns:

the ReadPreference

getWriteConcern

public WriteConcern getWriteConcern()

Description copied from interface: MongoCollection

Get the write concern for the MongoCollection.

Specified by:

getWriteConcern in interface MongoCollection<TDocument>

Returns:

the WriteConcern

getReadConcern

public ReadConcern getReadConcern()

Description copied from interface: MongoCollection

Get the read concern for the MongoCollection.

Specified by:

getReadConcern in interface MongoCollection<TDocument>

Returns:

the ReadConcern

withDocumentClass

public <NewTDocument> MongoCollection<NewTDocument> withDocumentClass(java.lang.Class<NewTDocument> newDocumentClass)

Description copied from interface: MongoCollection

Create a new MongoCollection instance with a different default class to cast any documents returned from the database into..

Specified by:

withDocumentClass in interface MongoCollection<TDocument>

Type Parameters:

NewTDocument - the type that the new collection will encode documents from and decode documents to

Parameters:

newDocumentClass - the default class to cast any documents returned from the database into.

Returns:

a new MongoCollection instance with the different default class

withCodecRegistry

public MongoCollection<TDocument> withCodecRegistry(CodecRegistry codecRegistry)

Description copied from interface: MongoCollection

Create a new MongoCollection instance with a different codec registry.

Specified by:

withCodecRegistry in interface MongoCollection<TDocument>

Parameters:

codecRegistry - the new CodecRegistry for the collection

Returns:

a new MongoCollection instance with the different codec registry

withReadPreference

public MongoCollection<TDocument> withReadPreference(ReadPreference readPreference)

Description copied from interface: MongoCollection

Create a new MongoCollection instance with a different read preference.

Specified by:

withReadPreference in interface MongoCollection<TDocument>

Parameters:

readPreference - the new ReadPreference for the collection

Returns:

a new MongoCollection instance with the different readPreference

withWriteConcern

public MongoCollection<TDocument> withWriteConcern(WriteConcern writeConcern)

Description copied from interface: MongoCollection

Create a new MongoCollection instance with a different write concern.

Specified by:

withWriteConcern in interface MongoCollection<TDocument>

Parameters:

writeConcern - the new WriteConcern for the collection

Returns:

a new MongoCollection instance with the different writeConcern

withReadConcern

public MongoCollection<TDocument> withReadConcern(ReadConcern readConcern)

Description copied from interface: MongoCollection

Create a new MongoCollection instance with a different read concern.

Specified by:

withReadConcern in interface MongoCollection<TDocument>

Parameters:

readConcern - the new ReadConcern for the collection

Returns:

a new MongoCollection instance with the different ReadConcern

count

public void count(SingleResultCallback<java.lang.Long> callback)

Description copied from interface: MongoCollection

Counts the number of documents in the collection.

Specified by:

count in interface MongoCollection<TDocument>

Parameters:

callback - the callback passed the number of documents in the collection

count

public void count(Bson filter,
                  SingleResultCallback<java.lang.Long> callback)

Description copied from interface: MongoCollection

Counts the number of documents in the collection according to the given options.

Specified by:

count in interface MongoCollection<TDocument>

Parameters:

filter - the query filter

callback - the callback passed the number of documents in the collection

count

public void count(Bson filter,
                  CountOptions options,
                  SingleResultCallback<java.lang.Long> callback)

Description copied from interface: MongoCollection

Counts the number of documents in the collection according to the given options.

Specified by:

count in interface MongoCollection<TDocument>

Parameters:

filter - the query filter

options - the options describing the count

callback - the callback passed the number of documents in the collection

distinct

public <TResult> DistinctIterable<TResult> distinct(java.lang.String fieldName,
                                                    java.lang.Class<TResult> resultClass)

Description copied from interface: MongoCollection

Gets the distinct values of the specified field name.

Specified by:

distinct in interface MongoCollection<TDocument>

Type Parameters:

TResult - the target type of the iterable.

Parameters:

fieldName - the field name

resultClass - the default class to cast any distinct items into.

Returns:

an iterable of distinct values

distinct

public <TResult> DistinctIterable<TResult> distinct(java.lang.String fieldName,
                                                    Bson filter,
                                                    java.lang.Class<TResult> resultClass)

Description copied from interface: MongoCollection

Gets the distinct values of the specified field name.

Specified by:

distinct in interface MongoCollection<TDocument>

Type Parameters:

TResult - the target type of the iterable.

Parameters:

fieldName - the field name

filter - the query filter

resultClass - the default class to cast any distinct items into.

Returns:

an iterable of distinct values

find

public FindIterable<TDocument> find()

Description copied from interface: MongoCollection

Finds all documents in the collection.

Specified by:

find in interface MongoCollection<TDocument>

Returns:

the find iterable interface

find

public <TResult> FindIterable<TResult> find(java.lang.Class<TResult> resultClass)

Description copied from interface: MongoCollection

Finds all documents in the collection.

Specified by:

find in interface MongoCollection<TDocument>

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

resultClass - the class to decode each document into

Returns:

the find iterable interface

find

public FindIterable<TDocument> find(Bson filter)

Description copied from interface: MongoCollection

Finds all documents in the collection.

Specified by:

find in interface MongoCollection<TDocument>

Parameters:

filter - the query filter

Returns:

the find iterable interface

find

public <TResult> FindIterable<TResult> find(Bson filter,
                                            java.lang.Class<TResult> resultClass)

Description copied from interface: MongoCollection

Finds all documents in the collection.

Specified by:

find in interface MongoCollection<TDocument>

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

filter - the query filter

resultClass - the class to decode each document into

Returns:

the find iterable interface

aggregate

public AggregateIterable<TDocument> aggregate(java.util.List<? extends Bson> pipeline)

Description copied from interface: MongoCollection

Aggregates documents according to the specified aggregation pipeline. If the pipeline ends with a $out stage, the returned iterable will be a query of the collection that the aggregation was written to. Note that in this case the pipeline will be executed even if the iterable is never iterated.

Specified by:

aggregate in interface MongoCollection<TDocument>

Parameters:

pipeline - the aggregate pipeline

Returns:

an iterable containing the result of the aggregation operation

aggregate

public <TResult> AggregateIterable<TResult> aggregate(java.util.List<? extends Bson> pipeline,
                                                      java.lang.Class<TResult> resultClass)

Description copied from interface: MongoCollection

Aggregates documents according to the specified aggregation pipeline. If the pipeline ends with a $out stage, the returned iterable will be a query of the collection that the aggregation was written to. Note that in this case the pipeline will be executed even if the iterable is never iterated.

Specified by:

aggregate in interface MongoCollection<TDocument>

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

pipeline - the aggregate pipeline

resultClass - the class to decode each document into

Returns:

an iterable containing the result of the aggregation operation

mapReduce

public MapReduceIterable<TDocument> mapReduce(java.lang.String mapFunction,
                                              java.lang.String reduceFunction)

Description copied from interface: MongoCollection

Aggregates documents according to the specified map-reduce function.

Specified by:

mapReduce in interface MongoCollection<TDocument>

Parameters:

mapFunction - A JavaScript function that associates or "maps" a value with a key and emits the key and value pair.

reduceFunction - A JavaScript function that "reduces" to a single object all the values associated with a particular key.

Returns:

an iterable containing the result of the map-reduce operation

mapReduce

public <TResult> MapReduceIterable<TResult> mapReduce(java.lang.String mapFunction,
                                                      java.lang.String reduceFunction,
                                                      java.lang.Class<TResult> resultClass)

Description copied from interface: MongoCollection

Aggregates documents according to the specified map-reduce function.

Specified by:

mapReduce in interface MongoCollection<TDocument>

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

mapFunction - A JavaScript function that associates or "maps" a value with a key and emits the key and value pair.

reduceFunction - A JavaScript function that "reduces" to a single object all the values associated with a particular key.

resultClass - the class to decode each resulting document into.

Returns:

an iterable containing the result of the map-reduce operation

bulkWrite

public void bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
                      SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: MongoCollection

Executes a mix of inserts, updates, replaces, and deletes.

Specified by:

bulkWrite in interface MongoCollection<TDocument>

Parameters:

requests - the writes to execute

callback - the callback passed the result of the bulk write

bulkWrite

public void bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
                      BulkWriteOptions options,
                      SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: MongoCollection

Executes a mix of inserts, updates, replaces, and deletes.

Specified by:

bulkWrite in interface MongoCollection<TDocument>

Parameters:

requests - the writes to execute

options - the options to apply to the bulk write operation

callback - the callback passed the result of the bulk write

insertOne

public void insertOne(TDocument document,
                      SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Inserts the provided document. If the document is missing an identifier, the driver should generate one.

Specified by:

insertOne in interface MongoCollection<TDocument>

Parameters:

document - the document to insert

callback - the callback that is completed once the insert has completed

insertOne

public void insertOne(TDocument document,
                      InsertOneOptions options,
                      SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Inserts the provided document. If the document is missing an identifier, the driver should generate one.

Specified by:

insertOne in interface MongoCollection<TDocument>

Parameters:

document - the document to insert

options - the options to apply to the operation

callback - the callback that is completed once the insert has completed

insertMany

public void insertMany(java.util.List<? extends TDocument> documents,
                       SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Inserts one or more documents. A call to this method is equivalent to a call to the bulkWrite method

Specified by:

insertMany in interface MongoCollection<TDocument>

Parameters:

documents - the documents to insert

callback - the callback that is completed once the insert has completed

See Also:

MongoCollection.bulkWrite(java.util.List<? extends com.mongodb.client.model.WriteModel<? extends TDocument>>, com.mongodb.async.SingleResultCallback<com.mongodb.bulk.BulkWriteResult>)

insertMany

public void insertMany(java.util.List<? extends TDocument> documents,
                       InsertManyOptions options,
                       SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Inserts one or more documents. A call to this method is equivalent to a call to the bulkWrite method

Specified by:

insertMany in interface MongoCollection<TDocument>

Parameters:

documents - the documents to insert

options - the options to apply to the operation

callback - the callback that is completed once the insert has completed

See Also:

MongoCollection.bulkWrite(java.util.List<? extends com.mongodb.client.model.WriteModel<? extends TDocument>>, com.mongodb.async.SingleResultCallback<com.mongodb.bulk.BulkWriteResult>)

deleteOne

public void deleteOne(Bson filter,
                      SingleResultCallback<DeleteResult> callback)

Description copied from interface: MongoCollection

Removes at most one document from the collection that matches the given filter. If no documents match, the collection is not modified.

Specified by:

deleteOne in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the delete operation

callback - the callback passed the result of the remove one operation

deleteOne

public void deleteOne(Bson filter,
                      DeleteOptions options,
                      SingleResultCallback<DeleteResult> callback)

Description copied from interface: MongoCollection

Removes at most one document from the collection that matches the given filter. If no documents match, the collection is not modified.

Specified by:

deleteOne in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the delete operation

options - the options to apply to the delete operation

callback - the callback passed the result of the remove one operation

deleteMany

public void deleteMany(Bson filter,
                       SingleResultCallback<DeleteResult> callback)

Description copied from interface: MongoCollection

Removes all documents from the collection that match the given query filter. If no documents match, the collection is not modified.

Specified by:

deleteMany in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the delete operation

callback - the callback passed the result of the remove many operation

deleteMany

public void deleteMany(Bson filter,
                       DeleteOptions options,
                       SingleResultCallback<DeleteResult> callback)

Description copied from interface: MongoCollection

Removes all documents from the collection that match the given query filter. If no documents match, the collection is not modified.

Specified by:

deleteMany in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the delete operation

options - the options to apply to the delete operation

callback - the callback passed the result of the remove many operation

replaceOne

public void replaceOne(Bson filter,
                       TDocument replacement,
                       SingleResultCallback<UpdateResult> callback)

Description copied from interface: MongoCollection

Replace a document in the collection according to the specified arguments.

Specified by:

replaceOne in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

callback - the callback passed the result of the replace one operation

replaceOne

public void replaceOne(Bson filter,
                       TDocument replacement,
                       UpdateOptions options,
                       SingleResultCallback<UpdateResult> callback)

Description copied from interface: MongoCollection

Replace a document in the collection according to the specified arguments.

Specified by:

replaceOne in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

options - the options to apply to the replace operation

callback - the callback passed the result of the replace one operation

updateOne

public void updateOne(Bson filter,
                      Bson update,
                      SingleResultCallback<UpdateResult> callback)

Description copied from interface: MongoCollection

Update a single document in the collection according to the specified arguments.

Specified by:

updateOne in interface MongoCollection<TDocument>

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

callback - the callback passed the result of the update one operation

updateOne

public void updateOne(Bson filter,
                      Bson update,
                      UpdateOptions options,
                      SingleResultCallback<UpdateResult> callback)

Description copied from interface: MongoCollection

Update a single document in the collection according to the specified arguments.

Specified by:

updateOne in interface MongoCollection<TDocument>

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

options - the options to apply to the update operation

callback - the callback passed the result of the update one operation

updateMany

public void updateMany(Bson filter,
                       Bson update,
                       SingleResultCallback<UpdateResult> callback)

Description copied from interface: MongoCollection

Update all documents in the collection according to the specified arguments.

Specified by:

updateMany in interface MongoCollection<TDocument>

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators. T

callback - the callback passed the result of the update many operation

updateMany

public void updateMany(Bson filter,
                       Bson update,
                       UpdateOptions options,
                       SingleResultCallback<UpdateResult> callback)

Description copied from interface: MongoCollection

Update all documents in the collection according to the specified arguments.

Specified by:

updateMany in interface MongoCollection<TDocument>

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

options - the options to apply to the update operation

callback - the callback passed the result of the update many operation

findOneAndDelete

public void findOneAndDelete(Bson filter,
                             SingleResultCallback<TDocument> callback)

Description copied from interface: MongoCollection

Atomically find a document and remove it.

Specified by:

findOneAndDelete in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to find the document with

callback - the callback passed the document that was removed. If no documents matched the query filter, then null will be returned

findOneAndDelete

public void findOneAndDelete(Bson filter,
                             FindOneAndDeleteOptions options,
                             SingleResultCallback<TDocument> callback)

Description copied from interface: MongoCollection

Atomically find a document and remove it.

Specified by:

findOneAndDelete in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to find the document with

options - the options to apply to the operation

callback - the callback passed the document that was removed. If no documents matched the query filter, then null will be returned

findOneAndReplace

public void findOneAndReplace(Bson filter,
                              TDocument replacement,
                              SingleResultCallback<TDocument> callback)

Description copied from interface: MongoCollection

Atomically find a document and replace it.

Specified by:

findOneAndReplace in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

callback - the callback passed the document that was replaced. Depending on the value of the returnOriginal property, this will either be the document as it was before the update or as it is after the update. If no documents matched the query filter, then null will be returned

findOneAndReplace

public void findOneAndReplace(Bson filter,
                              TDocument replacement,
                              FindOneAndReplaceOptions options,
                              SingleResultCallback<TDocument> callback)

Description copied from interface: MongoCollection

Atomically find a document and replace it.

Specified by:

findOneAndReplace in interface MongoCollection<TDocument>

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

options - the options to apply to the operation

callback - the callback passed the document that was replaced. Depending on the value of the returnOriginal property, this will either be the document as it was before the update or as it is after the update. If no documents matched the query filter, then null will be returned

findOneAndUpdate

public void findOneAndUpdate(Bson filter,
                             Bson update,
                             SingleResultCallback<TDocument> callback)

Description copied from interface: MongoCollection

Atomically find a document and update it.

Specified by:

findOneAndUpdate in interface MongoCollection<TDocument>

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

callback - the callback passed the document that was updated before the update was applied. If no documents matched the query filter, then null will be returned

findOneAndUpdate

public void findOneAndUpdate(Bson filter,
                             Bson update,
                             FindOneAndUpdateOptions options,
                             SingleResultCallback<TDocument> callback)

Description copied from interface: MongoCollection

Atomically find a document and update it.

Specified by:

findOneAndUpdate in interface MongoCollection<TDocument>

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

options - the options to apply to the operation

callback - the callback passed the document that was updated. Depending on the value of the returnOriginal property, this will either be the document as it was before the update or as it is after the update. If no documents matched the query filter, then null will be returned

drop

public void drop(SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Drops this collection from the Database.

Specified by:

drop in interface MongoCollection<TDocument>

Parameters:

callback - the callback that is completed once the collection has been dropped

createIndex

public void createIndex(Bson key,
                        SingleResultCallback<java.lang.String> callback)

Description copied from interface: MongoCollection

Creates an index. If successful, the callback will be executed with the name of the created index as the result.

Specified by:

createIndex in interface MongoCollection<TDocument>

Parameters:

key - an object describing the index key(s), which may not be null.

callback - the callback that is completed once the index has been created

createIndex

public void createIndex(Bson key,
                        IndexOptions indexOptions,
                        SingleResultCallback<java.lang.String> callback)

Description copied from interface: MongoCollection

Creates an index. If successful, the callback will be executed with the name of the created index as the result.

Specified by:

createIndex in interface MongoCollection<TDocument>

Parameters:

key - an object describing the index key(s), which may not be null.

indexOptions - the options for the index

callback - the callback that is completed once the index has been created

createIndexes

public void createIndexes(java.util.List<IndexModel> indexes,
                          SingleResultCallback<java.util.List<java.lang.String>> callback)

Description copied from interface: MongoCollection

Create multiple indexes. If successful, the callback will be executed with a list of the namess of the created index as the result.

Specified by:

createIndexes in interface MongoCollection<TDocument>

Parameters:

indexes - the list of indexes

callback - the callback that is completed once the indexes has been created

listIndexes

public ListIndexesIterable<Document> listIndexes()

Description copied from interface: MongoCollection

Get all the indexes in this collection.

Specified by:

listIndexes in interface MongoCollection<TDocument>

Returns:

the list indexes iterable interface

listIndexes

public <TResult> ListIndexesIterable<TResult> listIndexes(java.lang.Class<TResult> resultClass)

Description copied from interface: MongoCollection

Get all the indexes in this collection.

Specified by:

listIndexes in interface MongoCollection<TDocument>

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

resultClass - the class to decode each document into

Returns:

the list indexes iterable interface

dropIndex

public void dropIndex(java.lang.String indexName,
                      SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Drops the index given its name.

Specified by:

dropIndex in interface MongoCollection<TDocument>

Parameters:

indexName - the name of the index to remove

callback - the callback that is completed once the index has been dropped

dropIndex

public void dropIndex(Bson keys,
                      SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Drops the index given the keys used to create it.

Specified by:

dropIndex in interface MongoCollection<TDocument>

Parameters:

keys - the keys of the index to remove

callback - the callback that is completed once the index has been dropped

dropIndexes

public void dropIndexes(SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Drop all the indexes on this collection, except for the default on _id.

Specified by:

dropIndexes in interface MongoCollection<TDocument>

Parameters:

callback - the callback that is completed once all the indexes have been dropped

renameCollection

public void renameCollection(MongoNamespace newCollectionNamespace,
                             SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Rename the collection with oldCollectionName to the newCollectionName.

Specified by:

renameCollection in interface MongoCollection<TDocument>

Parameters:

newCollectionNamespace - the namespace the collection will be renamed to

callback - the callback that is completed once the collection has been renamed

renameCollection

public void renameCollection(MongoNamespace newCollectionNamespace,
                             RenameCollectionOptions options,
                             SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoCollection

Rename the collection with oldCollectionName to the newCollectionName.

Specified by:

renameCollection in interface MongoCollection<TDocument>

Parameters:

newCollectionNamespace - the name the collection will be renamed to

options - the options for renaming a collection

callback - the callback that is completed once the collection has been renamed

delete

private void delete(Bson filter,
                    DeleteOptions options,
                    boolean multi,
                    SingleResultCallback<DeleteResult> callback)

update

private void update(Bson filter,
                    Bson update,
                    UpdateOptions options,
                    boolean multi,
                    SingleResultCallback<UpdateResult> callback)

executeSingleWriteRequest

private void executeSingleWriteRequest(WriteRequest request,
                                       java.lang.Boolean bypassDocumentValidation,
                                       SingleResultCallback<BulkWriteResult> callback)

translateBulkWriteResult

private WriteConcernResult translateBulkWriteResult(WriteRequest request,
                                                    BulkWriteResult writeResult)

toUpdateResult

private UpdateResult toUpdateResult(BulkWriteResult result)

getCodec

private Codec<TDocument> getCodec()

getCodec

private <TResult> Codec<TResult> getCodec(java.lang.Class<TResult> resultClass)

documentToBsonDocument

private BsonDocument documentToBsonDocument(TDocument document)

toBsonDocument

private BsonDocument toBsonDocument(Bson document)