assert = function( b , msg ){ if ( b ) return; throw "assert failed : " + msg; } assert.eq = function( a , b , msg ){ if ( a == b ) return; if ( a != null && b != null && a.toString() == b.toString() ) return; throw "[" + a + "] != [" + b + "] are not equal : " + msg; } assert.neq = function( a , b , msg ){ if ( a != b ) return; throw "[" + a + "] != [" + b + "] are equal : " + msg; } assert.soon = function( f ) { var start = new Date(); var last; while( 1 ) { if ( f() ) return; if ( ( new Date() ).getTime() - start.getTime() > 30000 ) throw "assert.soon failed: " + f; sleep( 200 ); } } assert.throws = function( func , params , msg ){ try { func.apply( null , params ); } catch ( e ){ return e; } throw "did not throw exception: " + msg ; } assert.commandWorked = function( res , msg ){ if ( res.ok == 1 ) return; throw "command failed: " + tojson( res ) + " : " + msg; } assert.commandFailed = function( res , msg ){ if ( res.ok == 0 ) return; throw "command worked when it should have failed: " + tojson( res ) + " : " + msg; } assert.isnull = function( what , msg ){ if ( what == null ) return; throw "supposed to null (" + ( msg || "" ) + ") was: " + tojson( what ); } Object.extend = function( dst , src ){ for ( var k in src ){ dst[k] = src[k]; } return dst; } argumentsToArray = function( a ){ var arr = []; for ( var i=0; i 0 ){ s += ","; if ( sepLines ) s += "\n"; } s += tojson( this[i] ); } s += "]"; if ( sepLines ) s += "\n"; return s; } ObjectId.prototype.toString = function(){ return this.str; } ObjectId.prototype.tojson = function(){ return "\"" + this.str + "\""; } ObjectId.prototype.isObjectId = true; Thread = function(){ this.init.apply( this, arguments ); } threadInject( Thread.prototype ); fork = function() { var t = new Thread( function() {} ); Thread.apply( t, arguments ); return t; } tojson = function( x ){ if ( x == null || x == undefined ) return ""; switch ( typeof x ){ case "string": return "\"" + x + "\""; case "number": case "boolean": return "" + x; case "object": return tojsonObject( x ); default: throw "can't handle type " + ( typeof v ); } } tojsonObject = function( x ){ assert.eq( ( typeof x ) , "object" , "tojsonObject needs object, not [" + ( typeof x ) + "]" ); if ( x.tojson ) return x.tojson(); var s = "{"; var first = true; for ( var k in x ){ if ( first ) first = false; else s += " , "; s += "\"" + k + "\" : " + tojson( x[k] ); } return s + "}"; } shellPrint = function( x ){ it = x; if ( x != undefined ) shellPrintHelper( x ); if ( db ){ var e = db.getPrevError(); if ( e.err ) { if( e.nPrev <= 1 ) print( "error on last call: " + tojson( e.err ) ); else print( "an error " + tojson(e.err) + " occurred " + e.nPrev + " operations back in the command invocation" ); } db.resetError(); } } printjson = function(x){ print( tojson( x ) ); } shellPrintHelper = function( x ){ if ( typeof x != "object" ) return print( x ); var p = x.shellPrint; if ( typeof p == "function" ) return x.shellPrint(); var p = x.tojson; if ( typeof p == "function" ) print( x.tojson() ); else print( tojson( x ) ); } shellHelper = function( command , rest ){ command = command.trim(); var args = rest.trim().replace(/;$/,"").split( "\s+" ); if ( ! shellHelper[command] ) throw "no command [" + command + "]"; return shellHelper[command].apply( null , args ); } help = shellHelper.help = function(){ print( "HELP" ); print( "\t" + "show dbs show database names"); print( "\t" + "show collections show collections in current database"); print( "\t" + "show users show users in current database"); print( "\t" + "show profile show most recent system.profile entries with time >= 1ms"); print( "\t" + "use set curent database to " ); print( "\t" + "db.help() help on DB methods"); print( "\t" + "db.foo.help() help on collection methods"); print( "\t" + "db.foo.find() list objects in collection foo" ); print( "\t" + "db.foo.find( { a : 1 } ) list objects in foo where a == 1" ); print( "\t" + "it result of the last line evaluated; use to further iterate"); } shellHelper.use = function( dbname ){ db = db.getMongo().getDB( dbname ); print( "switched to db " + db.getName() ); } shellHelper.show = function( what ){ assert( typeof what == "string" ); if( what == "profile" ) { if( db.system.profile.count() == 0 ) { print("db.system.profile is empty"); print("Use db.setProfilingLevel(2) will enable profiling"); print("Use db.system.profile.find() to show raw profile entries"); } else { print(); db.system.profile.find({ millis : { $gt : 0 } }).sort({$natural:-1}).limit(5).forEach( function(x){print(""+x.millis+"ms " + String(x.ts).substring(0,24)); print(x.info); print("\n");} ) } return ""; } if ( what == "users" ) return db.system.users.find(); if ( what == "collections" || what == "tables" ) { db.getCollectionNames().forEach( function(x){print(x)} ); return ""; } if ( what == "dbs" ) { db.getMongo().getDBNames().sort().forEach( function(x){print(x)} ); return ""; } throw "don't know how to show [" + what + "]"; }