org.mule.modules.mongo.api

Class MongoClientImpl

java.lang.Object

org.mule.modules.mongo.api.MongoClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, MongoClient

public class MongoClientImpl
extends Object
implements MongoClient

Constructor Summary

Constructors

Constructor and Description
MongoClientImpl(com.mongodb.MongoClient mongo, String database)

Method Summary

Methods

Modifier and Type	Method and Description
org.bson.Document	addUser(String username, String password)
void	close()
long	countObjects(String collection, org.bson.conversions.Bson query)
void	createCollection(String collection, boolean capped, Integer maxObjects, Integer size)
com.mongodb.DBObject	createFile(InputStream content, String filename, String contentType, com.mongodb.DBObject metadata)
void	createIndex(String collection, String field, IndexOrder order)
void	dropCollection(String collection)
void	dropDatabase()
void	dropIndex(String collection, String name)
org.bson.Document	executeCommand(org.bson.Document command)
boolean	existsCollection(String collection)
Iterable<com.mongodb.DBObject>	findFiles(com.mongodb.DBObject query)
Iterable<org.bson.Document>	findObjects(String collection, org.bson.Document query, List<String> fields, Integer numToSkip, Integer limit, org.bson.Document sortBy)
com.mongodb.DBObject	findOneFile(com.mongodb.DBObject query)
org.bson.Document	findOneObject(String collection, org.bson.Document query, List<String> fields, boolean failOnNotFound)
com.mongodb.client.MongoCollection<org.bson.Document>	getCollection(String collection)
String	getConnectionId()
com.mongodb.client.MongoDatabase	getDatabase(String databaseName)
com.mongodb.client.MongoDatabase	getDb()
InputStream	getFileContent(com.mongodb.DBObject query)
protected com.mongodb.gridfs.GridFS	getGridFs()
String	insertObject(String collection, org.bson.Document document)
boolean	isAlive()
Iterable<String>	listCollections()
Iterable<com.mongodb.DBObject>	listFiles(com.mongodb.DBObject query)
Collection<org.bson.Document>	listIndices(String collection)
Iterable<org.bson.Document>	mapReduceObjects(String collection, String mapFunction, String reduceFunction, String outputCollection)
void	removeFiles(com.mongodb.DBObject query)
void	removeObjects(String collection, org.bson.conversions.Bson query)
void	saveObject(String collectionName, org.bson.Document document)
org.bson.Document	updateObjects(String collection, org.bson.Document query, org.bson.Document document, boolean multi, boolean upsert)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoClientImpl

public MongoClientImpl(com.mongodb.MongoClient mongo,
               String database)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getDatabase

public com.mongodb.client.MongoDatabase getDatabase(String databaseName)

Specified by:

getDatabase in interface MongoClient

countObjects

public long countObjects(@NotNull
                String collection,
                org.bson.conversions.Bson query)

Specified by:

countObjects in interface MongoClient

createCollection

public void createCollection(@NotNull
                    String collection,
                    boolean capped,
                    Integer maxObjects,
                    Integer size)

Specified by:

createCollection in interface MongoClient

getCollection

public com.mongodb.client.MongoCollection<org.bson.Document> getCollection(@NotNull
                                                                  String collection)

Specified by:

getCollection in interface MongoClient

addUser

public org.bson.Document addUser(String username,
                        String password)

Specified by:

addUser in interface MongoClient

dropDatabase

public void dropDatabase()

Specified by:

dropDatabase in interface MongoClient

dropCollection

public void dropCollection(@NotNull
                  String collection)

Specified by:

dropCollection in interface MongoClient

existsCollection

public boolean existsCollection(@NotNull
                       String collection)

Specified by:

existsCollection in interface MongoClient

findObjects

public Iterable<org.bson.Document> findObjects(@NotNull
                                      String collection,
                                      @NotNull
                                      org.bson.Document query,
                                      List<String> fields,
                                      Integer numToSkip,
                                      Integer limit,
                                      org.bson.Document sortBy)

Specified by:

findObjects in interface MongoClient

findOneObject

public org.bson.Document findOneObject(@NotNull
                              String collection,
                              @NotNull
                              org.bson.Document query,
                              List<String> fields,
                              boolean failOnNotFound)

Specified by:

findOneObject in interface MongoClient

insertObject

public String insertObject(@NotNull
                  String collection,
                  @NotNull
                  org.bson.Document document)

Specified by:

insertObject in interface MongoClient

listCollections

public Iterable<String> listCollections()

Specified by:

listCollections in interface MongoClient

mapReduceObjects

public Iterable<org.bson.Document> mapReduceObjects(@NotNull
                                           String collection,
                                           @NotNull
                                           String mapFunction,
                                           @NotNull
                                           String reduceFunction,
                                           String outputCollection)

Specified by:

mapReduceObjects in interface MongoClient

removeObjects

public void removeObjects(@NotNull
                 String collection,
                 @NotNull
                 org.bson.conversions.Bson query)

Specified by:

removeObjects in interface MongoClient

saveObject

public void saveObject(@NotNull
              String collectionName,
              @NotNull
              org.bson.Document document)

Specified by:

saveObject in interface MongoClient

updateObjects

public org.bson.Document updateObjects(@NotNull
                              String collection,
                              @NotNull
                              org.bson.Document query,
                              org.bson.Document document,
                              boolean multi,
                              boolean upsert)

Specified by:

updateObjects in interface MongoClient

createIndex

public void createIndex(String collection,
               String field,
               IndexOrder order)

Specified by:

createIndex in interface MongoClient

dropIndex

public void dropIndex(String collection,
             String name)

Specified by:

dropIndex in interface MongoClient

listIndices

public Collection<org.bson.Document> listIndices(String collection)

Specified by:

listIndices in interface MongoClient

createFile

public com.mongodb.DBObject createFile(@NotNull
                              InputStream content,
                              @NotNull
                              String filename,
                              String contentType,
                              com.mongodb.DBObject metadata)

Specified by:

createFile in interface MongoClient

findFiles

public Iterable<com.mongodb.DBObject> findFiles(com.mongodb.DBObject query)

Specified by:

findFiles in interface MongoClient

findOneFile

public com.mongodb.DBObject findOneFile(@NotNull
                               com.mongodb.DBObject query)

Specified by:

findOneFile in interface MongoClient

getFileContent

public InputStream getFileContent(@NotNull
                         com.mongodb.DBObject query)

Specified by:

getFileContent in interface MongoClient

listFiles

public Iterable<com.mongodb.DBObject> listFiles(@NotNull
                                       com.mongodb.DBObject query)

Specified by:

listFiles in interface MongoClient

removeFiles

public void removeFiles(@NotNull
               com.mongodb.DBObject query)

Specified by:

removeFiles in interface MongoClient

executeCommand

public org.bson.Document executeCommand(org.bson.Document command)

Specified by:

executeCommand in interface MongoClient

getGridFs

protected com.mongodb.gridfs.GridFS getGridFs()

getDb

public com.mongodb.client.MongoDatabase getDb()

isAlive

public boolean isAlive()

Specified by:

isAlive in interface MongoClient

getConnectionId

public String getConnectionId()

Specified by:

getConnectionId in interface MongoClient