summaryrefslogtreecommitdiff
path: root/jstests/aggregation/bugs/server6179.js
diff options
context:
space:
mode:
authorJonathan Abrahams <jonathan@mongodb.com>2016-03-09 12:17:50 -0500
committerJonathan Abrahams <jonathan@mongodb.com>2016-03-09 12:18:14 -0500
commit4ae691e8edc87d0e3cfb633bb91c328426be007b (patch)
tree52079a593f54382ca13a2e741633eab1b6271893 /jstests/aggregation/bugs/server6179.js
parenta025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff)
downloadmongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/aggregation/bugs/server6179.js')
-rw-r--r--jstests/aggregation/bugs/server6179.js113
1 files changed, 41 insertions, 72 deletions
diff --git a/jstests/aggregation/bugs/server6179.js b/jstests/aggregation/bugs/server6179.js
index 4eba802e14e..20158af7fb7 100644
--- a/jstests/aggregation/bugs/server6179.js
+++ b/jstests/aggregation/bugs/server6179.js
@@ -1,82 +1,51 @@
// SERVER-6179: support for two $groups in sharded agg
(function() {
-var s = new ShardingTest({ name: "aggregation_multiple_group", shards: 2, mongos: 1 });
-s.stopBalancer();
+ var s = new ShardingTest({name: "aggregation_multiple_group", shards: 2, mongos: 1});
+ s.stopBalancer();
-s.adminCommand({ enablesharding:"test" });
-s.ensurePrimaryShard('test', 'shard0001');
-s.adminCommand({ shardcollection: "test.data", key:{ _id: 1 } });
+ s.adminCommand({enablesharding: "test"});
+ s.ensurePrimaryShard('test', 'shard0001');
+ s.adminCommand({shardcollection: "test.data", key: {_id: 1}});
-var d = s.getDB( "test" );
+ var d = s.getDB("test");
-// Insert _id values 0 - 99
-var N = 100;
+ // Insert _id values 0 - 99
+ var N = 100;
-var bulkOp = d.data.initializeOrderedBulkOp();
-for(var i = 0; i < N; ++i) {
- bulkOp.insert({ _id: i, i: i%10 });
-}
-bulkOp.execute();
-
-// Split the data into 3 chunks
-s.adminCommand( { split:"test.data", middle:{ _id:33 } } );
-s.adminCommand( { split:"test.data", middle:{ _id:66 } } );
-
-// Migrate the middle chunk to another shard
-s.adminCommand({ movechunk: "test.data",
- find: { _id: 50 },
- to: s.getOther(s.getPrimaryShard("test")).name });
-
-// Check that we get results rather than an error
-var result = d.data.aggregate({$group: {_id: '$_id', i: {$first: '$i'}}},
- {$group: {_id: '$i', avg_id: {$avg: '$_id'}}},
- {$sort: {_id: 1}}).toArray();
-expected = [
- {
- "_id" : 0,
- "avg_id" : 45
- },
- {
- "_id" : 1,
- "avg_id" : 46
- },
- {
- "_id" : 2,
- "avg_id" : 47
- },
- {
- "_id" : 3,
- "avg_id" : 48
- },
- {
- "_id" : 4,
- "avg_id" : 49
- },
- {
- "_id" : 5,
- "avg_id" : 50
- },
- {
- "_id" : 6,
- "avg_id" : 51
- },
- {
- "_id" : 7,
- "avg_id" : 52
- },
- {
- "_id" : 8,
- "avg_id" : 53
- },
- {
- "_id" : 9,
- "avg_id" : 54
+ var bulkOp = d.data.initializeOrderedBulkOp();
+ for (var i = 0; i < N; ++i) {
+ bulkOp.insert({_id: i, i: i % 10});
}
-];
-
-assert.eq(result, expected);
-
-s.stop();
+ bulkOp.execute();
+
+ // Split the data into 3 chunks
+ s.adminCommand({split: "test.data", middle: {_id: 33}});
+ s.adminCommand({split: "test.data", middle: {_id: 66}});
+
+ // Migrate the middle chunk to another shard
+ s.adminCommand(
+ {movechunk: "test.data", find: {_id: 50}, to: s.getOther(s.getPrimaryShard("test")).name});
+
+ // Check that we get results rather than an error
+ var result = d.data.aggregate({$group: {_id: '$_id', i: {$first: '$i'}}},
+ {$group: {_id: '$i', avg_id: {$avg: '$_id'}}},
+ {$sort: {_id: 1}}).toArray();
+ expected = [
+ {"_id": 0, "avg_id": 45},
+ {"_id": 1, "avg_id": 46},
+ {"_id": 2, "avg_id": 47},
+ {"_id": 3, "avg_id": 48},
+ {"_id": 4, "avg_id": 49},
+ {"_id": 5, "avg_id": 50},
+ {"_id": 6, "avg_id": 51},
+ {"_id": 7, "avg_id": 52},
+ {"_id": 8, "avg_id": 53},
+ {"_id": 9, "avg_id": 54}
+ ];
+
+ assert.eq(result, expected);
+
+ s.stop();
})();