diff options
Diffstat (limited to 'jstests/core/mr_sort.js')
-rw-r--r-- | jstests/core/mr_sort.js | 51 |
1 files changed, 23 insertions, 28 deletions
diff --git a/jstests/core/mr_sort.js b/jstests/core/mr_sort.js index 8d0ba96ad82..b90ad3f6bf5 100644 --- a/jstests/core/mr_sort.js +++ b/jstests/core/mr_sort.js @@ -2,43 +2,38 @@ t = db.mr_sort; t.drop(); -t.ensureIndex( { x : 1 } ); - -t.insert( { x : 1 } ); -t.insert( { x : 10 } ); -t.insert( { x : 2 } ); -t.insert( { x : 9 } ); -t.insert( { x : 3 } ); -t.insert( { x : 8 } ); -t.insert( { x : 4 } ); -t.insert( { x : 7 } ); -t.insert( { x : 5 } ); -t.insert( { x : 6 } ); - -m = function(){ - emit( "a" , this.x ); +t.ensureIndex({x: 1}); + +t.insert({x: 1}); +t.insert({x: 10}); +t.insert({x: 2}); +t.insert({x: 9}); +t.insert({x: 3}); +t.insert({x: 8}); +t.insert({x: 4}); +t.insert({x: 7}); +t.insert({x: 5}); +t.insert({x: 6}); + +m = function() { + emit("a", this.x); }; -r = function( k , v ){ - return Array.sum( v ); +r = function(k, v) { + return Array.sum(v); }; - -res = t.mapReduce( m , r , "mr_sort_out " ); +res = t.mapReduce(m, r, "mr_sort_out "); x = res.convertToSingleObject(); res.drop(); -assert.eq( { "a" : 55 } , x , "A1" ); +assert.eq({"a": 55}, x, "A1"); -res = t.mapReduce( m , r , { out : "mr_sort_out" , query : { x : { $lt : 3 } } } ); +res = t.mapReduce(m, r, {out: "mr_sort_out", query: {x: {$lt: 3}}}); x = res.convertToSingleObject(); res.drop(); -assert.eq( { "a" : 3 } , x , "A2" ); +assert.eq({"a": 3}, x, "A2"); -res = t.mapReduce( m , r , { out : "mr_sort_out" , sort : { x : 1 } , limit : 2 } ); +res = t.mapReduce(m, r, {out: "mr_sort_out", sort: {x: 1}, limit: 2}); x = res.convertToSingleObject(); res.drop(); -assert.eq( { "a" : 3 } , x , "A3" ); - - - - +assert.eq({"a": 3}, x, "A3"); |