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

Add external storage checks to VertexAccessor

Browse Source
This commit is contained in:
Ante Pušić 2024-01-08 00:35:05 +01:00
parent ec35144265
commit fe7e230e21
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/storage/v2/vertex_accessor.cpp
View File

@ -270,9 +270,14 @@ Result<PropertyValue> VertexAccessor::SetProperty(PropertyId property, const Pro
// transactions get a SERIALIZATION_ERROR. // transactions get a SERIALIZATION_ERROR.
utils::AtomicMemoryBlock atomic_memory_block{ utils::AtomicMemoryBlock atomic_memory_block{
[transaction = transaction_, vertex = vertex_, &value, &property, &current_value]() { [transaction = transaction_, storage = storage_, vertex = vertex_, &value, &property, &current_value]() {
CreateAndLinkDelta(transaction, vertex, Delta::SetPropertyTag(), property, current_value); CreateAndLinkDelta(transaction, vertex, Delta::SetPropertyTag(), property, current_value);
if (std::ranges::any_of(vertex->labels,
[storage](auto &label) { return storage->indices_.text_index_->IndexExists(label); })) {
vertex->properties.SetProperty(property, value, true, vertex->gid);
} else {
vertex->properties.SetProperty(property, value); vertex->properties.SetProperty(property, value);
}
}}; }};
std::invoke(atomic_memory_block); std::invoke(atomic_memory_block);
@ -345,7 +350,13 @@ Result<std::vector<std::tuple<PropertyId, PropertyValue, PropertyValue>>> Vertex
std::optional<ReturnType> id_old_new_change; std::optional<ReturnType> id_old_new_change;
utils::AtomicMemoryBlock atomic_memory_block{ utils::AtomicMemoryBlock atomic_memory_block{
[storage = storage_, transaction = transaction_, vertex = vertex_, &properties, &id_old_new_change]() { [storage = storage_, transaction = transaction_, vertex = vertex_, &properties, &id_old_new_change]() {
if (std::ranges::any_of(vertex->labels,
[storage](auto &label) { return storage->indices_.text_index_->IndexExists(label); })) {
id_old_new_change.emplace(vertex->properties.UpdateProperties(properties, true, vertex->gid));
} else {
id_old_new_change.emplace(vertex->properties.UpdateProperties(properties)); id_old_new_change.emplace(vertex->properties.UpdateProperties(properties));
}
if (!id_old_new_change.has_value()) { if (!id_old_new_change.has_value()) {
return; return;
} }
@ -389,7 +400,12 @@ Result<std::map<PropertyId, PropertyValue>> VertexAccessor::ClearProperties() {
transaction->constraint_verification_info.RemovedProperty(vertex); transaction->constraint_verification_info.RemovedProperty(vertex);
transaction->manyDeltasCache.Invalidate(vertex, property); transaction->manyDeltasCache.Invalidate(vertex, property);
} }
if (std::ranges::any_of(vertex->labels,
[storage](auto &label) { return storage->indices_.text_index_->IndexExists(label); })) {
vertex->properties.ClearProperties(true, vertex->gid);
} else {
vertex->properties.ClearProperties(); vertex->properties.ClearProperties();
}
}}; }};
std::invoke(atomic_memory_block); std::invoke(atomic_memory_block);