summaryrefslogtreecommitdiff
path: root/jstests/core/mr_stored.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/core/mr_stored.js')
-rw-r--r--jstests/core/mr_stored.js124
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();
}());