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
|
// Tests that a view dependency chain is correctly logged in the global log for a find command
// against the view.
// @tags: [requires_profiling]
// The entry in the log should contain a field that looks like this:
// "resolvedViews":
// [
// {
// "viewNamespace":"<full name of the view>",
// "dependencyChain":[<names of views/collection in the dep chain, db name omitted>],
// "resolvedPipeline":[<the resolved pipeline of the view>]
// },
// {
// <repeat for all other views that had to be resolved for the query>
// }
// ],
(function() {
'use strict';
load("jstests/libs/logv2_helpers.js");
function resetProfiler(db) {
assert.commandWorked(db.setProfilingLevel(0, {slowms: 0}));
db.system.profile.drop();
assert.commandWorked(db.setProfilingLevel(1, {slowms: 0}));
}
function assertResolvedView(resolvedView, nss, dependencyDepth, pipelineSize) {
assert.eq(nss, resolvedView["viewNamespace"], resolvedView);
assert.eq(dependencyDepth, resolvedView["dependencyChain"].length, resolvedView);
assert.eq(pipelineSize, resolvedView["resolvedPipeline"].length, resolvedView);
}
// Check that the profiler has the expected record.
function checkProfilerLog(db) {
const result = db.system.profile.find({ns: "views_log_depchain_db.c_view"}).toArray();
assert.eq(1, result.length, result);
const record = result[0];
assert(record.hasOwnProperty("resolvedViews"), record);
const resolvedViews = record["resolvedViews"];
assert.eq(2, resolvedViews.length, resolvedViews);
// The views are logged sorted by their original namespace, not in the order of resolution.
assertResolvedView(resolvedViews[0], `${db.getName()}.b_view`, 2, 1);
assertResolvedView(resolvedViews[1], `${db.getName()}.c_view`, 3, 3);
}
const mongodOptions = {};
const conn = MongoRunner.runMongod(mongodOptions);
assert.neq(null, conn, `mongod failed to start with options ${tojson(mongodOptions)}`);
// Setup the tree of views.
const db = conn.getDB(`${jsTest.name()}_db`);
assert.commandWorked(db.dropDatabase());
assert.commandWorked(db.createCollection("base"));
assert.commandWorked(db.createView("a_view", "base", [{$project: {"aa": 0}}, {$sort: {"a": 1}}]));
assert.commandWorked(db.createView("b_view", "base", [{$project: {"bb": 0}}]));
assert.commandWorked(db.createView("c_view", "a_view", [
{$lookup: {from: "b_view", localField: "x", foreignField: "x", as: "y"}}
]));
// Run a simple query against the top view.
assert.commandWorked(db.setProfilingLevel(1, {slowms: 0}));
assert.commandWorked(db.runCommand({find: "c_view", filter: {}}));
checkProfilerLog(db);
// Sanity-check the "slow query" log (we do it only once, because the data between the profiler
// and "slow query" log are identical).
checkLog.containsWithCount(conn,
`"resolvedViews":[{"viewNamespace":"${db.getName()}.b_view",` +
`"dependencyChain":["b_view","base"],"resolvedPipeline":[{"$project`,
1);
// Run an aggregate query against the top view which uses one of the views from its dependency
// chain, so the logged data is the same as above.
resetProfiler(db);
const lookup = {
$lookup: {from: "b_view", localField: "x", foreignField: "x", as: "y"}
};
assert.commandWorked(db.runCommand({aggregate: "c_view", pipeline: [lookup], cursor: {}}));
checkProfilerLog(db);
// If a view is modified, the logs should reflect that.
assert.commandWorked(db.runCommand({drop: "c_view"}));
assert.commandWorked(db.createView("c_view", "b_view", [
{$lookup: {from: "a_view", localField: "x", foreignField: "x", as: "y"}}
]));
resetProfiler(db);
assert.commandWorked(db.runCommand({find: "c_view", filter: {}}));
const result = db.system.profile.find({ns: "views_log_depchain_db.c_view"}).toArray();
assert.eq(1, result.length, result);
const record = result[0];
assert(record.hasOwnProperty("resolvedViews"), record);
const resolvedViews = record["resolvedViews"];
assert.eq(2, resolvedViews.length, resolvedViews);
assertResolvedView(resolvedViews[0], `${db.getName()}.a_view`, 2, 2);
assertResolvedView(resolvedViews[1], `${db.getName()}.c_view`, 3, 2);
assert.commandWorked(db.dropDatabase());
MongoRunner.stopMongod(conn);
})();
|
