mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

switching locations

Browse Source
This commit is contained in:
Dwight 2008-06-28 13:46:59 -04:00
parent b1a480423b
commit d85e75b674
2 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
db/pdfile.cpp
View File

@ -665,6 +665,7 @@ void _unindexRecord(const char *ns, IndexDetails& id, JSObj& obj, const DiskLoc&
}
}
/* unindex all keys in all indexes for this record. */
void unindexRecord(const char *ns, NamespaceDetails *d, Record *todelete, const DiskLoc& dl) {
if( d->nIndexes == 0 ) return;
JSObj obj(todelete);

18
db/query.cpp
View File

@ -30,7 +30,7 @@ JSObj emptyObj((char *) &emptyObject);
int getGtLtOp(Element& e);
void appendElementHandlingGtLt(JSObjBuilder& b, Element& e);
int runCount(const char *ns, const JSObj& cmd, string& err);
int runCount(const char *ns, JSObj& cmd, string& err);
/* todo: _ cache query plans
_ use index on partial match with the query
@ -711,19 +711,29 @@ JSObj empty_obj = fromjson("{}");
/* { count: "collectionname"[, query: <query>] }
returns -1 on error.
*/
int runCount(const char *ns, const JSObj& cmd, string& err) {
int runCount(const char *ns, JSObj& cmd, string& err) {
NamespaceDetails *d = nsdetails(ns);
if( d == 0 ) {
err = "ns does not exist";
return -1;
}
auto_ptr<Cursor> c = getIndexCursor(ns, id_obj, empty_obj);
JSObj query = cmd.getObjectField("query");
auto_ptr<Cursor> c;
if( query.isEmpty() ) {
c = getIndexCursor(ns, id_obj, empty_obj);
} else {
c = getIndexCursor(ns, query, empty_obj);
}
if( c.get() == 0 ) {
cout << "TEMP: table scan" << endl;
c = findTableScan(ns, empty_obj);
}
else cout << "TEMP: indexed scan" << endl;
else
cout << "TEMP: indexed scan" << endl;
int count = 0;
if( c->ok() ) {
count++;