tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Pass the correct expression to the operator

Browse Source
This commit is contained in:
gvolfing 2023-01-13 12:38:50 +01:00
parent d22c962af4
commit 668f7857b1
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/query/v2/plan/operator.cpp
View File

@ -508,7 +508,7 @@ class DistributedScanAllByPrimaryKeyCursor : public Cursor {
// Evaluate the expressions that hold the PrimaryKey.
ExpressionEvaluator evaluator(&frame, context.symbol_table, context.evaluation_context, context.request_router,
storage::v3::View::OLD);
storage::v3::View::NEW);
std::vector<msgs::Value> pk;
MG_ASSERT(primary_key_);
@ -539,7 +539,7 @@ class DistributedScanAllByPrimaryKeyCursor : public Cursor {
}
if (current_vertex_it_ == current_batch_.end() &&
(request_state_ == State::COMPLETED || !MakeRequest(request_router, context))) {
(request_state_ == State::COMPLETED || !MakeRequestSingleFrame(frame, request_router, context))) {
ResetExecutionState();
continue;
}

2
src/query/v2/plan/rewrite/index_lookup.hpp
View File

@ -600,7 +600,7 @@ class IndexLookupRewriter final : public HierarchicalLogicalOperatorVisitor {
EraseLabelFilters(node_symbol, prim_label);
std::vector<query::v2::Expression *> pk_expressions;
std::transform(primary_key.begin(), primary_key.end(), std::back_inserter(pk_expressions),
[](const auto &exp) { return exp.first; });
[](const auto &exp) { return exp.second.property_filter->value_; });
return std::make_unique<ScanAllByPrimaryKey>(input, node_symbol, GetLabel(prim_label), pk_expressions);
}
}