friendlyEqual = function( a , b ){ if ( a == b ) return true; if ( tojson( a ) == tojson( b ) ) return true; return false; } doassert = function( msg ){ print( "assert: " + msg ); throw msg; } assert = function( b , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( b ) return; doassert( "assert failed : " + msg ); } assert._debug = false; assert.eq = function( a , b , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( a == b ) return; if ( ( a != null && b != null ) && friendlyEqual( a , b ) ) return; doassert( "[" + tojson( a ) + "] != [" + tojson( b ) + "] are not equal : " + msg ); } assert.neq = function( a , b , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( a != b ) return; doassert( "[" + a + "] != [" + b + "] are equal : " + msg ); } assert.soon = function( f, msg, timeout, interval ) { if ( assert._debug && msg ) print( "in assert for: " + msg ); var start = new Date(); timeout = timeout || 30000; interval = interval || 200; var last; while( 1 ) { if ( typeof( f ) == "string" ){ if ( eval( f ) ) return; } else { if ( f() ) return; } if ( ( new Date() ).getTime() - start.getTime() > timeout ) doassert( "assert.soon failed: " + f + ", msg:" + msg ); sleep( interval ); } } assert.throws = function( func , params , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); try { func.apply( null , params ); } catch ( e ){ return e; } doassert( "did not throw exception: " + msg ); } assert.commandWorked = function( res , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( res.ok == 1 ) return; doassert( "command failed: " + tojson( res ) + " : " + msg ); } assert.commandFailed = function( res , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( res.ok == 0 ) return; doassert( "command worked when it should have failed: " + tojson( res ) + " : " + msg ); } assert.isnull = function( what , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( what == null ) return; doassert( "supposed to null (" + ( msg || "" ) + ") was: " + tojson( what ) ); } assert.lt = function( a , b , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( a < b ) return; doassert( a + " is not less than " + b + " : " + msg ); } assert.gt = function( a , b , msg ){ if ( assert._debug && msg ) print( "in assert for: " + msg ); if ( a > b ) return; doassert( a + " is not greater than " + b + " : " + msg ); } Object.extend = function( dst , src , deep ){ for ( var k in src ){ var v = src[k]; if ( deep && typeof(v) == "object" ){ v = Object.extend( typeof ( v.length ) == "number" ? [] : {} , v , true ); } dst[k] = v; } return dst; } argumentsToArray = function( a ){ var arr = []; for ( var i=0; i= 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.it = function(){ if ( typeof( ___it___ ) == "undefined" || ___it___ == null ){ print( "no cursor" ); return; } shellPrintHelper( ___it___ ); } 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" ){ db.system.users.find().forEach( printjson ); return ""; } 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 + "]"; } if ( typeof( Map ) == "undefined" ){ Map = function(){ this._data = {}; } } Map.hash = function( val ){ if ( ! val ) return val; switch ( typeof( val ) ){ case 'string': case 'number': case 'date': return val.toString(); case 'object': case 'array': var s = ""; for ( var k in val ){ s += k + val[k]; } return s; } throw "can't hash : " + typeof( val ); } Map.prototype.put = function( key , value ){ var o = this._get( key ); var old = o.value; o.value = value; return old; } Map.prototype.get = function( key ){ return this._get( key ).value; } Map.prototype._get = function( key ){ var h = Map.hash( key ); var a = this._data[h]; if ( ! a ){ a = []; this._data[h] = a; } for ( var i=0; i