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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
|
/**
* Copyright (C) 2015 10gen Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License, version 3,
* as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
* As a special exception, the copyright holders give permission to link the
* code of portions of this program with the OpenSSL library under certain
* conditions as described in each individual source file and distribute
* linked combinations including the program with the OpenSSL library. You
* must comply with the GNU Affero General Public License in all respects for
* all of the code used other than as permitted herein. If you modify file(s)
* with this exception, you may extend this exception to your version of the
* file(s), but you are not obligated to do so. If you do not wish to do so,
* delete this exception statement from your version. If you delete this
* exception statement from all source files in the program, then also delete
* it in the license file.
*/
#pragma once
#include <vector>
#include "mongo/base/disallow_copying.h"
#include "mongo/db/exec/projection_exec_agg.h"
#include "mongo/stdx/functional.h"
#include "mongo/util/string_map.h"
namespace mongo {
class BSONObj;
class CollatorInterface;
class CompositeIndexabilityDiscriminator;
class MatchExpression;
struct IndexEntry;
using IndexabilityDiscriminator = stdx::function<bool(const MatchExpression* me)>;
using IndexabilityDiscriminators = std::vector<IndexabilityDiscriminator>;
using IndexToDiscriminatorMap = StringMap<CompositeIndexabilityDiscriminator>;
/**
* CompositeIndexabilityDiscriminator holds all indexability discriminators for a particular path,
* for a particular index. For example, a path may have both a collation discriminator and a sparse
* index discriminator for a particular index.
*/
class CompositeIndexabilityDiscriminator {
public:
/**
* Considers all discriminators for the path-index pair, and returns a single bit indicating
* whether the index can be used for that path.
*/
bool isMatchCompatibleWithIndex(const MatchExpression* me) const {
for (auto&& discriminator : _discriminators) {
if (!discriminator(me)) {
return false;
}
}
return true;
}
void addDiscriminator(IndexabilityDiscriminator discriminator) {
_discriminators.push_back(std::move(discriminator));
}
private:
IndexabilityDiscriminators _discriminators;
};
/**
* PlanCacheIndexabilityState holds a set of "indexability discriminators" for certain paths.
* An indexability discriminator is a binary predicate function, used to classify match
* expressions based on the data values in the expression.
*/
class PlanCacheIndexabilityState {
MONGO_DISALLOW_COPYING(PlanCacheIndexabilityState);
public:
PlanCacheIndexabilityState() = default;
/**
* Returns a map from index name to discriminator for each index associated with 'path'.
* Returns an empty set if no discriminators are registered for 'path'.
*
* The object returned by reference is valid until the next call to updateDiscriminators() or
* until destruction of 'this', whichever is first.
*/
const IndexToDiscriminatorMap& getDiscriminators(StringData path) const;
/**
* Construct an IndexToDiscriminator map for the given path, only for the wildcard indexes
* which have been included in the indexability state.
*/
IndexToDiscriminatorMap buildWildcardDiscriminators(StringData path) const;
/**
* Clears discriminators for all paths, and regenerate them from 'indexEntries'.
*/
void updateDiscriminators(const std::vector<IndexEntry>& indexEntries);
private:
using PathDiscriminatorsMap = StringMap<IndexToDiscriminatorMap>;
/**
* A $** index may index an infinite number of fields. We cannot just store a discriminator for
* every possible field that it indexes, so we have to maintain some special context about the
* index.
*/
struct WildcardIndexDiscriminatorContext {
WildcardIndexDiscriminatorContext(std::unique_ptr<ProjectionExecAgg> proj,
std::string name,
const MatchExpression* filter,
const CollatorInterface* coll)
: projectionExec(std::move(proj)),
catalogName(std::move(name)),
filterExpr(filter),
collator(coll) {}
std::unique_ptr<ProjectionExecAgg> projectionExec;
std::string catalogName;
// These are owned by the catalog.
const MatchExpression* filterExpr; // For partial indexes.
const CollatorInterface* collator;
};
/**
* Adds sparse index discriminators for the sparse index with the given key pattern to
* '_pathDiscriminatorsMap'.
*
* A sparse index discriminator distinguishes equality matches to null from other expression
* types. For example, this allows the predicate {a: 1} to be considered of a different
* shape from the predicate {a: null}, if there is a sparse index defined with "a" as an
* element of the key pattern. The former predicate is compatibile with this index, but the
* latter is not compatible.
*/
void processSparseIndex(const std::string& indexName, const BSONObj& keyPattern);
/**
* Adds partial index discriminators for the partial index with the given filter expression
* to the discriminators for that index in '_pathDiscriminatorsMap'.
*
* A partial index discriminator distinguishes expressions that match a given partial index
* predicate from expressions that don't match the partial index predicate. For example,
* this allows the predicate {a: {$gt: 5}} to be considered a different shape than the
* predicate {a: {$gt: -5}}, if there is a partial index defined with document filter {a:
* {$gt: 0}}. The former is compatible with this index, but the latter is not compatible.
*/
void processPartialIndex(const std::string& indexName, const MatchExpression* filterExpr);
/**
* Adds collation discriminators for the index with the given key pattern and collator to
* '_pathDiscriminatorsMap'.
*
* The discriminator for a given path returns true if the index collator matches the query
* collator, or if the query does not contain string comparison at that path.
*/
void processIndexCollation(const std::string& indexName,
const BSONObj& keyPattern,
const CollatorInterface* collator);
/**
* Adds special state for a $** index. When the discriminators are retrieved for a certain
* path, appropriate discriminators for the wildcard index will be included if it includes the
* given path.
*/
void processWildcardIndex(const IndexEntry& ie);
// PathDiscriminatorsMap is a map from field path to index name to IndexabilityDiscriminator.
PathDiscriminatorsMap _pathDiscriminatorsMap;
std::vector<WildcardIndexDiscriminatorContext> _wildcardIndexDiscriminators;
};
} // namespace mongo
|
