|
virtual std::auto_ptr< DBClientCursor > | query (const std::string &ns, Query query, int nToReturn=0, int nToSkip=0, const BSONObj *fieldsToReturn=0, int queryOptions=0, int batchSize=0) |
| send a query to the database. More...
|
|
virtual void | parallelScan (const StringData &ns, int numCursors, std::vector< DBClientCursor * > *cursors, stdx::function< DBClientBase *()> connectionFactory) |
| Returns a list of up to 'numCursors' cursors that can be iterated concurrently. More...
|
|
virtual unsigned long long | query (stdx::function< void(const BSONObj &)> f, const std::string &ns, Query query, const BSONObj *fieldsToReturn=0, int queryOptions=0) |
| Uses QueryOption_Exhaust, when available. More...
|
|
virtual std::auto_ptr< DBClientCursor > | getMore (const std::string &ns, long long cursorId, int nToReturn=0, int options=0) |
| don't use this - called automatically by DBClientCursor for you More...
|
|
virtual void | insert (const std::string &ns, BSONObj obj, int flags=0, const WriteConcern *wc=NULL) |
| insert an object into the database
|
|
virtual void | insert (const std::string &ns, const std::vector< BSONObj > &v, int flags=0, const WriteConcern *wc=NULL) |
| insert a vector of objects into the database
|
|
virtual void | update (const std::string &ns, Query query, BSONObj obj, bool upsert=false, bool multi=false, const WriteConcern *wc=NULL) |
| updates objects matching query
|
|
BSONObj | findAndModify (const StringData &ns, const BSONObj &query, const BSONObj &update, bool upsert=false, bool returnNew=false, const BSONObj &sort=BSONObj(), const BSONObj &fields=BSONObj(), const WriteConcern *wc=NULL, bool bypassDocumentValidation=false) |
| Modifies and returns a single document. More...
|
|
BSONObj | findAndRemove (const StringData &ns, const BSONObj &query, const BSONObj &sort=BSONObj(), const BSONObj &fields=BSONObj(), const WriteConcern *wc=NULL) |
| Removes and returns a single document. More...
|
|
virtual BulkOperationBuilder | initializeUnorderedBulkOp (const std::string &ns) |
| Initializes an unordered bulk operation by returning an object that can be used to enqueue multiple operations for batch execution. More...
|
|
virtual BulkOperationBuilder | initializeOrderedBulkOp (const std::string &ns) |
| Initializes an ordered bulk operation by returning an object that can be used to enqueue multiple operations for batch execution. More...
|
|
virtual void | remove (const std::string &ns, Query q, bool justOne=0, const WriteConcern *wc=NULL) |
| remove matching objects from the database More...
|
|
virtual bool | isStillConnected ()=0 |
| if not checked recently, checks whether the underlying socket/sockets are still valid
|
|
Public Member Functions inherited from mongo::DBClientWithCommands |
bool | simpleCommand (const std::string &dbname, BSONObj *info, const std::string &command) |
| helper function. More...
|
|
virtual bool | runCommand (const std::string &dbname, const BSONObj &cmd, BSONObj &info, int options=0) |
| Run a database command. More...
|
|
void | auth (const BSONObj ¶ms) |
| Authenticate a user. More...
|
|
bool | auth (const std::string &dbname, const std::string &username, const std::string &pwd, std::string &errmsg, bool digestPassword=true) |
| Authorize access to a particular database. More...
|
|
virtual void | logout (const std::string &dbname, BSONObj &info) |
| Logs out the connection for the given database. More...
|
|
virtual unsigned long long | count (const std::string &ns, const Query &query=Query(), int options=0, int limit=0, int skip=0) |
| count number of objects in collection ns that match the query criteria specified throws UserAssertion if database returns an error
|
|
virtual bool | isMaster (bool &isMaster, BSONObj *info=0) |
| returns true in isMaster parm if this db is the current master of a replica pair. More...
|
|
bool | createCollection (const std::string &ns, long long size=0, bool capped=false, int max=0, BSONObj *info=0) |
| Create a new collection in the database. More...
|
|
bool | createCollectionWithOptions (const std::string &ns, long long size=0, bool capped=false, int max=0, const BSONObj &extraOptions=BSONObj(), BSONObj *info=0) |
| Creates a new collection in the database. More...
|
|
std::string | getLastError (const std::string &db, bool fsync=false, bool j=false, int w=0, int wtimeout=0) |
| Get error result from the last write operation (insert/update/delete) on this connection. More...
|
|
std::string | getLastError (bool fsync=false, bool j=false, int w=0, int wtimeout=0) |
| Same as the form of getLastError that takes a dbname, but just uses the admin DB.
|
|
virtual BSONObj | getLastErrorDetailed (const std::string &db, bool fsync=false, bool j=false, int w=0, int wtimeout=0) |
| Get error result from the last write operation (insert/update/delete) on this connection. More...
|
|
virtual BSONObj | getLastErrorDetailed (bool fsync=false, bool j=false, int w=0, int wtimeout=0) |
| Same as the form of getLastErrorDetailed that takes a dbname, but just uses the admin DB.
|
|
BSONObj | getPrevError () |
| Return the last error which has occurred, even if not the very last operation. More...
|
|
bool | resetError () |
| Reset the previous error state for this connection (accessed via getLastError and getPrevError). More...
|
|
virtual bool | dropCollection (const std::string &ns, BSONObj *info=NULL) |
| Delete the specified collection. More...
|
|
bool | repairDatabase (const std::string &dbname, BSONObj *info=0) |
| Perform a repair and compaction of the specified database. More...
|
|
bool | copyDatabase (const std::string &fromdb, const std::string &todb, const std::string &fromhost="", const std::string &mechanism="DEFAULT", const std::string &username="", const std::string &password="", BSONObj *info=0) |
| Copy database from one server or name to another server or name. More...
|
|
BSONObj | mapreduce (const std::string &ns, const std::string &jsmapf, const std::string &jsreducef, Query query=Query(), MROutput output=MRInline) |
| Run a map/reduce job on the server. More...
|
|
void | group (const StringData &ns, const StringData &jsreduce, std::vector< BSONObj > *output, const BSONObj &initial=BSONObj(), const Query &query=Query(), const BSONObj &key=BSONObj(), const StringData &finalize="") |
| Groups documents in a collection by the specified key and performs simple aggregation functions such as computing counts and sums. More...
|
|
void | groupWithKeyFunction (const StringData &ns, const StringData &jsreduce, std::vector< BSONObj > *output, const BSONObj &initial=BSONObj(), const Query &query=Query(), const StringData &jskey="", const StringData &finalize="") |
| Does the same thing as 'group' but accepts a key function, 'jskey', that is used to create an object representing the key. More...
|
|
BSONObj | distinct (const StringData &ns, const StringData &field, const Query &query=Query()) |
| Finds the distinct values for a specified field across a single collection and returns the results in an array. More...
|
|
bool | eval (const std::string &dbname, const std::string &jscode, BSONObj &info, BSONElement &retValue, BSONObj *args=0, bool nolock=false) |
| Run javascript code on the database server. More...
|
|
bool | validate (const std::string &ns, bool scandata=true) |
| validate a collection, checking for errors and reporting back statistics. More...
|
|
template<class T , class NumType > |
| MONGO_CLIENT_DEPRECATED ("deprecated in MongoDB 3.0") bool eval(const std |
| eval invocation with one parm to server and one numeric field (either int or double) returned
|
|
std::list< std::string > | getDatabaseNames () |
| get a list of all the current databases uses the { listDatabases : 1 } command. More...
|
|
std::list< std::string > | getCollectionNames (const std::string &db, const BSONObj &filter=BSONObj()) |
| Get a list of all the current collections in db.
|
|
std::list< BSONObj > | getCollectionInfos (const std::string &db, const BSONObj &filter=BSONObj()) |
| { name : "<short collection name>", options : { } }
|
|
std::auto_ptr< DBClientCursor > | enumerateCollections (const std::string &db, const BSONObj &filter=BSONObj(), int batchSize=0) |
| Returns a DBClientCursor with collection information objects. More...
|
|
void | createIndex (const StringData &ns, const BSONObj &keys) |
| Create an index on the collection 'ns' as described by the given keys. More...
|
|
virtual void | createIndex (const StringData &ns, const IndexSpec &descriptor) |
| Create an index on the collection 'ns' as described by the given descriptor. More...
|
|
virtual std::list< std::string > | getIndexNames (const std::string &ns, int options=0) |
| Enumerates all indexes on ns (a db-qualified collection name). More...
|
|
virtual void | dropIndexes (const std::string &ns) |
| drops all indexes for the collection
|
|
virtual bool | dropDatabase (const std::string &dbname, BSONObj *info=0) |
| Erase / drop an entire database.
|
|
virtual BSONObj | findOne (const std::string &ns, const Query &query, const BSONObj *fieldsToReturn=0, int queryOptions=0) |
|
void | findN (std::vector< BSONObj > &out, const std::string &ns, Query query, int nToReturn, int nToSkip=0, const BSONObj *fieldsToReturn=0, int queryOptions=0, int batchSize=0) |
| query N objects from the database into an array. More...
|
|
void | save (const StringData &ns, const BSONObj &toSave, const WriteConcern *wc=NULL) |
| Saves a document to a collection. More...
|
|
virtual bool | call (Message &toSend, Message &response, bool assertOk=true, std::string *actualServer=0)=0 |
| actualServer is set to the actual server where they call went if there was a choice (SlaveOk)
|
|