diff options
Diffstat (limited to 'jstests/core/mr_stored.js')
-rw-r--r-- | jstests/core/mr_stored.js | 124 |
1 files changed, 62 insertions, 62 deletions
diff --git a/jstests/core/mr_stored.js b/jstests/core/mr_stored.js index e2c8d1450ec..c1c38253727 100644 --- a/jstests/core/mr_stored.js +++ b/jstests/core/mr_stored.js @@ -8,81 +8,81 @@ // requires_non_retryable_writes, // ] (function() { - "use strict"; +"use strict"; - // Use a unique database name to avoid conflicts with other tests that directly modify - // system.js. - const testDB = db.getSiblingDB("mr_stored"); - const coll = testDB.test; - coll.drop(); +// Use a unique database name to avoid conflicts with other tests that directly modify +// system.js. +const testDB = db.getSiblingDB("mr_stored"); +const coll = testDB.test; +coll.drop(); - assert.commandWorked(coll.insert({"partner": 1, "visits": 9})); - assert.commandWorked(coll.insert({"partner": 2, "visits": 9})); - assert.commandWorked(coll.insert({"partner": 1, "visits": 11})); - assert.commandWorked(coll.insert({"partner": 1, "visits": 30})); - assert.commandWorked(coll.insert({"partner": 2, "visits": 41})); - assert.commandWorked(coll.insert({"partner": 2, "visits": 41})); +assert.commandWorked(coll.insert({"partner": 1, "visits": 9})); +assert.commandWorked(coll.insert({"partner": 2, "visits": 9})); +assert.commandWorked(coll.insert({"partner": 1, "visits": 11})); +assert.commandWorked(coll.insert({"partner": 1, "visits": 30})); +assert.commandWorked(coll.insert({"partner": 2, "visits": 41})); +assert.commandWorked(coll.insert({"partner": 2, "visits": 41})); - let map = function(obj) { - emit(obj.partner, {stats: [obj.visits]}); - }; +let map = function(obj) { + emit(obj.partner, {stats: [obj.visits]}); +}; - let reduce = 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]); - total += v[i].stats[j]; - } +let reduce = 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]); + total += v[i].stats[j]; } - return {stats: stats, total: total}; - }; + } + return {stats: stats, total: total}; +}; - // Test that map reduce works with stored javascript - assert.commandWorked(testDB.system.js.insert({_id: "mr_stored_map", value: map})); - assert.commandWorked(testDB.system.js.insert({_id: "mr_stored_reduce", value: reduce})); +// Test that map reduce works with stored javascript +assert.commandWorked(testDB.system.js.insert({_id: "mr_stored_map", value: map})); +assert.commandWorked(testDB.system.js.insert({_id: "mr_stored_reduce", value: reduce})); - let res = coll.mapReduce( - function() { - mr_stored_map(this); - }, - function(k, v) { - return mr_stored_reduce(k, v); - }, - {out: "mr_stored_out", scope: {xx: 1}}); +let res = coll.mapReduce( + function() { + mr_stored_map(this); + }, + function(k, v) { + return mr_stored_reduce(k, v); + }, + {out: "mr_stored_out", scope: {xx: 1}}); - let z = res.convertToSingleObject(); - assert.eq(2, Object.keySet(z).length); - assert.eq([9, 11, 30], z["1"].stats); - assert.eq([9, 41, 41], z["2"].stats); +let z = res.convertToSingleObject(); +assert.eq(2, Object.keySet(z).length); +assert.eq([9, 11, 30], z["1"].stats); +assert.eq([9, 41, 41], z["2"].stats); - res.drop(); +res.drop(); - map = function(obj) { - var x = "partner"; - var y = "visits"; - emit(obj[x], {stats: [obj[y]]}); - }; +map = function(obj) { + var x = "partner"; + var y = "visits"; + emit(obj[x], {stats: [obj[y]]}); +}; - assert.commandWorked(testDB.system.js.save({_id: "mr_stored_map", value: map})); +assert.commandWorked(testDB.system.js.save({_id: "mr_stored_map", value: map})); - res = coll.mapReduce( - function() { - mr_stored_map(this); - }, - function(k, v) { - return mr_stored_reduce(k, v); - }, - {out: "mr_stored_out", scope: {xx: 1}}); +res = coll.mapReduce( + function() { + mr_stored_map(this); + }, + function(k, v) { + return mr_stored_reduce(k, v); + }, + {out: "mr_stored_out", scope: {xx: 1}}); - z = res.convertToSingleObject(); - assert.eq(2, Object.keySet(z).length); - assert.eq([9, 11, 30], z["1"].stats); - assert.eq([9, 41, 41], z["2"].stats); +z = res.convertToSingleObject(); +assert.eq(2, Object.keySet(z).length); +assert.eq([9, 11, 30], z["1"].stats); +assert.eq([9, 41, 41], z["2"].stats); - assert.commandWorked(testDB.system.js.remove({_id: "mr_stored_map"})); - assert.commandWorked(testDB.system.js.remove({_id: "mr_stored_reduce"})); +assert.commandWorked(testDB.system.js.remove({_id: "mr_stored_map"})); +assert.commandWorked(testDB.system.js.remove({_id: "mr_stored_reduce"})); - res.drop(); +res.drop(); }()); |