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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
// shard6.js
(function() {
"use strict";
var summary = "";
var s = new ShardingTest({name: "shard6", shards: 2});
s.adminCommand({enablesharding: "test"});
s.ensurePrimaryShard('test', s.shard1.shardName);
s.adminCommand({shardcollection: "test.data", key: {num: 1}});
var version = s.getDB("admin").runCommand({buildinfo: 1}).versionArray;
var post32 = (version[0] > 4) || ((version[0] == 3) && (version[1] > 2));
var db = s.getDB("test");
function poolStats(where) {
var total = 0;
var msg = "poolStats " + where + " ";
var stats = db.runCommand("connPoolStats");
for (var h in stats.hosts) {
if (!stats.hosts.hasOwnProperty(h)) {
continue;
}
var host = stats.hosts[h];
msg += host.created + " ";
total += host.created;
}
printjson(stats.hosts);
print("****\n" + msg + "\n*****");
summary += msg + "\n";
if (post32) {
assert.eq(total, stats.totalCreated, "mismatched number of total connections created");
}
return total;
}
poolStats("at start");
// we want a lot of data, so lets make a 50k string to cheat :)
var bigString = "this is a big string. ".repeat(50000);
// ok, now lets insert a some data
var num = 0;
for (; num < 100; num++) {
db.data.save({num: num, bigString: bigString});
}
assert.eq(100, db.data.find().toArray().length, "basic find after setup");
poolStats("setup done");
// limit
assert.eq(77, db.data.find().limit(77).itcount(), "limit test 1");
assert.eq(1, db.data.find().limit(1).itcount(), "limit test 2");
for (var i = 1; i < 10; i++) {
assert.eq(i, db.data.find().limit(i).itcount(), "limit test 3a : " + i);
assert.eq(i, db.data.find().skip(i).limit(i).itcount(), "limit test 3b : " + i);
poolStats("after loop : " + i);
}
poolStats("limit test done");
function assertOrder(start, num) {
var a = db.data.find().skip(start).limit(num).sort({num: 1}).map(function(z) {
return z.num;
});
var c = [];
for (var i = 0; i < num; i++)
c.push(start + i);
assert.eq(c, a, "assertOrder start: " + start + " num: " + num);
}
assertOrder(0, 10);
assertOrder(5, 10);
poolStats("after checking order");
function doItCount(skip, sort, batchSize) {
var c = db.data.find();
if (skip)
c.skip(skip);
if (sort)
c.sort(sort);
if (batchSize)
c.batchSize(batchSize);
return c.itcount();
}
function checkItCount(batchSize) {
assert.eq(5, doItCount(num - 5, null, batchSize), "skip 1 " + batchSize);
assert.eq(5, doItCount(num - 5, {num: 1}, batchSize), "skip 2 " + batchSize);
assert.eq(5, doItCount(num - 5, {_id: 1}, batchSize), "skip 3 " + batchSize);
assert.eq(0, doItCount(num + 5, {num: 1}, batchSize), "skip 4 " + batchSize);
assert.eq(0, doItCount(num + 5, {_id: 1}, batchSize), "skip 5 " + batchSize);
}
poolStats("before checking itcount");
checkItCount(0);
checkItCount(2);
poolStats("after checking itcount");
// --- Verify that modify & save style updates doesn't work on sharded clusters ---
var o = db.data.findOne();
o.x = 16;
assert.commandFailedWithCode(db.data.save(o), ErrorCodes.ShardKeyNotFound);
poolStats("at end");
print(summary);
assert.throws(function() {
s.adminCommand({enablesharding: "admin"});
});
s.stop();
})();
|
