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/aggregation/bugs/server6179.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-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.js | 113 |
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(); })(); |