1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
// tests to make sure that tag ranges are added/removed/updated successfully
function countTags( num, message ) {
assert.eq( s.config.tags.count() , num , message );
}
var s = new ShardingTest({ name: "tag_range",
shards: 2,
mongos: 1 });
// this set up is not required but prevents warnings in the remove
db = s.getDB( "tag_range" );
s.adminCommand( { enableSharding : "test" } );
s.ensurePrimaryShard('test', 'shard0001');
s.adminCommand( { shardCollection : "test.tag_range" , key : { _id : 1 } } );
assert.eq( 1 , s.config.chunks.count() );
sh.addShardTag( "shard0000" , "a" );
// add two ranges, verify the additions
sh.addTagRange( "test.tag_range" , { _id : 5 } , { _id : 10 } , "a" );
sh.addTagRange( "test.tag_range" , { _id : 10 } , { _id : 15 } , "b" );
countTags( 2 , "tag ranges were not successfully added" );
// remove the second range, should be left with one
sh.removeTagRange( "test.tag_range" , { _id : 10 } , { _id : 15 } , "b" );
countTags( 1 , "tag range not removed successfully" );
// the additions are actually updates, so you can alter a range's max
sh.addTagRange( "test.tag_range" , { _id : 5 } , { _id : 11 } , "a" );
assert.eq( 11 , s.config.tags.findOne().max._id , "tag range not updated successfully" );
// add range min=max, verify the additions
try {
sh.addTagRange( "test.tag_range" , { _id : 20 } , { _id : 20 } , "a" );
} catch (e) {
countTags( 1 , "tag range should not have been added" );
}
// removeTagRange tests for tag ranges that do not exist
// Bad namespace
sh.removeTagRange("badns", { _id : 5 }, { _id : 11 }, "a");
countTags(1 , "Bad namespace: tag range does not exist");
// Bad tag
sh.removeTagRange("test.tag_range", { _id : 5 }, { _id : 11 }, "badtag");
countTags(1 , "Bad tag: tag range does not exist");
// Bad min
sh.removeTagRange("test.tag_range", { _id : 0 }, { _id : 11 }, "a");
countTags(1 , "Bad min: tag range does not exist");
// Bad max
sh.removeTagRange("test.tag_range", { _id : 5 }, { _id : 12 }, "a");
countTags(1 , "Bad max: tag range does not exist");
// Invalid namesapce
sh.removeTagRange(35, { _id : 5 }, { _id : 11 }, "a");
countTags(1 , "Invalid namespace: tag range does not exist");
// Invalid tag
sh.removeTagRange("test.tag_range", { _id : 5 }, { _id : 11 }, 35);
countTags(1 , "Invalid tag: tag range does not exist");
// Invalid min
sh.removeTagRange("test.tag_range", 35, { _id : 11 }, "a");
countTags(1 , "Invalid min: tag range does not exist");
// Invalid max
sh.removeTagRange("test.tag_range", { _id : 5 }, 35, "a");
countTags(1 , "Invalid max: tag range does not exist");
s.stop();
|
