diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:17:50 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:18:14 -0500 |
commit | 4ae691e8edc87d0e3cfb633bb91c328426be007b (patch) | |
tree | 52079a593f54382ca13a2e741633eab1b6271893 /jstests/core/mr_merge.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz |
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/core/mr_merge.js')
-rw-r--r-- | jstests/core/mr_merge.js | 59 |
1 files changed, 33 insertions, 26 deletions
diff --git a/jstests/core/mr_merge.js b/jstests/core/mr_merge.js index 83d00f39392..92490cdd6fd 100644 --- a/jstests/core/mr_merge.js +++ b/jstests/core/mr_merge.js @@ -2,59 +2,66 @@ t = db.mr_merge; t.drop(); -t.insert( { a : [ 1 , 2 ] } ); -t.insert( { a : [ 2 , 3 ] } ); -t.insert( { a : [ 3 , 4 ] } ); +t.insert({a: [1, 2]}); +t.insert({a: [2, 3]}); +t.insert({a: [3, 4]}); outName = "mr_merge_out"; out = db[outName]; out.drop(); -m = function(){ for (i=0; i<this.a.length; i++ ) emit( this.a[i] , 1 ); }; -r = function(k,vs){ return Array.sum( vs ); }; +m = function() { + for (i = 0; i < this.a.length; i++) + emit(this.a[i], 1); +}; +r = function(k, vs) { + return Array.sum(vs); +}; -function tos( o ){ +function tos(o) { var s = ""; - for ( var i=0; i<100; i++ ){ - if ( o[i] ) + for (var i = 0; i < 100; i++) { + if (o[i]) s += i + "_" + o[i]; } return s; } +res = t.mapReduce(m, r, {out: outName}); -res = t.mapReduce( m , r , { out : outName } ); +expected = { + "1": 1, + "2": 2, + "3": 2, + "4": 1 +}; +assert.eq(tos(expected), tos(res.convertToSingleObject()), "A"); - -expected = { "1" : 1 , "2" : 2 , "3" : 2 , "4" : 1 }; -assert.eq( tos( expected ) , tos( res.convertToSingleObject() ) , "A" ); - -t.insert( { a : [ 4 , 5 ] } ); -out.insert( { _id : 10 , value : "5" } ); -res = t.mapReduce( m , r , { out : outName } ); +t.insert({a: [4, 5]}); +out.insert({_id: 10, value: "5"}); +res = t.mapReduce(m, r, {out: outName}); expected["4"]++; expected["5"] = 1; -assert.eq( tos( expected ) , tos( res.convertToSingleObject() ) , "B" ); +assert.eq(tos(expected), tos(res.convertToSingleObject()), "B"); -t.insert( { a : [ 5 , 6 ] } ); -out.insert( { _id : 10 , value : "5" } ); -res = t.mapReduce( m , r , { out : { merge : outName } } ); +t.insert({a: [5, 6]}); +out.insert({_id: 10, value: "5"}); +res = t.mapReduce(m, r, {out: {merge: outName}}); expected["5"]++; expected["10"] = 5; expected["6"] = 1; -assert.eq( tos( expected ) , tos( res.convertToSingleObject() ) , "C" ); +assert.eq(tos(expected), tos(res.convertToSingleObject()), "C"); // test that the nonAtomic output gives valid result -t.insert( { a : [ 6 , 7 ] } ); -out.insert( { _id : 20 , value : "10" } ); -res = t.mapReduce( m , r , { out : { merge : outName, nonAtomic: true } } ); +t.insert({a: [6, 7]}); +out.insert({_id: 20, value: "10"}); +res = t.mapReduce(m, r, {out: {merge: outName, nonAtomic: true}}); expected["6"]++; expected["20"] = 10; expected["7"] = 1; -assert.eq( tos( expected ) , tos( res.convertToSingleObject() ) , "D" ); - +assert.eq(tos(expected), tos(res.convertToSingleObject()), "D"); |