info.pascalkrause.vertx.mongodata.datasource

Class MongoClientDataSource

java.lang.Object

info.pascalkrause.vertx.mongodata.datasource.MongoClientDataSource

All Implemented Interfaces:

MongoDataSource

public class MongoClientDataSource
extends java.lang.Object
implements MongoDataSource

Constructor Summary

Constructors

Constructor and Description
MongoClientDataSource(io.vertx.ext.mongo.MongoClient client)

Method Summary

Modifier and Type	Method and Description
MongoDataSource	bulkInsert(java.lang.String collection, java.util.List<io.vertx.core.json.JsonObject> documents, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> resultHandler) Insert many documents into the collection.
MongoDataSource	count(java.lang.String collection, io.vertx.core.json.JsonObject query, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> resultHandler) Count matching documents in a collection.
MongoDataSource	createIndex(java.lang.String collection, Index index, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler) Creates an index on the collection.
MongoDataSource	deleteIndex(java.lang.String collection, java.lang.String name, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler) Deletes an index.
MongoDataSource	dropCollection(java.lang.String collection, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler) Drops the collection.
MongoDataSource	find(java.lang.String collection, io.vertx.core.json.JsonObject query, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.core.json.JsonObject>>> resultHandler) Find matching documents in the specified collection
MongoDataSource	listIndexes(java.lang.String collection, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonArray>> resultHandler) List all indexes.
MongoDataSource	removeDocuments(java.lang.String collection, io.vertx.core.json.JsonObject query, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> resultHandler) Remove matching documents in a collection.
MongoDataSource	upsert(java.lang.String collection, io.vertx.core.json.JsonObject document, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>> resultHandler) Insert or update a document into the collection.

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoClientDataSource

public MongoClientDataSource(io.vertx.ext.mongo.MongoClient client)

Method Detail

count

public MongoDataSource count(java.lang.String collection,
                             io.vertx.core.json.JsonObject query,
                             io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> resultHandler)

Description copied from interface: MongoDataSource

Count matching documents in a collection.

Specified by:

count in interface MongoDataSource

Parameters:

collection - the collection

query - query used to match documents

resultHandler - will be provided with the number of matching documents

Returns:

The actual instance of MongoDataSource.

find

public MongoDataSource find(java.lang.String collection,
                            io.vertx.core.json.JsonObject query,
                            io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.core.json.JsonObject>>> resultHandler)

Description copied from interface: MongoDataSource

Find matching documents in the specified collection

Specified by:

find in interface MongoDataSource

Parameters:

collection - the collection

query - query used to match documents

resultHandler - will be provided with list of documents

Returns:

The actual instance of MongoDataSource.

upsert

public MongoDataSource upsert(java.lang.String collection,
                              io.vertx.core.json.JsonObject document,
                              io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>> resultHandler)

Description copied from interface: MongoDataSource

Insert or update a document into the collection.

Specified by:

upsert in interface MongoDataSource

Parameters:

collection - the collection

document - The document to insert or update.

resultHandler - A handler to handle the AsnycResult which contains a String with the new id (insert), or null (update).

Returns:

The actual instance of MongoDataSource.

bulkInsert

public MongoDataSource bulkInsert(java.lang.String collection,
                                  java.util.List<io.vertx.core.json.JsonObject> documents,
                                  io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> resultHandler)

Description copied from interface: MongoDataSource

Insert many documents into the collection.

Specified by:

bulkInsert in interface MongoDataSource

Parameters:

collection - the collection

documents - A collection of resources to insert into the collection.

resultHandler - A handler to handle the AsnycResult which contains the number of inserted documents.

Returns:

The actual instance of MongoDataSource.

removeDocuments

public MongoDataSource removeDocuments(java.lang.String collection,
                                       io.vertx.core.json.JsonObject query,
                                       io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> resultHandler)

Description copied from interface: MongoDataSource

Remove matching documents in a collection.

Specified by:

removeDocuments in interface MongoDataSource

Parameters:

collection - the collection

query - A filter for the remove request.

resultHandler - A handler to handle the AsnycResult which contains the number of deleted entries.

Returns:

The actual instance of MongoDataSource.

dropCollection

public MongoDataSource dropCollection(java.lang.String collection,
                                      io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler)

Description copied from interface: MongoDataSource

Drops the collection.

Specified by:

dropCollection in interface MongoDataSource

Parameters:

collection - The collection.

resultHandler - will be called when complete

Returns:

The actual instance of MongoDataSource.

createIndex

public MongoDataSource createIndex(java.lang.String collection,
                                   Index index,
                                   io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler)

Description copied from interface: MongoDataSource

Creates an index on the collection. If there is already an index with this name, it will be overridden.

Specified by:

createIndex in interface MongoDataSource

Parameters:

collection - The collection.

resultHandler - A handler which will be called when the index is created.

Returns:

The actual MongoDataSource.

listIndexes

public MongoDataSource listIndexes(java.lang.String collection,
                                   io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonArray>> resultHandler)

Description copied from interface: MongoDataSource

List all indexes.

Specified by:

listIndexes in interface MongoDataSource

Parameters:

collection - The collection.

resultHandler - A handler which contains a JsonArray including indexes.

Returns:

The actual MongoDataSource.

deleteIndex

public MongoDataSource deleteIndex(java.lang.String collection,
                                   java.lang.String name,
                                   io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler)

Description copied from interface: MongoDataSource

Deletes an index.

Specified by:

deleteIndex in interface MongoDataSource

Parameters:

collection - The collection.

name - The name of the index which should be deleted.

resultHandler - A handler which will be called when the index is deleted.

Returns:

The actual MongoDataSource.