diff options
Diffstat (limited to 'jstests/core/mr_stored.js')
-rw-r--r-- | jstests/core/mr_stored.js | 82 |
1 files changed, 47 insertions, 35 deletions
diff --git a/jstests/core/mr_stored.js b/jstests/core/mr_stored.js index 3403411ea70..63fa301e66d 100644 --- a/jstests/core/mr_stored.js +++ b/jstests/core/mr_stored.js @@ -2,65 +2,77 @@ t = db.mr_stored; t.drop(); -t.save( { "partner" : 1, "visits" : 9 } ); -t.save( { "partner" : 2, "visits" : 9 } ); -t.save( { "partner" : 1, "visits" : 11 } ); -t.save( { "partner" : 1, "visits" : 30 } ); -t.save( { "partner" : 2, "visits" : 41 } ); -t.save( { "partner" : 2, "visits" : 41 } ); +t.save({"partner": 1, "visits": 9}); +t.save({"partner": 2, "visits": 9}); +t.save({"partner": 1, "visits": 11}); +t.save({"partner": 1, "visits": 30}); +t.save({"partner": 2, "visits": 41}); +t.save({"partner": 2, "visits": 41}); -m = function(obj){ - emit( obj.partner , { stats : [ obj.visits ] } ); +m = function(obj) { + emit(obj.partner, {stats: [obj.visits]}); }; -r = function( k , v ){ +r = function(k, v) { var stats = []; var total = 0; - for ( var i=0; i<v.length; i++ ){ - for ( var j in v[i].stats ) { - stats.push( v[i].stats[j] ); + for (var i = 0; i < v.length; i++) { + for (var j in v[i].stats) { + stats.push(v[i].stats[j]); total += v[i].stats[j]; } } - return { stats : stats , total : total }; + return { + stats: stats, + total: total + }; }; // Test that map reduce works with stored javascript -db.system.js.save( { _id : "mr_stored_map" , value : m } ); -db.system.js.save( { _id : "mr_stored_reduce" , value : r } ); +db.system.js.save({_id: "mr_stored_map", value: m}); +db.system.js.save({_id: "mr_stored_reduce", value: r}); -res = t.mapReduce( function () { mr_stored_map(this); } , - function ( k , v ) { return mr_stored_reduce( k , v ); } , - { out : "mr_stored_out" , scope : { xx : 1 } } ); -//res.find().forEach( printjson ) +res = t.mapReduce( + function() { + mr_stored_map(this); + }, + function(k, v) { + return mr_stored_reduce(k, v); + }, + {out: "mr_stored_out", scope: {xx: 1}}); +// res.find().forEach( printjson ) z = res.convertToSingleObject(); -assert.eq( 2 , Object.keySet( z ).length , "A1" ); -assert.eq( [ 9 , 11 , 30 ] , z["1"].stats , "A2" ); -assert.eq( [ 9 , 41 , 41 ] , z["2"].stats , "A3" ); - +assert.eq(2, Object.keySet(z).length, "A1"); +assert.eq([9, 11, 30], z["1"].stats, "A2"); +assert.eq([9, 41, 41], z["2"].stats, "A3"); res.drop(); -m = function(obj){ +m = function(obj) { var x = "partner"; var y = "visits"; - emit( obj[x] , { stats : [ obj[y] ] } ); + emit(obj[x], {stats: [obj[y]]}); }; -db.system.js.save( { _id : "mr_stored_map" , value : m } ); +db.system.js.save({_id: "mr_stored_map", value: m}); -res = t.mapReduce( function () { mr_stored_map(this); } , - function ( k , v ) { return mr_stored_reduce( k , v ); } , - { out : "mr_stored_out" , scope : { xx : 1 } } ); -//res.find().forEach( printjson ) +res = t.mapReduce( + function() { + mr_stored_map(this); + }, + function(k, v) { + return mr_stored_reduce(k, v); + }, + {out: "mr_stored_out", scope: {xx: 1}}); +// res.find().forEach( printjson ) z = res.convertToSingleObject(); -assert.eq( 2 , Object.keySet( z ).length , "B1" ); -assert.eq( [ 9 , 11 , 30 ] , z["1"].stats , "B2" ); -assert.eq( [ 9 , 41 , 41 ] , z["2"].stats , "B3" ); +assert.eq(2, Object.keySet(z).length, "B1"); +assert.eq([9, 11, 30], z["1"].stats, "B2"); +assert.eq([9, 41, 41], z["2"].stats, "B3"); -db.system.js.remove( { _id : "mr_stored_map" } ); -db.system.js.remove( { _id : "mr_stored_reduce" } ); +db.system.js.remove({_id: "mr_stored_map"}); +db.system.js.remove({_id: "mr_stored_reduce"}); res.drop(); |