Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<MongoClient> |
__TYPE_ARG |
static String |
DEFAULT_DB_NAME
The name of the default database
|
static String |
DEFAULT_POOL_NAME
The name of the default pool
|
Constructor and Description |
---|
MongoClient(MongoClient delegate) |
MongoClient(Object delegate) |
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
MongoClient |
bulkWrite(String collection,
List<BulkOperation> operations)
Execute a bulk operation.
|
MongoClient |
bulkWrite(String collection,
List<BulkOperation> operations,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
Execute a bulk operation.
|
MongoClient |
bulkWriteWithOptions(String collection,
List<BulkOperation> operations,
BulkWriteOptions bulkWriteOptions)
Execute a bulk operation with the specified write options.
|
MongoClient |
bulkWriteWithOptions(String collection,
List<BulkOperation> operations,
BulkWriteOptions bulkWriteOptions,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
Execute a bulk operation with the specified write options.
|
void |
close()
Close the client and release its resources
|
void |
close(Handler<AsyncResult<Void>> handler)
Close the client and release its resources
|
MongoClient |
count(String collection,
JsonObject query)
Count matching documents in a collection.
|
MongoClient |
count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
MongoClient |
countWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
MongoClient |
countWithOptions(String collection,
JsonObject query,
CountOptions countOptions,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
static MongoClient |
create(Vertx vertx,
JsonObject config)
Create a Mongo client which maintains its own data source.
|
MongoClient |
createCollection(String collectionName)
Create a new collection
|
MongoClient |
createCollection(String collectionName,
Handler<AsyncResult<Void>> resultHandler)
Create a new collection
|
MongoClient |
createCollectionWithOptions(String collectionName,
CreateCollectionOptions collectionOptions)
Create a new collection with options
|
MongoClient |
createCollectionWithOptions(String collectionName,
CreateCollectionOptions collectionOptions,
Handler<AsyncResult<Void>> resultHandler)
Create a new collection with options
|
MongoClient |
createDefaultGridFsBucketService()
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
MongoClient |
createDefaultGridFsBucketService(Handler<AsyncResult<MongoGridFsClient>> resultHandler)
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
MongoClient |
createGridFsBucketService(String bucketName)
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
MongoClient |
createGridFsBucketService(String bucketName,
Handler<AsyncResult<MongoGridFsClient>> resultHandler)
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
MongoClient |
createIndex(String collection,
JsonObject key)
Creates an index.
|
MongoClient |
createIndex(String collection,
JsonObject key,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
MongoClient |
createIndexes(String collection,
List<IndexModel> indexes)
creates an indexes
|
MongoClient |
createIndexes(String collection,
List<IndexModel> indexes,
Handler<AsyncResult<Void>> resultHandler)
creates an indexes
|
MongoClient |
createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
MongoClient |
createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
static MongoClient |
createShared(Vertx vertx,
JsonObject config)
Like
createShared(io.vertx.reactivex.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default data source name |
static MongoClient |
createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a Mongo client which shares its data source with any other Mongo clients created with the same
data source name
|
MongoClient |
distinct(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
MongoClient |
distinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
MongoClient |
distinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
distinctBatch(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
distinctBatch(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
dropCollection(String collection)
Drop a collection
|
MongoClient |
dropCollection(String collection,
Handler<AsyncResult<Void>> resultHandler)
Drop a collection
|
MongoClient |
dropIndex(String collection,
String indexName)
Drops the index given its name.
|
MongoClient |
dropIndex(String collection,
String indexName,
Handler<AsyncResult<Void>> resultHandler)
Drops the index given its name.
|
boolean |
equals(Object o) |
MongoClient |
find(String collection,
JsonObject query)
Find matching documents in the specified collection
|
MongoClient |
find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
ReadStream<JsonObject> |
findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
MongoClient |
findOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
MongoClient |
findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
findOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
findOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
findOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
MongoClient |
findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
MongoClient |
findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
findWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
MongoClient |
findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
getCollections()
Get a list of all collections in the database.
|
MongoClient |
getCollections(Handler<AsyncResult<List<String>>> resultHandler)
Get a list of all collections in the database.
|
MongoClient |
getDelegate() |
int |
hashCode() |
MongoClient |
insert(String collection,
JsonObject document)
Insert a document in the specified collection
|
MongoClient |
insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
MongoClient |
insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
MongoClient |
insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
MongoClient |
listIndexes(String collection)
Get all the indexes in this collection.
|
MongoClient |
listIndexes(String collection,
Handler<AsyncResult<JsonArray>> resultHandler)
Get all the indexes in this collection.
|
static MongoClient |
newInstance(MongoClient arg) |
MongoClient |
removeDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
removeDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
replaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
runCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
MongoClient |
runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Maybe<MongoClientBulkWriteResult> |
rxBulkWrite(String collection,
List<BulkOperation> operations)
Execute a bulk operation.
|
Maybe<MongoClientBulkWriteResult> |
rxBulkWriteWithOptions(String collection,
List<BulkOperation> operations,
BulkWriteOptions bulkWriteOptions)
Execute a bulk operation with the specified write options.
|
Completable |
rxClose()
Close the client and release its resources
|
Single<Long> |
rxCount(String collection,
JsonObject query)
Count matching documents in a collection.
|
Single<Long> |
rxCountWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
Completable |
rxCreateCollection(String collectionName)
Create a new collection
|
Completable |
rxCreateCollectionWithOptions(String collectionName,
CreateCollectionOptions collectionOptions)
Create a new collection with options
|
Single<MongoGridFsClient> |
rxCreateDefaultGridFsBucketService()
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
Single<MongoGridFsClient> |
rxCreateGridFsBucketService(String bucketName)
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
Completable |
rxCreateIndex(String collection,
JsonObject key)
Creates an index.
|
Completable |
rxCreateIndexes(String collection,
List<IndexModel> indexes)
creates an indexes
|
Completable |
rxCreateIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
Single<JsonArray> |
rxDistinct(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
rxDistinct(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
Single<JsonArray> |
rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Completable |
rxDropCollection(String collection)
Drop a collection
|
Completable |
rxDropIndex(String collection,
String indexName)
Drops the index given its name.
|
Single<List<JsonObject>> |
rxFind(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Maybe<JsonObject> |
rxFindOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Maybe<JsonObject> |
rxFindOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
rxFindOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
rxFindOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
rxFindOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
rxFindOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Maybe<JsonObject> |
rxFindOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
rxFindWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Single<List<String>> |
rxGetCollections()
Get a list of all collections in the database.
|
Maybe<String> |
rxInsert(String collection,
JsonObject document)
Insert a document in the specified collection
|
Maybe<String> |
rxInsertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
Single<JsonArray> |
rxListIndexes(String collection)
Get all the indexes in this collection.
|
Maybe<MongoClientDeleteResult> |
rxRemoveDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
rxRemoveDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
rxRemoveDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
rxRemoveDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientUpdateResult> |
rxReplaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
rxReplaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<JsonObject> |
rxRunCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
Maybe<String> |
rxSave(String collection,
JsonObject document)
Save a document in the specified collection
|
Maybe<String> |
rxSaveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
Maybe<MongoClientUpdateResult> |
rxUpdateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
rxUpdateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
save(String collection,
JsonObject document)
Save a document in the specified collection
|
MongoClient |
save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
MongoClient |
saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
MongoClient |
saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
String |
toString() |
MongoClient |
updateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
updateCollection(String collection,
JsonObject query,
JsonArray update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
updateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
public static final io.vertx.lang.rx.TypeArg<MongoClient> __TYPE_ARG
public static final String DEFAULT_POOL_NAME
public static final String DEFAULT_DB_NAME
public MongoClient(MongoClient delegate)
public MongoClient(Object delegate)
public MongoClient getDelegate()
public static MongoClient create(Vertx vertx, JsonObject config)
vertx
- the Vert.x instanceconfig
- the configurationpublic static MongoClient createShared(Vertx vertx, JsonObject config, String dataSourceName)
vertx
- the Vert.x instanceconfig
- the configurationdataSourceName
- the data source namepublic static MongoClient createShared(Vertx vertx, JsonObject config)
createShared(io.vertx.reactivex.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String)
but with the default data source namevertx
- the Vert.x instanceconfig
- the configurationpublic MongoClient save(String collection, JsonObject document, Handler<AsyncResult<String>> resultHandler)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentresultHandler
- result handler will be provided with the id if document didn't already have onepublic MongoClient save(String collection, JsonObject document)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentpublic Maybe<String> rxSave(String collection, JsonObject document)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentpublic MongoClient saveWithOptions(String collection, JsonObject document, WriteOption writeOption, Handler<AsyncResult<String>> resultHandler)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentwriteOption
- the write option to useresultHandler
- result handler will be provided with the id if document didn't already have onepublic MongoClient saveWithOptions(String collection, JsonObject document, WriteOption writeOption)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentwriteOption
- the write option to usepublic Maybe<String> rxSaveWithOptions(String collection, JsonObject document, WriteOption writeOption)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentwriteOption
- the write option to usepublic MongoClient insert(String collection, JsonObject document, Handler<AsyncResult<String>> resultHandler)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentresultHandler
- result handler will be provided with the id if document didn't already have onepublic MongoClient insert(String collection, JsonObject document)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentpublic Maybe<String> rxInsert(String collection, JsonObject document)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentpublic MongoClient insertWithOptions(String collection, JsonObject document, WriteOption writeOption, Handler<AsyncResult<String>> resultHandler)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentwriteOption
- the write option to useresultHandler
- result handler will be provided with the id if document didn't already have onepublic MongoClient insertWithOptions(String collection, JsonObject document, WriteOption writeOption)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentwriteOption
- the write option to usepublic Maybe<String> rxInsertWithOptions(String collection, JsonObject document, WriteOption writeOption)
This operation might change _id field of document parameter
collection
- the collectiondocument
- the documentwriteOption
- the write option to usepublic MongoClient updateCollection(String collection, JsonObject query, JsonObject update, Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedresultHandler
- will be called with a MongoClientUpdateResult
when completepublic MongoClient updateCollection(String collection, JsonObject query, JsonObject update)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedpublic Maybe<MongoClientUpdateResult> rxUpdateCollection(String collection, JsonObject query, JsonObject update)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedpublic MongoClient updateCollection(String collection, JsonObject query, JsonArray update, Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedresultHandler
- will be called with a MongoClientUpdateResult
when completepublic MongoClient updateCollection(String collection, JsonObject query, JsonArray update)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedpublic Maybe<MongoClientUpdateResult> rxUpdateCollection(String collection, JsonObject query, JsonArray update)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedpublic MongoClient updateCollectionWithOptions(String collection, JsonObject query, JsonObject update, UpdateOptions options, Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedoptions
- options to configure the updateresultHandler
- will be called with a MongoClientUpdateResult
when completepublic MongoClient updateCollectionWithOptions(String collection, JsonObject query, JsonObject update, UpdateOptions options)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedoptions
- options to configure the updatepublic Maybe<MongoClientUpdateResult> rxUpdateCollectionWithOptions(String collection, JsonObject query, JsonObject update, UpdateOptions options)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- used to describe how the documents will be updatedoptions
- options to configure the updatepublic MongoClient updateCollectionWithOptions(String collection, JsonObject query, JsonArray update, UpdateOptions options, Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- aggregation pipeline used to describe how documents will be updatedoptions
- options to configure the updateresultHandler
- will be called with a MongoClientUpdateResult
when completepublic MongoClient updateCollectionWithOptions(String collection, JsonObject query, JsonArray update, UpdateOptions options)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- aggregation pipeline used to describe how documents will be updatedoptions
- options to configure the updatepublic Maybe<MongoClientUpdateResult> rxUpdateCollectionWithOptions(String collection, JsonObject query, JsonArray update, UpdateOptions options)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsupdate
- aggregation pipeline used to describe how documents will be updatedoptions
- options to configure the updatepublic MongoClient replaceDocuments(String collection, JsonObject query, JsonObject replace, Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsreplace
- all matching documents will be replaced with thisresultHandler
- will be called with a MongoClientUpdateResult
when completepublic MongoClient replaceDocuments(String collection, JsonObject query, JsonObject replace)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsreplace
- all matching documents will be replaced with thispublic Maybe<MongoClientUpdateResult> rxReplaceDocuments(String collection, JsonObject query, JsonObject replace)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsreplace
- all matching documents will be replaced with thispublic MongoClient replaceDocumentsWithOptions(String collection, JsonObject query, JsonObject replace, UpdateOptions options, Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsreplace
- all matching documents will be replaced with thisoptions
- options to configure the replaceresultHandler
- will be called with a MongoClientUpdateResult
when completepublic MongoClient replaceDocumentsWithOptions(String collection, JsonObject query, JsonObject replace, UpdateOptions options)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsreplace
- all matching documents will be replaced with thisoptions
- options to configure the replacepublic Maybe<MongoClientUpdateResult> rxReplaceDocumentsWithOptions(String collection, JsonObject query, JsonObject replace, UpdateOptions options)
MongoClientUpdateResult
resultcollection
- the collectionquery
- query used to match the documentsreplace
- all matching documents will be replaced with thisoptions
- options to configure the replacepublic MongoClient bulkWrite(String collection, List<BulkOperation> operations, Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
collection
- the collectionoperations
- the operations to executeresultHandler
- will be called with a MongoClientBulkWriteResult
when completepublic MongoClient bulkWrite(String collection, List<BulkOperation> operations)
collection
- the collectionoperations
- the operations to executepublic Maybe<MongoClientBulkWriteResult> rxBulkWrite(String collection, List<BulkOperation> operations)
collection
- the collectionoperations
- the operations to executepublic MongoClient bulkWriteWithOptions(String collection, List<BulkOperation> operations, BulkWriteOptions bulkWriteOptions, Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
collection
- the collectionoperations
- the operations to executebulkWriteOptions
- the write optionsresultHandler
- will be called with a MongoClientBulkWriteResult
when completepublic MongoClient bulkWriteWithOptions(String collection, List<BulkOperation> operations, BulkWriteOptions bulkWriteOptions)
collection
- the collectionoperations
- the operations to executebulkWriteOptions
- the write optionspublic Maybe<MongoClientBulkWriteResult> rxBulkWriteWithOptions(String collection, List<BulkOperation> operations, BulkWriteOptions bulkWriteOptions)
collection
- the collectionoperations
- the operations to executebulkWriteOptions
- the write optionspublic MongoClient find(String collection, JsonObject query, Handler<AsyncResult<List<JsonObject>>> resultHandler)
collection
- the collectionquery
- query used to match documentsresultHandler
- will be provided with list of documentspublic MongoClient find(String collection, JsonObject query)
collection
- the collectionquery
- query used to match documentspublic Single<List<JsonObject>> rxFind(String collection, JsonObject query)
collection
- the collectionquery
- query used to match documentspublic ReadStream<JsonObject> findBatch(String collection, JsonObject query)
collection
- the collectionquery
- query used to match documentspublic MongoClient findWithOptions(String collection, JsonObject query, FindOptions options, Handler<AsyncResult<List<JsonObject>>> resultHandler)
collection
- the collectionquery
- query used to match documentsoptions
- options to configure the findresultHandler
- will be provided with list of documentspublic MongoClient findWithOptions(String collection, JsonObject query, FindOptions options)
collection
- the collectionquery
- query used to match documentsoptions
- options to configure the findpublic Single<List<JsonObject>> rxFindWithOptions(String collection, JsonObject query, FindOptions options)
collection
- the collectionquery
- query used to match documentsoptions
- options to configure the findpublic ReadStream<JsonObject> findBatchWithOptions(String collection, JsonObject query, FindOptions options)
collection
- the collectionquery
- query used to match documentsoptions
- options to configure the findpublic MongoClient findOne(String collection, JsonObject query, JsonObject fields, Handler<AsyncResult<JsonObject>> resultHandler)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentfields
- the fieldsresultHandler
- will be provided with the document, if anypublic MongoClient findOne(String collection, JsonObject query, JsonObject fields)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentfields
- the fieldspublic Maybe<JsonObject> rxFindOne(String collection, JsonObject query, JsonObject fields)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentfields
- the fieldspublic MongoClient findOneAndUpdate(String collection, JsonObject query, JsonObject update, Handler<AsyncResult<JsonObject>> resultHandler)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentupdate
- used to describe how the documents will be updatedresultHandler
- will be provided with the document, if anypublic MongoClient findOneAndUpdate(String collection, JsonObject query, JsonObject update)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentupdate
- used to describe how the documents will be updatedpublic Maybe<JsonObject> rxFindOneAndUpdate(String collection, JsonObject query, JsonObject update)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentupdate
- used to describe how the documents will be updatedpublic MongoClient findOneAndUpdateWithOptions(String collection, JsonObject query, JsonObject update, FindOptions findOptions, UpdateOptions updateOptions, Handler<AsyncResult<JsonObject>> resultHandler)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentupdate
- used to describe how the documents will be updatedfindOptions
- options to configure the findupdateOptions
- options to configure the updateresultHandler
- will be provided with the document, if anypublic MongoClient findOneAndUpdateWithOptions(String collection, JsonObject query, JsonObject update, FindOptions findOptions, UpdateOptions updateOptions)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentupdate
- used to describe how the documents will be updatedfindOptions
- options to configure the findupdateOptions
- options to configure the updatepublic Maybe<JsonObject> rxFindOneAndUpdateWithOptions(String collection, JsonObject query, JsonObject update, FindOptions findOptions, UpdateOptions updateOptions)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentupdate
- used to describe how the documents will be updatedfindOptions
- options to configure the findupdateOptions
- options to configure the updatepublic MongoClient findOneAndReplace(String collection, JsonObject query, JsonObject replace, Handler<AsyncResult<JsonObject>> resultHandler)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentreplace
- the replacement documentresultHandler
- will be provided with the document, if anypublic MongoClient findOneAndReplace(String collection, JsonObject query, JsonObject replace)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentreplace
- the replacement documentpublic Maybe<JsonObject> rxFindOneAndReplace(String collection, JsonObject query, JsonObject replace)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentreplace
- the replacement documentpublic MongoClient findOneAndReplaceWithOptions(String collection, JsonObject query, JsonObject replace, FindOptions findOptions, UpdateOptions updateOptions, Handler<AsyncResult<JsonObject>> resultHandler)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentreplace
- the replacement documentfindOptions
- options to configure the findupdateOptions
- options to configure the updateresultHandler
- will be provided with the document, if anypublic MongoClient findOneAndReplaceWithOptions(String collection, JsonObject query, JsonObject replace, FindOptions findOptions, UpdateOptions updateOptions)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentreplace
- the replacement documentfindOptions
- options to configure the findupdateOptions
- options to configure the updatepublic Maybe<JsonObject> rxFindOneAndReplaceWithOptions(String collection, JsonObject query, JsonObject replace, FindOptions findOptions, UpdateOptions updateOptions)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentreplace
- the replacement documentfindOptions
- options to configure the findupdateOptions
- options to configure the updatepublic MongoClient findOneAndDelete(String collection, JsonObject query, Handler<AsyncResult<JsonObject>> resultHandler)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentresultHandler
- will be provided with the deleted document, if anypublic MongoClient findOneAndDelete(String collection, JsonObject query)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentpublic Maybe<JsonObject> rxFindOneAndDelete(String collection, JsonObject query)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentpublic MongoClient findOneAndDeleteWithOptions(String collection, JsonObject query, FindOptions findOptions, Handler<AsyncResult<JsonObject>> resultHandler)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentfindOptions
- options to configure the findresultHandler
- will be provided with the deleted document, if anypublic MongoClient findOneAndDeleteWithOptions(String collection, JsonObject query, FindOptions findOptions)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentfindOptions
- options to configure the findpublic Maybe<JsonObject> rxFindOneAndDeleteWithOptions(String collection, JsonObject query, FindOptions findOptions)
This operation might change _id field of query parameter
collection
- the collectionquery
- the query used to match the documentfindOptions
- options to configure the findpublic MongoClient count(String collection, JsonObject query, Handler<AsyncResult<Long>> resultHandler)
collection
- the collectionquery
- query used to match documentsresultHandler
- will be provided with the number of matching documentspublic MongoClient count(String collection, JsonObject query)
collection
- the collectionquery
- query used to match documentspublic Single<Long> rxCount(String collection, JsonObject query)
collection
- the collectionquery
- query used to match documentspublic MongoClient countWithOptions(String collection, JsonObject query, CountOptions countOptions, Handler<AsyncResult<Long>> resultHandler)
collection
- the collectionquery
- query used to match documentscountOptions
- resultHandler
- will be provided with the number of matching documentspublic MongoClient countWithOptions(String collection, JsonObject query, CountOptions countOptions)
collection
- the collectionquery
- query used to match documentscountOptions
- public Single<Long> rxCountWithOptions(String collection, JsonObject query, CountOptions countOptions)
collection
- the collectionquery
- query used to match documentscountOptions
- public MongoClient removeDocuments(String collection, JsonObject query, Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentsresultHandler
- will be called with a MongoClientDeleteResult
when completepublic MongoClient removeDocuments(String collection, JsonObject query)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentspublic Maybe<MongoClientDeleteResult> rxRemoveDocuments(String collection, JsonObject query)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentspublic MongoClient removeDocumentsWithOptions(String collection, JsonObject query, WriteOption writeOption, Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentswriteOption
- the write option to useresultHandler
- will be called with a MongoClientDeleteResult
when completepublic MongoClient removeDocumentsWithOptions(String collection, JsonObject query, WriteOption writeOption)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentswriteOption
- the write option to usepublic Maybe<MongoClientDeleteResult> rxRemoveDocumentsWithOptions(String collection, JsonObject query, WriteOption writeOption)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentswriteOption
- the write option to usepublic MongoClient removeDocument(String collection, JsonObject query, Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentresultHandler
- will be called with a MongoClientDeleteResult
when completepublic MongoClient removeDocument(String collection, JsonObject query)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentpublic Maybe<MongoClientDeleteResult> rxRemoveDocument(String collection, JsonObject query)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentpublic MongoClient removeDocumentWithOptions(String collection, JsonObject query, WriteOption writeOption, Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentwriteOption
- the write option to useresultHandler
- will be called with a MongoClientDeleteResult
when completepublic MongoClient removeDocumentWithOptions(String collection, JsonObject query, WriteOption writeOption)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentwriteOption
- the write option to usepublic Maybe<MongoClientDeleteResult> rxRemoveDocumentWithOptions(String collection, JsonObject query, WriteOption writeOption)
MongoClientDeleteResult
resultcollection
- the collectionquery
- query used to match documentwriteOption
- the write option to usepublic MongoClient createCollection(String collectionName, Handler<AsyncResult<Void>> resultHandler)
collectionName
- the name of the collectionresultHandler
- will be called when completepublic MongoClient createCollection(String collectionName)
collectionName
- the name of the collectionpublic Completable rxCreateCollection(String collectionName)
collectionName
- the name of the collectionpublic MongoClient createCollectionWithOptions(String collectionName, CreateCollectionOptions collectionOptions, Handler<AsyncResult<Void>> resultHandler)
collectionName
- the name of the collectioncollectionOptions
- options of the collectionresultHandler
- will be called when completepublic MongoClient createCollectionWithOptions(String collectionName, CreateCollectionOptions collectionOptions)
collectionName
- the name of the collectioncollectionOptions
- options of the collectionpublic Completable rxCreateCollectionWithOptions(String collectionName, CreateCollectionOptions collectionOptions)
collectionName
- the name of the collectioncollectionOptions
- options of the collectionpublic MongoClient getCollections(Handler<AsyncResult<List<String>>> resultHandler)
resultHandler
- will be called with a list of collections.public MongoClient getCollections()
public Single<List<String>> rxGetCollections()
public MongoClient dropCollection(String collection, Handler<AsyncResult<Void>> resultHandler)
collection
- the collectionresultHandler
- will be called when completepublic MongoClient dropCollection(String collection)
collection
- the collectionpublic Completable rxDropCollection(String collection)
collection
- the collectionpublic MongoClient createIndex(String collection, JsonObject key, Handler<AsyncResult<Void>> resultHandler)
collection
- the collectionkey
- A document that contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.resultHandler
- will be called when completepublic MongoClient createIndex(String collection, JsonObject key)
collection
- the collectionkey
- A document that contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.public Completable rxCreateIndex(String collection, JsonObject key)
collection
- the collectionkey
- A document that contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.public MongoClient createIndexWithOptions(String collection, JsonObject key, IndexOptions options, Handler<AsyncResult<Void>> resultHandler)
collection
- the collectionkey
- A document that contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.options
- the options for the indexresultHandler
- will be called when completepublic MongoClient createIndexWithOptions(String collection, JsonObject key, IndexOptions options)
collection
- the collectionkey
- A document that contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.options
- the options for the indexpublic Completable rxCreateIndexWithOptions(String collection, JsonObject key, IndexOptions options)
collection
- the collectionkey
- A document that contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.options
- the options for the indexpublic MongoClient createIndexes(String collection, List<IndexModel> indexes, Handler<AsyncResult<Void>> resultHandler)
collection
- the collectionindexes
- A model that contains pairs of document and indexOptions, document contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.resultHandler
- will be called when completepublic MongoClient createIndexes(String collection, List<IndexModel> indexes)
collection
- the collectionindexes
- A model that contains pairs of document and indexOptions, document contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.public Completable rxCreateIndexes(String collection, List<IndexModel> indexes)
collection
- the collectionindexes
- A model that contains pairs of document and indexOptions, document contains the field and value pairs where the field is the index key and the value describes the type of index for that field. For an ascending index on a field, specify a value of 1; for descending index, specify a value of -1.public MongoClient listIndexes(String collection, Handler<AsyncResult<JsonArray>> resultHandler)
collection
- the collectionresultHandler
- will be called when completepublic MongoClient listIndexes(String collection)
collection
- the collectionpublic Single<JsonArray> rxListIndexes(String collection)
collection
- the collectionpublic MongoClient dropIndex(String collection, String indexName, Handler<AsyncResult<Void>> resultHandler)
collection
- the collectionindexName
- the name of the index to removeresultHandler
- will be called when completepublic MongoClient dropIndex(String collection, String indexName)
collection
- the collectionindexName
- the name of the index to removepublic Completable rxDropIndex(String collection, String indexName)
collection
- the collectionindexName
- the name of the index to removepublic MongoClient runCommand(String commandName, JsonObject command, Handler<AsyncResult<JsonObject>> resultHandler)
commandName
- the name of the commandcommand
- the commandresultHandler
- will be called with the result.public MongoClient runCommand(String commandName, JsonObject command)
commandName
- the name of the commandcommand
- the commandpublic Maybe<JsonObject> rxRunCommand(String commandName, JsonObject command)
commandName
- the name of the commandcommand
- the commandpublic MongoClient distinct(String collection, String fieldName, String resultClassname, Handler<AsyncResult<JsonArray>> resultHandler)
collection
- the collectionfieldName
- the field nameresultClassname
- resultHandler
- will be provided with array of values.public MongoClient distinct(String collection, String fieldName, String resultClassname)
collection
- the collectionfieldName
- the field nameresultClassname
- public Single<JsonArray> rxDistinct(String collection, String fieldName, String resultClassname)
collection
- the collectionfieldName
- the field nameresultClassname
- public MongoClient distinct(String collection, String fieldName, String resultClassname, DistinctOptions distinctOptions, Handler<AsyncResult<JsonArray>> resultHandler)
collection
- the collectionfieldName
- the field nameresultClassname
- distinctOptions
- options (e.g. collation)resultHandler
- will be provided with array of values.public MongoClient distinct(String collection, String fieldName, String resultClassname, DistinctOptions distinctOptions)
collection
- the collectionfieldName
- the field nameresultClassname
- distinctOptions
- options (e.g. collation)public Single<JsonArray> rxDistinct(String collection, String fieldName, String resultClassname, DistinctOptions distinctOptions)
collection
- the collectionfieldName
- the field nameresultClassname
- distinctOptions
- options (e.g. collation)public MongoClient distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, Handler<AsyncResult<JsonArray>> resultHandler)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the queryresultHandler
- will be provided with array of values.public MongoClient distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querypublic Single<JsonArray> rxDistinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querypublic MongoClient distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, DistinctOptions distinctOptions, Handler<AsyncResult<JsonArray>> resultHandler)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querydistinctOptions
- options (e.g. collation)resultHandler
- will be provided with array of values.public MongoClient distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, DistinctOptions distinctOptions)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querydistinctOptions
- options (e.g. collation)public Single<JsonArray> rxDistinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, DistinctOptions distinctOptions)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querydistinctOptions
- options (e.g. collation)public ReadStream<JsonObject> distinctBatch(String collection, String fieldName, String resultClassname)
collection
- the collectionfieldName
- the field nameresultClassname
- public ReadStream<JsonObject> distinctBatch(String collection, String fieldName, String resultClassname, DistinctOptions distinctOptions)
collection
- the collectionfieldName
- the field nameresultClassname
- distinctOptions
- options (e.g. collation)public ReadStream<JsonObject> distinctBatchWithQuery(String collection, String fieldName, String resultClassname, JsonObject query)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querypublic ReadStream<JsonObject> distinctBatchWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, DistinctOptions distinctOptions)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querydistinctOptions
- options (e.g. collation)public ReadStream<JsonObject> distinctBatchWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, int batchSize)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querybatchSize
- the number of documents to load in a batchpublic ReadStream<JsonObject> distinctBatchWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, int batchSize, DistinctOptions distinctOptions)
collection
- the collectionfieldName
- the field nameresultClassname
- query
- the querybatchSize
- the number of documents to load in a batchdistinctOptions
- options (e.g. collation)public ReadStream<JsonObject> aggregate(String collection, JsonArray pipeline)
AggregateOptions
.collection
- the collectionpipeline
- aggregation pipeline to be executedpublic ReadStream<JsonObject> aggregateWithOptions(String collection, JsonArray pipeline, AggregateOptions options)
collection
- the collectionpipeline
- aggregation pipeline to be executedoptions
- options to configure the aggregation commandpublic MongoClient createDefaultGridFsBucketService(Handler<AsyncResult<MongoGridFsClient>> resultHandler)
MongoGridFsClient
used to interact with Mongo GridFS.resultHandler
- the MongoGridFsClient
to interact with the bucket named bucketNamepublic MongoClient createDefaultGridFsBucketService()
MongoGridFsClient
used to interact with Mongo GridFS.public Single<MongoGridFsClient> rxCreateDefaultGridFsBucketService()
MongoGridFsClient
used to interact with Mongo GridFS.public MongoClient createGridFsBucketService(String bucketName, Handler<AsyncResult<MongoGridFsClient>> resultHandler)
MongoGridFsClient
used to interact with Mongo GridFS.bucketName
- the name of the GridFS bucketresultHandler
- the MongoGridFsClient
to interact with the bucket named bucketNamepublic MongoClient createGridFsBucketService(String bucketName)
MongoGridFsClient
used to interact with Mongo GridFS.bucketName
- the name of the GridFS bucketpublic Single<MongoGridFsClient> rxCreateGridFsBucketService(String bucketName)
MongoGridFsClient
used to interact with Mongo GridFS.bucketName
- the name of the GridFS bucketpublic void close(Handler<AsyncResult<Void>> handler)
handler
- public void close()
public Completable rxClose()
public ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> watch(String collection, JsonArray pipeline, boolean withUpdatedDoc, int batchSize)
collection
- the collectionpipeline
- watching pipeline to be executedwithUpdatedDoc
- whether to get updated fullDocument for "update" operationbatchSize
- the number of documents to load in a batchpublic static MongoClient newInstance(MongoClient arg)
Copyright © 2024 Eclipse. All rights reserved.