public class

MongoClientImpl

extends Object
implements MongoClient
java.lang.Object
   ↳ org.mule.module.mongo.api.MongoClientImpl

Summary

Fields
private final DB db
private static final Logger logger
Public Constructors
MongoClientImpl(DB db)
Public Methods
WriteResult addUser(String username, String password)
void close()
long countObjects(String collection, DBObject query)
void createCollection(String collection, boolean capped, Integer maxObjects, Integer size)
DBObject createFile(InputStream content, String filename, String contentType, DBObject metadata)
void createIndex(String collection, String field, IndexOrder order)
void dropCollection(String collection)
void dropDatabase()
void dropIndex(String collection, String name)
DBObject executeComamnd(DBObject command)
boolean existsCollection(String collection)
Iterable<DBObject> findFiles(DBObject query)
Iterable<DBObject> findObjects(String collection, DBObject query, List<String> fields, Integer numToSkip, Integer limit, DBObject sortBy)
DBObject findOneFile(DBObject query)
DBObject findOneObject(String collection, DBObject query, List<String> fields, boolean failOnNotFound)
DBCollection getCollection(String collection)
DB getDb()
InputStream getFileContent(DBObject query)
String insertObject(String collection, DBObject object, WriteConcern writeConcern)
Collection<String> listCollections()
Iterable<DBObject> listFiles(DBObject query)
Collection<DBObject> listIndices(String collection)
Iterable<DBObject> mapReduceObjects(String collection, String mapFunction, String reduceFunction, String outputCollection)
void removeFiles(DBObject query)
void removeObjects(String collection, DBObject query, WriteConcern writeConcern)
void requestDone()
void requestStart()
void saveObject(String collection, DBObject object, WriteConcern writeConcern)
void updateObjects(String collection, DBObject query, DBObject object, boolean upsert, boolean multi, WriteConcern writeConcern)
Protected Methods
GridFS getGridFs()
[Expand]
Inherited Methods
From class java.lang.Object
From interface java.io.Closeable
From interface java.lang.AutoCloseable
From interface org.mule.module.mongo.api.MongoClient

Fields

private final DB db

private static final Logger logger

Public Constructors

public MongoClientImpl (DB db)

Parameters
db

Public Methods

public WriteResult addUser (String username, String password)

Parameters
username
password

public void close ()

Throws
IOException

public long countObjects (String collection, DBObject query)

Parameters
collection
query

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

Parameters
collection
capped
maxObjects
size

public DBObject createFile (InputStream content, String filename, String contentType, DBObject metadata)

Parameters
content
filename
contentType
metadata

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

Parameters
collection
field
order

public void dropCollection (String collection)

Parameters
collection

public void dropDatabase ()

public void dropIndex (String collection, String name)

Parameters
collection
name

public DBObject executeComamnd (DBObject command)

Parameters
command

public boolean existsCollection (String collection)

Parameters
collection

public Iterable<DBObject> findFiles (DBObject query)

Parameters
query

public Iterable<DBObject> findObjects (String collection, DBObject query, List<String> fields, Integer numToSkip, Integer limit, DBObject sortBy)

Parameters
collection
query
fields
numToSkip
limit
sortBy

public DBObject findOneFile (DBObject query)

Parameters
query

public DBObject findOneObject (String collection, DBObject query, List<String> fields, boolean failOnNotFound)

Parameters
collection
query
fields
failOnNotFound

public DBCollection getCollection (String collection)

Parameters
collection

public DB getDb ()

public InputStream getFileContent (DBObject query)

Parameters
query

public String insertObject (String collection, DBObject object, WriteConcern writeConcern)

Parameters
collection
object
writeConcern

public Collection<String> listCollections ()

public Iterable<DBObject> listFiles (DBObject query)

Parameters
query

public Collection<DBObject> listIndices (String collection)

Parameters
collection

public Iterable<DBObject> mapReduceObjects (String collection, String mapFunction, String reduceFunction, String outputCollection)

Parameters
collection
mapFunction
reduceFunction
outputCollection

public void removeFiles (DBObject query)

Parameters
query

public void removeObjects (String collection, DBObject query, WriteConcern writeConcern)

Parameters
collection
query
writeConcern

public void requestDone ()

public void requestStart ()

public void saveObject (String collection, DBObject object, WriteConcern writeConcern)

Parameters
collection
object
writeConcern

public void updateObjects (String collection, DBObject query, DBObject object, boolean upsert, boolean multi, WriteConcern writeConcern)

Parameters
collection
query
object
upsert
multi
writeConcern

Protected Methods

protected GridFS getGridFs ()