summaryrefslogtreecommitdiff
path: root/src/mongo/db/query/stats/stats_path_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/query/stats/stats_path_test.cpp')
-rw-r--r--src/mongo/db/query/stats/stats_path_test.cpp129
1 files changed, 129 insertions, 0 deletions
diff --git a/src/mongo/db/query/stats/stats_path_test.cpp b/src/mongo/db/query/stats/stats_path_test.cpp
new file mode 100644
index 00000000000..3e3afe50b32
--- /dev/null
+++ b/src/mongo/db/query/stats/stats_path_test.cpp
@@ -0,0 +1,129 @@
+/**
+ * Copyright (C) 2022-present MongoDB, Inc.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the Server Side Public License, version 1,
+ * as published by MongoDB, Inc.
+ *
+ * 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
+ * Server Side Public License for more details.
+ *
+ * You should have received a copy of the Server Side Public License
+ * along with this program. If not, see
+ * <http://www.mongodb.com/licensing/server-side-public-license>.
+ *
+ * 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 Server Side 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.
+ */
+
+#include "mongo/bson/bsonobjbuilder.h"
+#include "mongo/db/exec/sbe/values/bson.h"
+#include "mongo/db/exec/sbe/values/value.h"
+#include "mongo/db/query/stats/array_histogram.h"
+#include "mongo/db/query/stats/scalar_histogram.h"
+#include "mongo/db/query/stats/stats_gen.h"
+#include "mongo/unittest/unittest.h"
+#include "mongo/util/assert_util.h"
+
+namespace mongo::stats {
+namespace {
+
+IDLParserContext ctx("StatsPath");
+
+/**
+ * Validate round trip conversion for histogram bucket
+ */
+TEST(StatsPath, BasicValidStatsBucketDouble) {
+ // Create & parse StatsBucket.
+ auto serializedBucket = Bucket{3.0, 4.0, 15.0, 2.0, 6.0}.serialize();
+ auto parsedBucket = StatsBucket::parse(ctx, serializedBucket);
+
+ // Round-trip conversion.
+ auto bucketToBSON = parsedBucket.toBSON();
+ ASSERT_BSONOBJ_EQ(serializedBucket, bucketToBSON);
+}
+
+/**
+ * Validate round-trip conversion for StatsPath datatype.
+ */
+TEST(StatsPath, BasicValidStatsPath) {
+ // Initialize histogram buckets.
+ constexpr double doubleCount = 15.0;
+ constexpr double trueCount = 12.0;
+ constexpr double falseCount = 16.0;
+ constexpr double numDocs = doubleCount + trueCount + falseCount;
+ std::vector<Bucket> buckets{
+ Bucket{1.0, 0.0, 1.0, 0.0, 1.0},
+ Bucket{2.0, 5.0, 8.0, 1.0, 2.0},
+ Bucket{3.0, 4.0, 15.0, 2.0, 6.0},
+ };
+
+ // Initialize histogram bounds.
+ auto [boundsTag, boundsVal] = sbe::value::makeNewArray();
+ sbe::value::ValueGuard boundsGuard{boundsTag, boundsVal};
+ auto bounds = sbe::value::getArrayView(boundsVal);
+ bounds->push_back(sbe::value::TypeTags::NumberDouble, 1.0);
+ bounds->push_back(sbe::value::TypeTags::NumberDouble, 2.0);
+ bounds->push_back(sbe::value::TypeTags::NumberDouble, 3.0);
+
+ // Create a scalar histogram.
+ TypeCounts tc{
+ {sbe::value::TypeTags::NumberDouble, doubleCount},
+ {sbe::value::TypeTags::Boolean, trueCount + falseCount},
+ };
+ ScalarHistogram sh(*bounds, buckets);
+ ArrayHistogram ah(sh, tc, trueCount, falseCount);
+
+ // Serialize to BSON.
+ auto serializedPath = stats::makeStatsPath("somePath", numDocs, ah);
+
+ // Parse StatsPath via IDL & serialize to BSON.
+ auto parsedPath = StatsPath::parse(ctx, serializedPath);
+ auto parsedPathToBSON = parsedPath.toBSON();
+
+ // We should end up with the same serialized BSON in the end.
+ ASSERT_BSONOBJ_EQ(serializedPath, parsedPathToBSON);
+}
+
+/**
+ * Validate round-trip conversion for StatsPath datatype.
+ */
+TEST(StatsPath, BasicValidEmptyStatsPath) {
+ // Initialize histogram buckets.
+ constexpr double numDocs = 0.0;
+ std::vector<Bucket> buckets;
+
+ // Initialize histogram bounds.
+ auto [boundsTag, boundsVal] = sbe::value::makeNewArray();
+ sbe::value::ValueGuard boundsGuard{boundsTag, boundsVal};
+ auto bounds = sbe::value::getArrayView(boundsVal);
+
+ // Create an empty scalar histogram.
+ TypeCounts tc;
+ ScalarHistogram sh(*bounds, buckets);
+ ArrayHistogram ah(sh, tc);
+
+ // Serialize to BSON.
+ auto serializedPath = stats::makeStatsPath("someEmptyPath", numDocs, ah);
+
+ // Parse StatsPath via IDL & serialize to BSON.
+ auto parsedPath = StatsPath::parse(ctx, serializedPath);
+ auto parsedPathToBSON = parsedPath.toBSON();
+
+ // We should end up with the same serialized BSON in the end.
+ ASSERT_BSONOBJ_EQ(serializedPath, parsedPathToBSON);
+}
+
+} // namespace
+} // namespace mongo::stats