org.apache.storm.mongodb.common

Class MongoDBClient

java.lang.Object

org.apache.storm.mongodb.common.MongoDBClient

public class MongoDBClient
extends Object

Constructor Summary

Constructors

Constructor and Description
MongoDBClient(String url, String collectionName)

Method Summary

Modifier and Type	Method and Description
void	close() Closes all resources associated with this instance.
void	insert(List<org.bson.Document> documents, boolean ordered) Inserts one or more documents.
void	update(org.bson.conversions.Bson filter, org.bson.conversions.Bson update, boolean upsert) Update all documents in the collection according to the specified query filter.

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoDBClient

public MongoDBClient(String url,
                     String collectionName)

Method Detail

insert

public void insert(List<org.bson.Document> documents,
                   boolean ordered)

Inserts one or more documents. This method is equivalent to a call to the bulkWrite method. The documents will be inserted in the order provided, stopping on the first failed insertion.

Parameters:

documents -

update

public void update(org.bson.conversions.Bson filter,
                   org.bson.conversions.Bson update,
                   boolean upsert)

Update all documents in the collection according to the specified query filter. When upsert set to true, the new document will be inserted if there are no matches to the query filter.

Parameters:

filter -

update -

upsert -

close

public void close()

Closes all resources associated with this instance.