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
|
/**
* Utilities for testing query sampling.
*/
var QuerySamplingUtil = (function() {
load("jstests/libs/uuid_util.js");
load("jstests/sharding/analyze_shard_key/libs/analyze_shard_key_util.js");
function getCollectionUuid(db, collName) {
const listCollectionRes =
assert.commandWorked(db.runCommand({listCollections: 1, filter: {name: collName}}));
return listCollectionRes.cursor.firstBatch[0].info.uuid;
}
function generateRandomString(length = 5) {
return extractUUIDFromObject(UUID()).substring(0, length);
}
function generateRandomCollation() {
return {locale: "en_US", strength: AnalyzeShardKeyUtil.getRandInteger(1, 5)};
}
function makeCmdObjIgnoreSessionInfo(originalCmdObj) {
const modifiedCmdObj = Object.extend({}, originalCmdObj);
delete modifiedCmdObj["lsid"];
delete modifiedCmdObj["txnNumber"];
return modifiedCmdObj;
}
/**
* Waits for the config.sampledQueries collection to have 'expectedSampledQueryDocs.length'
* number of documents for the collection 'ns'. For every (sampleId, cmdName, cmdObj) in
* 'expectedSampledQueryDocs', asserts that there is a config.sampledQueries document with _id
* equal to sampleId and that it has the given fields.
*/
function assertSoonSampledQueryDocuments(conn, ns, collectionUuid, expectedSampledQueryDocs) {
const coll = conn.getCollection("config.sampledQueries");
let actualSampledQueryDocs;
assert.soon(() => {
actualSampledQueryDocs = coll.find({ns}).toArray();
return actualSampledQueryDocs.length >= expectedSampledQueryDocs.length;
}, "timed out waiting for sampled query documents");
assert.eq(actualSampledQueryDocs.length,
expectedSampledQueryDocs.length,
{actualSampledQueryDocs, expectedSampledQueryDocs});
for (let {sampleId, cmdName, cmdObj} of expectedSampledQueryDocs) {
const doc = coll.findOne({_id: sampleId});
assert.neq(doc, null);
assert.eq(doc.ns, ns, doc);
assert.eq(doc.collectionUuid, collectionUuid, doc);
assert.eq(doc.cmdName, cmdName, doc);
for (let key in cmdObj) {
const value = cmdObj[key];
if (typeof value === 'object') {
for (let subKey in value) {
assert.eq(doc.cmd[key][subKey],
cmdObj[key][subKey],
{subKey, actual: doc.cmd, expected: cmdObj});
}
} else {
assert.eq(doc.cmd[key], cmdObj[key], {key, actual: doc.cmd, expected: cmdObj});
}
}
}
}
function assertNoSampledQueryDocuments(conn, ns) {
const coll = conn.getCollection("config.sampledQueries");
assert.eq(coll.find({ns}).itcount(), 0);
}
/**
* Waits for the config.sampledQueriesDiff collection to have a document with _id equal to
* sampleId, and then asserts that the diff in that document matches one of the diffs in
* 'expectedSampledDiffs'.
*/
function assertSoonSingleSampledDiffDocument(
conn, sampleId, ns, collectionUuid, expectedSampledDiffs) {
const coll = conn.getCollection("config.sampledQueriesDiff");
assert.soon(() => {
const doc = coll.findOne({_id: sampleId});
if (!doc) {
return false;
}
assert.eq(doc.ns, ns, doc);
assert.eq(doc.collectionUuid, collectionUuid, doc);
assert(expectedSampledDiffs.some(diff => {
return bsonUnorderedFieldsCompare(doc.diff, diff) === 0;
}),
doc);
return true;
});
}
function assertNoSampledDiffDocuments(conn, ns) {
const coll = conn.getCollection("config.sampledQueriesDiff");
assert.eq(coll.find({ns: ns}).itcount(), 0);
}
function clearSampledDiffCollection(primary) {
const coll = primary.getCollection("config.sampledQueriesDiff");
assert.commandWorked(coll.remove({}));
}
return {
getCollectionUuid,
generateRandomString,
generateRandomCollation,
makeCmdObjIgnoreSessionInfo,
assertSoonSampledQueryDocuments,
assertNoSampledQueryDocuments,
assertSoonSingleSampledDiffDocument,
assertNoSampledDiffDocuments,
clearSampledDiffCollection
};
})();
|
