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

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.client.gridfs.model.GridFSFile	createFile(InputStream content, String filename, org.bson.Document 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	existDatabase(String name)
boolean	existsCollection(String collection)
org.bson.Document	findAndUpdateObject(String collection, org.bson.Document query, org.bson.Document update, List<String> fields, boolean returnNew, org.bson.Document sortBy, boolean remove, boolean upsert, boolean bypassDocumentValidation, boolean returnId)
Iterable<com.mongodb.client.gridfs.model.GridFSFile>	findFiles(org.bson.Document query)
Iterable<org.bson.Document>	findObjects(String collection, org.bson.Document query, List<String> fields, Integer numToSkip, Integer limit, org.bson.Document sortBy)
Iterable<org.bson.Document>	findObjects(String collection, org.bson.Document query, List<String> fields, Integer numToSkip, Integer limit, org.bson.Document sortBy, boolean returnId)
com.mongodb.client.gridfs.model.GridFSFile	findOneFile(org.bson.Document query)
org.bson.Document	findOneObject(String collection, org.bson.Document query, List<String> fields, boolean failOnNotFound, boolean returnId)
com.mongodb.client.MongoCollection<org.bson.Document>	getCollection(String collection)
String	getConnectionId()
com.mongodb.client.MongoDatabase	getDatabase(String databaseName)
InputStream	getFileContent(org.bson.types.ObjectId id)
protected com.mongodb.client.gridfs.GridFSBucket	getGridFs()
String	insertObject(String collection, org.bson.Document document)
org.bson.Document	insertObjects(String collection, List<org.bson.Document> documents, boolean ordered)
boolean	isAlive()
Iterable<String>	listCollections()
Iterable<com.mongodb.client.gridfs.model.GridFSFile>	listFiles(org.bson.Document query)
Collection<org.bson.Document>	listIndices(String collection)
Iterable<org.bson.Document>	mapReduceObjects(String collection, String mapFunction, String reduceFunction, String outputCollection)
void	removeFiles(org.bson.BsonObjectId id)
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

existDatabase

public boolean existDatabase(String name)

Specified by:

existDatabase 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

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,
                                               boolean returnId)

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,
                                       boolean returnId)

Specified by:

findOneObject in interface MongoClient

insertObject

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

Specified by:

insertObject in interface MongoClient

insertObjects

public org.bson.Document insertObjects(String collection,
                                       List<org.bson.Document> documents,
                                       boolean ordered)

Specified by:

insertObjects 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.client.gridfs.model.GridFSFile createFile(@NotNull
                                                             InputStream content,
                                                             @NotNull
                                                             String filename,
                                                             org.bson.Document metadata)

Specified by:

createFile in interface MongoClient

findFiles

public Iterable<com.mongodb.client.gridfs.model.GridFSFile> findFiles(@NotNull
                                                                      org.bson.Document query)

Specified by:

findFiles in interface MongoClient

findOneFile

public com.mongodb.client.gridfs.model.GridFSFile findOneFile(@NotNull
                                                              org.bson.Document query)

Specified by:

findOneFile in interface MongoClient

findAndUpdateObject

public org.bson.Document findAndUpdateObject(@NotNull
                                             String collection,
                                             @NotNull
                                             org.bson.Document query,
                                             @NotNull
                                             org.bson.Document update,
                                             List<String> fields,
                                             boolean returnNew,
                                             org.bson.Document sortBy,
                                             boolean remove,
                                             boolean upsert,
                                             boolean bypassDocumentValidation,
                                             boolean returnId)

Specified by:

findAndUpdateObject in interface MongoClient

getFileContent

public InputStream getFileContent(@NotNull
                                  org.bson.types.ObjectId id)

Specified by:

getFileContent in interface MongoClient

listFiles

public Iterable<com.mongodb.client.gridfs.model.GridFSFile> listFiles(org.bson.Document query)

Specified by:

listFiles in interface MongoClient

removeFiles

public void removeFiles(org.bson.BsonObjectId id)

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.client.gridfs.GridFSBucket getGridFs()

isAlive

public boolean isAlive()

Specified by:

isAlive in interface MongoClient

getConnectionId

public String getConnectionId()

Specified by:

getConnectionId in interface MongoClient