From 75e83d20e2a090569349304c6880b90b8aede634 Mon Sep 17 00:00:00 2001 From: "hs.zhang" <22708345+cangfengzhs@users.noreply.github.com> Date: Tue, 9 Nov 2021 15:07:04 +0800 Subject: [PATCH] rm outdated test --- src/storage/test/IndexScanTest.cpp | 1360 ---------------------------- 1 file changed, 1360 deletions(-) delete mode 100644 src/storage/test/IndexScanTest.cpp diff --git a/src/storage/test/IndexScanTest.cpp b/src/storage/test/IndexScanTest.cpp deleted file mode 100644 index 59d5df1ef6f..00000000000 --- a/src/storage/test/IndexScanTest.cpp +++ /dev/null @@ -1,1360 +0,0 @@ -/* Copyright (c) 2018 vesoft inc. All rights reserved. - * - * This source code is licensed under Apache 2.0 License. - */ - -#include -#include - -#include "codec/RowReader.h" -#include "common/base/Base.h" -#include "common/fs/TempDir.h" -#include "common/utils/NebulaKeyUtils.h" -#include "storage/index/LookUpEdgeIndexProcessor.h" -#include "storage/index/LookUpVertexIndexProcessor.h" -#include "storage/test/TestUtils.h" - -DECLARE_uint32(raft_heartbeat_interval_secs); - -namespace nebula { -namespace storage { -using IndexValues = std::vector>; - -std::string indexStr(RowReader* reader, const nebula::cpp2::ColumnDef& col) { - auto res = RowReader::getPropByName(reader, col.get_name()); - if (!ok(res)) { - LOG(ERROR) << "Skip bad column prop " << col.get_name(); - return ""; - } - auto&& v = value(std::move(res)); - switch (col.get_type().get_type()) { - case nebula::cpp2::SupportedType::BOOL: { - auto val = boost::get(v); - std::string raw; - raw.reserve(sizeof(bool)); - raw.append(reinterpret_cast(&val), sizeof(bool)); - return raw; - } - case nebula::cpp2::SupportedType::INT: - case nebula::cpp2::SupportedType::TIMESTAMP: { - return NebulaKeyUtils::encodeInt64(boost::get(v)); - } - case nebula::cpp2::SupportedType::FLOAT: - case nebula::cpp2::SupportedType::DOUBLE: { - return NebulaKeyUtils::encodeDouble(boost::get(v)); - } - case nebula::cpp2::SupportedType::STRING: { - return boost::get(v); - } - default: - LOG(ERROR) << "Unknown type: " - << apache::thrift::util::enumNameSafe(col.get_type().get_type()); - } - return ""; -} - -IndexValues collectIndexValues(RowReader* reader, - const std::vector& cols) { - IndexValues values; - if (reader == nullptr) { - return values; - } - for (auto& col : cols) { - auto val = indexStr(reader, col); - values.emplace_back(col.get_type().get_type(), std::move(val)); - } - return values; -} - -static std::string genEdgeIndexKey(meta::SchemaManager* schemaMan, - const std::string& prop, - GraphSpaceID spaceId, - PartitionID partId, - EdgeType type, - std::shared_ptr& index, - VertexID src, - VertexID dst) { - auto reader = RowReaderWrapper::getEdgePropReader(schemaMan, prop, spaceId, type); - auto values = collectIndexValues(reader.get(), index->get_fields()); - auto indexKey = - NebulaKeyUtils::edgeIndexKeys(partId, index->get_index_id(), src, 0, dst, values)[0]; - return indexKey; -} - -static std::string genVertexIndexKey(meta::SchemaManager* schemaMan, - const std::string& prop, - GraphSpaceID spaceId, - PartitionID partId, - TagID tagId, - std::shared_ptr& index, - VertexID vId) { - auto reader = RowReaderWrapper::getTagPropReader(schemaMan, prop, spaceId, tagId); - auto values = collectIndexValues(reader.get(), index->get_fields()); - auto indexKey = NebulaKeyUtils::vertexIndexKey(partId, index->get_index_id(), vId, values); - return indexKey; -} - -static std::shared_ptr genEdgeSchemaProvider(int32_t intFieldsNum, - int32_t stringFieldsNum) { - nebula::cpp2::Schema schema; - for (auto i = 0; i < intFieldsNum; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::INT; - schema.columns.emplace_back(std::move(column)); - } - for (auto i = intFieldsNum; i < intFieldsNum + stringFieldsNum; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::STRING; - schema.columns.emplace_back(std::move(column)); - } - return std::make_shared(std::move(schema)); -} - -/** - * It will generate tag SchemaProvider with some int fields and string fields - * */ -static std::shared_ptr genTagSchemaProvider(TagID tagId, - int32_t intFieldsNum, - int32_t stringFieldsNum) { - nebula::cpp2::Schema schema; - for (auto i = 0; i < intFieldsNum; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("tag_%d_col_%d", tagId, i); - column.type.type = nebula::cpp2::SupportedType::INT; - schema.columns.emplace_back(std::move(column)); - } - for (auto i = intFieldsNum; i < intFieldsNum + stringFieldsNum; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("tag_%d_col_%d", tagId, i); - column.type.type = nebula::cpp2::SupportedType::STRING; - schema.columns.emplace_back(std::move(column)); - } - return std::make_shared(std::move(schema)); -} - -static std::unique_ptr mockSchemaMan(GraphSpaceID spaceId, - EdgeType edgeType, - TagID tagId) { - auto* schemaMan = new AdHocSchemaManager(); - schemaMan->addEdgeSchema( - spaceId /*space id*/, edgeType /*edge type*/, genEdgeSchemaProvider(10, 10)); - schemaMan->addTagSchema(spaceId /*space id*/, tagId, genTagSchemaProvider(tagId, 3, 3)); - std::unique_ptr sm(schemaMan); - return sm; -} - -void mockData(kvstore::KVStore* kv, - meta::SchemaManager* schemaMan, - meta::IndexManager* indexMan, - EdgeType edgeType, - TagID tagId, - GraphSpaceID spaceId) { - auto vindex = indexMan->getTagIndex(spaceId, tagId).value(); - auto eindex = indexMan->getEdgeIndex(spaceId, edgeType).value(); - for (auto partId = 0; partId < 3; partId++) { - std::vector data; - for (auto vertexId = partId * 10; vertexId < (partId + 1) * 10; vertexId++) { - auto key = NebulaKeyUtils::vertexKey(partId, vertexId, tagId, 0); - RowWriter writer; - for (uint64_t numInt = 0; numInt < 3; numInt++) { - writer << (numInt + 1); - } - for (auto numString = 3; numString < 6; numString++) { - writer << folly::stringPrintf("tag_string_col_%d", numString); - } - auto val = writer.encode(); - auto indexKey = genVertexIndexKey(schemaMan, val, spaceId, partId, tagId, vindex, vertexId); - data.emplace_back(std::move(indexKey), ""); - data.emplace_back(std::move(key), std::move(val)); - - for (auto dstId = 10001; dstId <= 10007; dstId++) { - VLOG(3) << "Write part " << partId << ", vertex " << vertexId << ", dst " << dstId; - auto ekey = NebulaKeyUtils::edgeKey(partId, vertexId, edgeType, 0, dstId); - RowWriter ewriter(nullptr); - for (uint64_t numInt = 0; numInt < 10; numInt++) { - ewriter << (numInt + 1); - } - for (auto numString = 10; numString < 20; numString++) { - ewriter << folly::stringPrintf("string_col_%d", numString); - } - auto eval = ewriter.encode(); - auto edgeIndex = - genEdgeIndexKey(schemaMan, eval, spaceId, partId, edgeType, eindex, vertexId, dstId); - data.emplace_back(std::move(edgeIndex), ""); - data.emplace_back(std::move(ekey), std::move(eval)); - } - } - folly::Baton baton; - kv->asyncMultiPut(0, partId, std::move(data), [&](cpp2::ErrorCode code) { - EXPECT_EQ(code, cpp2::ErrorCode::SUCCEEDED); - baton.post(); - }); - baton.wait(); - } -} - -static std::unique_ptr mockIndexMan(GraphSpaceID spaceId = 0, - TagID tagId = 3001, - EdgeType edgeType = 101) { - auto* indexMan = new AdHocIndexManager(); - { - std::vector cols; - for (auto i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("tag_%d_col_%d", tagId, i); - column.type.type = nebula::cpp2::SupportedType::INT; - cols.emplace_back(std::move(column)); - } - for (auto i = 3; i < 6; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("tag_%d_col_%d", tagId, i); - column.type.type = nebula::cpp2::SupportedType::STRING; - cols.emplace_back(std::move(column)); - } - indexMan->addTagIndex(spaceId, tagId, tagId, std::move(cols)); - } - { - std::vector cols; - for (int32_t i = 0; i < 10; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::INT; - cols.emplace_back(std::move(column)); - } - for (int32_t i = 10; i < 20; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::STRING; - cols.emplace_back(std::move(column)); - } - indexMan->addEdgeIndex(spaceId, edgeType, edgeType, std::move(cols)); - } - std::unique_ptr im(indexMan); - return im; -} - -static cpp2::LookUpVertexIndexResp execLookupVertices(const std::string& filter, - bool hasReturnCols = true) { - fs::TempDir rootPath("/tmp/execLookupVertices.XXXXXX"); - std::unique_ptr kv = TestUtils::initKV(rootPath.path()); - GraphSpaceID spaceId = 0; - TagID tagId = 3001; - EdgeType type = 101; - LOG(INFO) << "Prepare meta..."; - auto schemaMan = mockSchemaMan(spaceId, type, tagId); - auto indexMan = mockIndexMan(spaceId, tagId, type); - mockData(kv.get(), schemaMan.get(), indexMan.get(), type, tagId, spaceId); - auto* processor = - LookUpVertexIndexProcessor::instance(kv.get(), schemaMan.get(), indexMan.get(), nullptr); - cpp2::LookUpIndexRequest req; - decltype(req.parts) parts; - parts.emplace_back(0); - parts.emplace_back(1); - parts.emplace_back(2); - if (hasReturnCols) { - decltype(req.return_columns) cols; - cols.emplace_back("tag_3001_col_0"); - cols.emplace_back("tag_3001_col_1"); - cols.emplace_back("tag_3001_col_3"); - cols.emplace_back("tag_3001_col_4"); - req.set_return_columns(cols); - } - req.set_space_id(spaceId); - req.set_parts(std::move(parts)); - req.set_index_id(tagId); - - req.set_filter(filter); - auto f = processor->getFuture(); - processor->process(req); - return std::move(f).get(); -} - -static cpp2::LookUpEdgeIndexResp execLookupEdges(const std::string& filter, - bool hasReturnCols = true) { - fs::TempDir rootPath("/tmp/execLookupEdges.XXXXXX"); - std::unique_ptr kv = TestUtils::initKV(rootPath.path()); - GraphSpaceID spaceId = 0; - TagID tagId = 3001; - EdgeType type = 101; - LOG(INFO) << "Prepare meta..."; - auto schemaMan = mockSchemaMan(spaceId, type, tagId); - auto indexMan = mockIndexMan(spaceId, tagId, type); - mockData(kv.get(), schemaMan.get(), indexMan.get(), type, tagId, spaceId); - auto* processor = - LookUpEdgeIndexProcessor::instance(kv.get(), schemaMan.get(), indexMan.get(), nullptr); - cpp2::LookUpIndexRequest req; - decltype(req.parts) parts; - parts.emplace_back(0); - parts.emplace_back(1); - parts.emplace_back(2); - if (hasReturnCols) { - decltype(req.return_columns) cols; - cols.emplace_back("col_0"); - cols.emplace_back("col_1"); - cols.emplace_back("col_3"); - cols.emplace_back("col_4"); - cols.emplace_back("col_10"); - cols.emplace_back("col_11"); - cols.emplace_back("col_13"); - cols.emplace_back("col_14"); - req.set_return_columns(cols); - } - req.set_space_id(spaceId); - req.set_parts(std::move(parts)); - req.set_index_id(type); - - req.set_filter(filter); - auto f = processor->getFuture(); - processor->process(req); - return std::move(f).get(); -} - -static cpp2::LookUpEdgeIndexResp checkLookupEdgesString(const std::string& filter) { - fs::TempDir rootPath("/tmp/checkLookupEdgesString.XXXXXX"); - std::unique_ptr kv = TestUtils::initKV(rootPath.path()); - GraphSpaceID spaceId = 0; - EdgeType type = 101; - - nebula::cpp2::Schema schema; - for (auto i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::STRING; - schema.columns.emplace_back(std::move(column)); - } - auto sp = std::make_shared(std::move(schema)); - auto* sm = new AdHocSchemaManager(); - sm->addEdgeSchema(spaceId /*space id*/, type /*edge type*/, sp); - std::unique_ptr schemaMan(sm); - - auto* im = new AdHocIndexManager(); - { - std::vector cols; - for (int32_t i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::STRING; - cols.emplace_back(std::move(column)); - } - im->addEdgeIndex(spaceId, type, type, std::move(cols)); - } - std::unique_ptr indexMan(im); - auto eindex = indexMan->getEdgeIndex(spaceId, type).value(); - sleep(FLAGS_raft_heartbeat_interval_secs); - { - for (auto partId = 0; partId < 3; partId++) { - std::vector data; - { - VertexID srcId = 1; - VertexID dstId = 10; - auto eKey = NebulaKeyUtils::edgeKey(partId, srcId, type, 0, dstId); - RowWriter ewriter(nullptr); - ewriter << "AB" - << "CAB" - << "CABC"; - auto eval = ewriter.encode(); - auto edgeIndex = - genEdgeIndexKey(schemaMan.get(), eval, spaceId, partId, type, eindex, srcId, dstId); - data.emplace_back(std::move(edgeIndex), ""); - data.emplace_back(std::move(eKey), std::move(eval)); - } - { - VertexID srcId = 2; - VertexID dstId = 20; - auto eKey = NebulaKeyUtils::edgeKey(partId, srcId, type, 0, dstId); - RowWriter ewriter(nullptr); - ewriter << "ABC" - << "ABC" - << "ABC"; - auto eval = ewriter.encode(); - auto edgeIndex = - genEdgeIndexKey(schemaMan.get(), eval, spaceId, partId, type, eindex, srcId, dstId); - data.emplace_back(std::move(edgeIndex), ""); - data.emplace_back(std::move(eKey), std::move(eval)); - } - folly::Baton baton; - kv->asyncMultiPut(0, partId, std::move(data), [&](cpp2::ErrorCode code) { - EXPECT_EQ(code, cpp2::ErrorCode::SUCCEEDED); - baton.post(); - }); - baton.wait(); - } - } - auto* processor = - LookUpEdgeIndexProcessor::instance(kv.get(), schemaMan.get(), indexMan.get(), nullptr); - cpp2::LookUpIndexRequest req; - decltype(req.parts) parts; - parts.emplace_back(0); - parts.emplace_back(1); - parts.emplace_back(2); - decltype(req.return_columns) cols; - cols.emplace_back("col_0"); - cols.emplace_back("col_1"); - cols.emplace_back("col_2"); - req.set_space_id(spaceId); - req.set_parts(std::move(parts)); - req.set_index_id(type); - req.set_return_columns(cols); - req.set_filter(filter); - auto f = processor->getFuture(); - processor->process(req); - return std::move(f).get(); -} - -static cpp2::LookUpVertexIndexResp checkLookupVerticesString(const std::string& filter) { - fs::TempDir rootPath("/tmp/checkLookupVerticesString.XXXXXX"); - std::unique_ptr kv = TestUtils::initKV(rootPath.path()); - GraphSpaceID spaceId = 0; - TagID tagId = 3001; - nebula::cpp2::Schema schema; - for (auto i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::STRING; - schema.columns.emplace_back(std::move(column)); - } - auto sp = std::make_shared(std::move(schema)); - auto* sm = new AdHocSchemaManager(); - sm->addTagSchema(spaceId /*space id*/, tagId /*Tag ID*/, sp); - std::unique_ptr schemaMan(sm); - - auto* im = new AdHocIndexManager(); - { - std::vector cols; - for (int32_t i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::STRING; - cols.emplace_back(std::move(column)); - } - im->addTagIndex(spaceId, tagId, tagId, std::move(cols)); - } - std::unique_ptr indexMan(im); - auto vindex = indexMan->getTagIndex(spaceId, tagId).value(); - sleep(FLAGS_raft_heartbeat_interval_secs); - { - for (auto partId = 0; partId < 3; partId++) { - std::vector data; - auto version = std::numeric_limits::max() - 1; - { - VertexID vertexId = 100; - auto key = NebulaKeyUtils::vertexKey(partId, vertexId, tagId, version); - RowWriter twriter(nullptr); - twriter << "AB" - << "CAB" - << "CABC"; - auto tval = twriter.encode(); - auto vIndex = - genVertexIndexKey(schemaMan.get(), tval, spaceId, partId, tagId, vindex, vertexId); - data.emplace_back(std::move(vIndex), ""); - data.emplace_back(std::move(key), std::move(tval)); - } - { - VertexID vertexId = 200; - auto key = NebulaKeyUtils::vertexKey(partId, vertexId, tagId, version); - RowWriter twriter(nullptr); - twriter << "ABC" - << "ABC" - << "ABC"; - auto tval = twriter.encode(); - auto vIndex = - genVertexIndexKey(schemaMan.get(), tval, spaceId, partId, tagId, vindex, vertexId); - data.emplace_back(std::move(vIndex), ""); - data.emplace_back(std::move(key), std::move(tval)); - } - folly::Baton baton; - kv->asyncMultiPut(0, partId, std::move(data), [&](cpp2::ErrorCode code) { - EXPECT_EQ(code, cpp2::ErrorCode::SUCCEEDED); - baton.post(); - }); - baton.wait(); - } - } - auto* processor = - LookUpVertexIndexProcessor::instance(kv.get(), schemaMan.get(), indexMan.get(), nullptr); - cpp2::LookUpIndexRequest req; - decltype(req.parts) parts; - parts.emplace_back(0); - parts.emplace_back(1); - parts.emplace_back(2); - decltype(req.return_columns) cols; - cols.emplace_back("col_0"); - cols.emplace_back("col_1"); - cols.emplace_back("col_2"); - req.set_space_id(spaceId); - req.set_parts(std::move(parts)); - req.set_index_id(tagId); - req.set_return_columns(cols); - req.set_filter(filter); - auto f = processor->getFuture(); - processor->process(req); - return std::move(f).get(); -} - -static cpp2::LookUpEdgeIndexResp checkLookupEdgesDouble(const std::string& filter) { - fs::TempDir rootPath("/tmp/checkLookupEdgesDouble.XXXXXX"); - std::unique_ptr kv = TestUtils::initKV(rootPath.path()); - GraphSpaceID spaceId = 0; - EdgeType type = 101; - - nebula::cpp2::Schema schema; - for (auto i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::DOUBLE; - schema.columns.emplace_back(std::move(column)); - } - auto sp = std::make_shared(std::move(schema)); - auto* sm = new AdHocSchemaManager(); - sm->addEdgeSchema(spaceId /*space id*/, type /*edge type*/, sp); - std::unique_ptr schemaMan(sm); - - auto* im = new AdHocIndexManager(); - { - std::vector cols; - for (int32_t i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::DOUBLE; - cols.emplace_back(std::move(column)); - } - im->addEdgeIndex(spaceId, type, type, std::move(cols)); - } - std::unique_ptr indexMan(im); - auto eindex = indexMan->getEdgeIndex(spaceId, type).value(); - sleep(FLAGS_raft_heartbeat_interval_secs); - { - for (auto partId = 0; partId < 3; partId++) { - std::vector data; - { - VertexID srcId = 1; - VertexID dstId = 10; - auto eKey = NebulaKeyUtils::edgeKey(partId, srcId, type, 0, dstId); - RowWriter ewriter(nullptr); - ewriter << boost::get(1.1) << boost::get(0.0) << boost::get(-1.1); - auto eval = ewriter.encode(); - auto edgeIndex = - genEdgeIndexKey(schemaMan.get(), eval, spaceId, partId, type, eindex, srcId, dstId); - data.emplace_back(std::move(edgeIndex), ""); - data.emplace_back(std::move(eKey), std::move(eval)); - } - { - VertexID srcId = 2; - VertexID dstId = 20; - auto eKey = NebulaKeyUtils::edgeKey(partId, srcId, type, 0, dstId); - RowWriter ewriter(nullptr); - ewriter << boost::get(2.2) << boost::get(0.0) << boost::get(-2.2); - auto eval = ewriter.encode(); - auto edgeIndex = - genEdgeIndexKey(schemaMan.get(), eval, spaceId, partId, type, eindex, srcId, dstId); - data.emplace_back(std::move(edgeIndex), ""); - data.emplace_back(std::move(eKey), std::move(eval)); - } - folly::Baton baton; - kv->asyncMultiPut(0, partId, std::move(data), [&](cpp2::ErrorCode code) { - EXPECT_EQ(code, cpp2::ErrorCode::SUCCEEDED); - baton.post(); - }); - baton.wait(); - } - } - auto* processor = - LookUpEdgeIndexProcessor::instance(kv.get(), schemaMan.get(), indexMan.get(), nullptr); - cpp2::LookUpIndexRequest req; - decltype(req.parts) parts; - parts.emplace_back(0); - parts.emplace_back(1); - parts.emplace_back(2); - decltype(req.return_columns) cols; - cols.emplace_back("col_0"); - cols.emplace_back("col_1"); - cols.emplace_back("col_2"); - req.set_space_id(spaceId); - req.set_parts(std::move(parts)); - req.set_index_id(type); - req.set_return_columns(cols); - req.set_filter(filter); - auto f = processor->getFuture(); - processor->process(req); - return std::move(f).get(); -} - -static cpp2::LookUpVertexIndexResp checkLookupVerticesDouble(const std::string& filter) { - fs::TempDir rootPath("/tmp/checkLookupVerticesDouble.XXXXXX"); - std::unique_ptr kv = TestUtils::initKV(rootPath.path()); - GraphSpaceID spaceId = 0; - TagID tagId = 3001; - nebula::cpp2::Schema schema; - for (auto i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::DOUBLE; - schema.columns.emplace_back(std::move(column)); - } - auto sp = std::make_shared(std::move(schema)); - auto* sm = new AdHocSchemaManager(); - sm->addTagSchema(spaceId /*space id*/, tagId /*Tag ID*/, sp); - std::unique_ptr schemaMan(sm); - - auto* im = new AdHocIndexManager(); - { - std::vector cols; - for (int32_t i = 0; i < 3; i++) { - nebula::cpp2::ColumnDef column; - column.name = folly::stringPrintf("col_%d", i); - column.type.type = nebula::cpp2::SupportedType::DOUBLE; - cols.emplace_back(std::move(column)); - } - im->addTagIndex(spaceId, tagId, tagId, std::move(cols)); - } - std::unique_ptr indexMan(im); - auto vindex = indexMan->getTagIndex(spaceId, tagId).value(); - sleep(FLAGS_raft_heartbeat_interval_secs); - { - for (auto partId = 0; partId < 3; partId++) { - std::vector data; - auto version = std::numeric_limits::max() - 1; - { - VertexID vertexId = 100; - auto key = NebulaKeyUtils::vertexKey(partId, vertexId, tagId, version); - RowWriter twriter(nullptr); - twriter << boost::get(1.1) << boost::get(0.0) << boost::get(-1.1); - auto tval = twriter.encode(); - auto vIndex = - genVertexIndexKey(schemaMan.get(), tval, spaceId, partId, tagId, vindex, vertexId); - data.emplace_back(std::move(vIndex), ""); - data.emplace_back(std::move(key), std::move(tval)); - } - { - VertexID vertexId = 200; - auto key = NebulaKeyUtils::vertexKey(partId, vertexId, tagId, version); - RowWriter twriter(nullptr); - twriter << boost::get(2.2) << boost::get(0.0) << boost::get(-2.2); - auto tval = twriter.encode(); - auto vIndex = - genVertexIndexKey(schemaMan.get(), tval, spaceId, partId, tagId, vindex, vertexId); - data.emplace_back(std::move(vIndex), ""); - data.emplace_back(std::move(key), std::move(tval)); - } - folly::Baton baton; - kv->asyncMultiPut(0, partId, std::move(data), [&](cpp2::ErrorCode code) { - EXPECT_EQ(code, cpp2::ErrorCode::SUCCEEDED); - baton.post(); - }); - baton.wait(); - } - } - auto* processor = - LookUpVertexIndexProcessor::instance(kv.get(), schemaMan.get(), indexMan.get(), nullptr); - cpp2::LookUpIndexRequest req; - decltype(req.parts) parts; - parts.emplace_back(0); - parts.emplace_back(1); - parts.emplace_back(2); - decltype(req.return_columns) cols; - cols.emplace_back("col_0"); - cols.emplace_back("col_1"); - cols.emplace_back("col_2"); - req.set_space_id(spaceId); - req.set_parts(std::move(parts)); - req.set_index_id(tagId); - req.set_return_columns(cols); - req.set_filter(filter); - auto f = processor->getFuture(); - processor->process(req); - return std::move(f).get(); -} - -TEST(IndexScanTest, SimpleScanTest) { - { - LOG(INFO) << "Build filter..."; - auto* prop = new std::string("tag_3001_col_0"); - auto* alias = new std::string("3001"); - auto* aliaExp = new AliasPropertyExpression(new std::string(""), alias, prop); - auto* priExp = new PrimaryExpression(1L); - auto relExp = - std::make_unique(aliaExp, RelationalExpression::Operator::EQ, priExp); - auto resp = execLookupVertices(Expression::encode(relExp.get())); - - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(4, resp.get_schema()->get_columns().size()); - EXPECT_EQ(30, resp.rows.size()); - } - { - LOG(INFO) << "Build filter..."; - auto* prop = new std::string("col_0"); - auto* alias = new std::string("101"); - auto* aliaExp = new AliasPropertyExpression(new std::string(""), alias, prop); - auto* priExp = new PrimaryExpression(1L); - auto relExp = - std::make_unique(aliaExp, RelationalExpression::Operator::EQ, priExp); - auto resp = execLookupEdges(Expression::encode(relExp.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(8, resp.get_schema()->get_columns().size()); - EXPECT_EQ(210, resp.rows.size()); - } -} - -TEST(IndexScanTest, AccurateScanTest) { - { - LOG(INFO) << "Build filter..."; - /** - * where tag_3001_col_0 == 1 and - * tag_3001_col_1 == 2 and - * tag_3001_col_2 == 3 - */ - auto* col0 = new std::string("tag_3001_col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(1L); - auto* r1 = new RelationalExpression(ape0, RelationalExpression::Operator::EQ, pe0); - - auto* col1 = new std::string("tag_3001_col_1"); - auto* alias1 = new std::string("3001"); - auto* ape1 = new AliasPropertyExpression(new std::string(""), alias1, col1); - auto* pe1 = new PrimaryExpression(2L); - auto* r2 = new RelationalExpression(ape1, RelationalExpression::Operator::EQ, pe1); - - auto* col2 = new std::string("tag_3001_col_2"); - auto* alias2 = new std::string("3001"); - auto* ape2 = new AliasPropertyExpression(new std::string(""), alias2, col2); - auto* pe2 = new PrimaryExpression(3L); - auto* r3 = new RelationalExpression(ape2, RelationalExpression::Operator::EQ, pe2); - auto* le1 = new LogicalExpression(r1, LogicalExpression::AND, r2); - - auto logExp = std::make_unique(le1, LogicalExpression::AND, r3); - auto resp = execLookupVertices(Expression::encode(logExp.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(4, resp.get_schema()->get_columns().size()); - EXPECT_EQ(30, resp.rows.size()); - } - { - LOG(INFO) << "Build filter..."; - /** - * where col_0 == 1 and - * col_1 == 2 and - * col_2 == 3 - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(1L); - auto* r1 = new RelationalExpression(ape0, RelationalExpression::Operator::EQ, pe0); - - auto* col1 = new std::string("col_1"); - auto* alias1 = new std::string("101"); - auto* ape1 = new AliasPropertyExpression(new std::string(""), alias1, col1); - auto* pe1 = new PrimaryExpression(2L); - auto* r2 = new RelationalExpression(ape1, RelationalExpression::Operator::EQ, pe1); - - auto* col2 = new std::string("col_2"); - auto* alias2 = new std::string("101"); - auto* ape2 = new AliasPropertyExpression(new std::string(""), alias2, col2); - auto* pe2 = new PrimaryExpression(3L); - auto* r3 = new RelationalExpression(ape2, RelationalExpression::Operator::EQ, pe2); - auto* le1 = new LogicalExpression(r1, LogicalExpression::AND, r2); - - auto logExp = std::make_unique(le1, LogicalExpression::AND, r3); - auto resp = execLookupEdges(Expression::encode(logExp.get())); - - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(8, resp.get_schema()->get_columns().size()); - EXPECT_EQ(210, resp.rows.size()); - } -} -TEST(IndexScanTest, SeekScanTest) { - { - LOG(INFO) << "Build filter..."; - /** - * where tag_3001_col_0 > 0 - */ - auto* col0 = new std::string("tag_3001_col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(0L); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::GT, pe0); - auto resp = execLookupVertices(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(4, resp.get_schema()->get_columns().size()); - EXPECT_EQ(30, resp.rows.size()); - } - { - LOG(INFO) << "Build filter..."; - /** - * where col_0 > 0 - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(0L); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::GT, pe0); - auto resp = execLookupEdges(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(8, resp.get_schema()->get_columns().size()); - EXPECT_EQ(210, resp.rows.size()); - } - { - LOG(INFO) << "Build filter..."; - /** - * where tag_3001_col_1 > 0 - */ - auto* col0 = new std::string("tag_3001_col_1"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(0L); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::GT, pe0); - auto resp = execLookupVertices(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(4, resp.get_schema()->get_columns().size()); - EXPECT_EQ(30, resp.rows.size()); - } - { - LOG(INFO) << "Build filter..."; - /** - * where col_1 > 0 - */ - auto* col0 = new std::string("col_1"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(0L); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::GT, pe0); - auto resp = execLookupEdges(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(8, resp.get_schema()->get_columns().size()); - EXPECT_EQ(210, resp.rows.size()); - } -} - -TEST(IndexScanTest, PrefixScanTest) { - { - LOG(INFO) << "Build filter..."; - /** - * where tag_3001_col_0 == 1 and - * tag_3001_col_1 > 1 - */ - auto* col0 = new std::string("tag_3001_col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(1L); - auto* r1 = new RelationalExpression(ape0, RelationalExpression::Operator::EQ, pe0); - - auto* col1 = new std::string("tag_3001_col_1"); - auto* alias1 = new std::string("3001"); - auto* ape1 = new AliasPropertyExpression(new std::string(""), alias1, col1); - auto* pe1 = new PrimaryExpression(1L); - auto* r2 = new RelationalExpression(ape1, RelationalExpression::Operator::GT, pe1); - - auto logExp = std::make_unique(r1, LogicalExpression::AND, r2); - auto resp = execLookupVertices(Expression::encode(logExp.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(4, resp.get_schema()->get_columns().size()); - EXPECT_EQ(30, resp.rows.size()); - } - { - LOG(INFO) << "Build filter..."; - /** - * where col_0 == 1 and - * col_1 > 1 - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(1L); - auto* r1 = new RelationalExpression(ape0, RelationalExpression::Operator::EQ, pe0); - - auto* col1 = new std::string("col_1"); - auto* alias1 = new std::string("101"); - auto* ape1 = new AliasPropertyExpression(new std::string(""), alias1, col1); - auto* pe1 = new PrimaryExpression(1L); - auto* r2 = new RelationalExpression(ape1, RelationalExpression::Operator::GT, pe1); - - auto logExp = std::make_unique(r1, LogicalExpression::AND, r2); - auto resp = execLookupEdges(Expression::encode(logExp.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(8, resp.get_schema()->get_columns().size()); - EXPECT_EQ(210, resp.rows.size()); - } -} - -TEST(IndexScanTest, NoReturnColumnsTest) { - { - LOG(INFO) << "Build filter..."; - /** - * where tag_3001_col_0 == 1 and - * tag_3001_col_1 > 1 - */ - auto* col0 = new std::string("tag_3001_col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(1L); - auto* r1 = new RelationalExpression(ape0, RelationalExpression::Operator::EQ, pe0); - - auto* col1 = new std::string("tag_3001_col_1"); - auto* alias1 = new std::string("3001"); - auto* ape1 = new AliasPropertyExpression(new std::string(""), alias1, col1); - auto* pe1 = new PrimaryExpression(1L); - auto* r2 = new RelationalExpression(ape1, RelationalExpression::Operator::GT, pe1); - - auto logExp = std::make_unique(r1, LogicalExpression::AND, r2); - auto resp = execLookupVertices(Expression::encode(logExp.get()), false); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(NULL, resp.get_schema()); - EXPECT_EQ(30, resp.rows.size()); - } - { - LOG(INFO) << "Build filter..."; - /** - * where col_0 == 1 and - * col_1 > 1 - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - auto* pe0 = new PrimaryExpression(1L); - auto* r1 = new RelationalExpression(ape0, RelationalExpression::Operator::EQ, pe0); - - auto* col1 = new std::string("col_1"); - auto* alias1 = new std::string("101"); - auto* ape1 = new AliasPropertyExpression(new std::string(""), alias1, col1); - auto* pe1 = new PrimaryExpression(1L); - auto* r2 = new RelationalExpression(ape1, RelationalExpression::Operator::GT, pe1); - - auto logExp = std::make_unique(r1, LogicalExpression::AND, r2); - auto resp = execLookupEdges(Expression::encode(logExp.get()), false); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(NULL, resp.get_schema()); - EXPECT_EQ(210, resp.rows.size()); - } -} - -TEST(IndexScanTest, EdgeStringTest) { - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "AB" << "CAB" << "CABC" - * "ABC" << "ABC" << "ABC" - * - * where col_0 == "ABC" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - std::string c0("ABC"); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupEdgesString(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << "ABC" - << "ABC" - << "ABC"; - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(2, row.get_key().get_src()); - EXPECT_EQ(20, row.get_key().get_dst()); - EXPECT_EQ(101, row.get_key().get_edge_type()); - EXPECT_EQ(0, row.get_key().get_ranking()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "AB" << "CAB" << "CABC" - * "ABC" << "ABC" << "ABC" - * - * where col_0 == "AB" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - std::string c0("AB"); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupEdgesString(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << "AB" - << "CAB" - << "CABC"; - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(1, row.get_key().get_src()); - EXPECT_EQ(10, row.get_key().get_dst()); - EXPECT_EQ(101, row.get_key().get_edge_type()); - EXPECT_EQ(0, row.get_key().get_ranking()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "AB" << "CAB" << "CABC" - * "ABC" << "ABC" << "ABC" - * - * where col_1 == "CAB" - */ - auto* col0 = new std::string("col_1"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - std::string c1("CAB"); - auto* pe0 = new PrimaryExpression(c1); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupEdgesString(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << "AB" - << "CAB" - << "CABC"; - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(1, row.get_key().get_src()); - EXPECT_EQ(10, row.get_key().get_dst()); - EXPECT_EQ(101, row.get_key().get_edge_type()); - EXPECT_EQ(0, row.get_key().get_ranking()); - } - } -} - -TEST(IndexScanTest, VertexStringTest) { - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "AB" << "CAB" << "CABC" - * "ABC" << "ABC" << "ABC" - * - * where col_0 == "ABC" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - std::string c0("ABC"); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupVerticesString(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << "ABC" - << "ABC" - << "ABC"; - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(200, row.get_vertex_id()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "AB" << "CAB" << "CABC" - * "ABC" << "ABC" << "ABC" - * - * where col_0 == "AB" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - std::string c0("AB"); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupVerticesString(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << "AB" - << "CAB" - << "CABC"; - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(100, row.get_vertex_id()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "AB" << "CAB" << "CABC" - * "ABC" << "ABC" << "ABC" - * - * where col_1 == "CAB" - */ - auto* col0 = new std::string("col_1"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - std::string c1("CAB"); - auto* pe0 = new PrimaryExpression(c1); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupVerticesString(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << "AB" - << "CAB" - << "CABC"; - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(100, row.get_vertex_id()); - } - } -} - -TEST(IndexScanTest, EdgeDoubleTest) { - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_0 == "1.1" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - double c0(1.1); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupEdgesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << boost::get(1.1) << boost::get(0.0) << boost::get(-1.1); - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(1, row.get_key().get_src()); - EXPECT_EQ(10, row.get_key().get_dst()); - EXPECT_EQ(101, row.get_key().get_edge_type()); - EXPECT_EQ(0, row.get_key().get_ranking()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_2 == "-1.1" - */ - auto* col2 = new std::string("col_2"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col2); - double c2(-1.1); - auto* pe0 = new PrimaryExpression(c2); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupEdgesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << boost::get(1.1) << boost::get(0.0) << boost::get(-1.1); - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(1, row.get_key().get_src()); - EXPECT_EQ(10, row.get_key().get_dst()); - EXPECT_EQ(101, row.get_key().get_edge_type()); - EXPECT_EQ(0, row.get_key().get_ranking()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_0 > "1.1" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - double c0(1.1); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::GT, pe0); - auto resp = checkLookupEdgesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << boost::get(2.2) << boost::get(0.0) << boost::get(-2.2); - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(2, row.get_key().get_src()); - EXPECT_EQ(20, row.get_key().get_dst()); - EXPECT_EQ(101, row.get_key().get_edge_type()); - EXPECT_EQ(0, row.get_key().get_ranking()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_1 == "0.0" - */ - auto* col1 = new std::string("col_1"); - auto* alias0 = new std::string("101"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col1); - double c1(0.0); - auto* pe0 = new PrimaryExpression(c1); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupEdgesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(6, resp.rows.size()); - } -} - -TEST(IndexScanTest, VertexDoubleTest) { - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_0 == "1.1" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - double c0(1.1); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupVerticesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << boost::get(1.1) << boost::get(0.0) << boost::get(-1.1); - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(100, row.get_vertex_id()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_2 == "-1.1" - */ - auto* col2 = new std::string("col_2"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col2); - double c2(-1.1); - auto* pe0 = new PrimaryExpression(c2); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupVerticesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << boost::get(1.1) << boost::get(0.0) << boost::get(-1.1); - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(100, row.get_vertex_id()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_0 > "1.1" - */ - auto* col0 = new std::string("col_0"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col0); - double c0(1.1); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::GT, pe0); - auto resp = checkLookupVerticesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(3, resp.rows.size()); - RowWriter ewriter(nullptr); - ewriter << boost::get(2.2) << boost::get(0.0) << boost::get(-2.2); - auto eval = ewriter.encode(); - for (const auto& row : resp.rows) { - EXPECT_EQ(eval, row.get_props()); - EXPECT_EQ(200, row.get_vertex_id()); - } - } - { - LOG(INFO) << "Build filter..."; - /** - * Total rows : - * col_0 col_1 col_2 - * "1.1" << "0.0" << "-1.1" - * "2.2" << "0.0" << "-2.2" - * - * where col_1 == "0.0" - */ - auto* col1 = new std::string("col_1"); - auto* alias0 = new std::string("3001"); - auto* ape0 = new AliasPropertyExpression(new std::string(""), alias0, col1); - double c0(0.0); - auto* pe0 = new PrimaryExpression(c0); - auto r1 = std::make_unique(ape0, RelationalExpression::Operator::EQ, pe0); - auto resp = checkLookupVerticesDouble(Expression::encode(r1.get())); - EXPECT_EQ(0, resp.result.failed_codes.size()); - EXPECT_EQ(3, resp.get_schema()->get_columns().size()); - EXPECT_EQ(6, resp.rows.size()); - } -} - -} // namespace storage -} // namespace nebula - -int main(int argc, char** argv) { - testing::InitGoogleTest(&argc, argv); - folly::init(&argc, &argv, true); - google::SetStderrLogging(google::INFO); - return RUN_ALL_TESTS(); -}