lbug 0.16.1

An in-process property graph database management system built for query speed and scalability
Documentation 
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

#include "storage/index/index.h"

#include "common/exception/runtime.h"
#include "common/serializer/deserializer.h"
#include "common/serializer/serializer.h"
#include "main/client_context.h"
#include "storage/storage_manager.h"

namespace lbug {
namespace storage {

IndexStorageInfo::~IndexStorageInfo() = default;

Index::InsertState::~InsertState() = default;

Index::UpdateState::~UpdateState() = default;

Index::DeleteState::~DeleteState() = default;

Index::~Index() = default;

bool Index::isBuiltOnColumn(common::column_id_t columnID) const {
    auto it = std::find(indexInfo.columnIDs.begin(), indexInfo.columnIDs.end(), columnID);
    return it != indexInfo.columnIDs.end();
}

void IndexInfo::serialize(common::Serializer& ser) const {
    ser.write<std::string>(name);
    ser.write<std::string>(indexType);
    ser.write<common::table_id_t>(tableID);
    ser.serializeVector(columnIDs);
    ser.serializeVector(keyDataTypes);
    ser.write<bool>(isPrimary);
    ser.write<bool>(isBuiltin);
}

IndexInfo IndexInfo::deserialize(common::Deserializer& deSer) {
    std::string name;
    std::string indexType;
    common::table_id_t tableID = common::INVALID_TABLE_ID;
    std::vector<common::column_id_t> columnIDs;
    std::vector<common::PhysicalTypeID> keyDataTypes;
    bool isPrimary = false;
    bool isBuiltin = false;
    deSer.deserializeValue(name);
    deSer.deserializeValue(indexType);
    deSer.deserializeValue<common::table_id_t>(tableID);
    deSer.deserializeVector(columnIDs);
    deSer.deserializeVector(keyDataTypes);
    deSer.deserializeValue<bool>(isPrimary);
    deSer.deserializeValue<bool>(isBuiltin);
    return IndexInfo{std::move(name), std::move(indexType), tableID, std::move(columnIDs),
        std::move(keyDataTypes), isPrimary, isBuiltin};
}

std::shared_ptr<common::BufferWriter> IndexStorageInfo::serialize() const {
    return std::make_shared<common::BufferWriter>(0 /*maximumSize*/);
}

void Index::serialize(common::Serializer& ser) const {
    indexInfo.serialize(ser);
    auto bufferedWriter = storageInfo->serialize();
    ser.write<uint64_t>(bufferedWriter->getSize());
    ser.write(bufferedWriter->getData().data.get(), bufferedWriter->getSize());
}

IndexHolder::IndexHolder(std::unique_ptr<Index> loadedIndex)
    : indexInfo{loadedIndex->getIndexInfo()}, storageInfoBuffer{nullptr}, storageInfoBufferSize{0},
      loaded{true}, index{std::move(loadedIndex)} {}

IndexHolder::IndexHolder(IndexInfo indexInfo, std::unique_ptr<uint8_t[]> storageInfoBuffer,
    uint32_t storageInfoBufferSize)
    : indexInfo{std::move(indexInfo)}, storageInfoBuffer{std::move(storageInfoBuffer)},
      storageInfoBufferSize{storageInfoBufferSize}, loaded{false}, index{nullptr} {}

void IndexHolder::serialize(common::Serializer& ser) const {
    if (loaded) {
        DASSERT(index);
        index->serialize(ser);
    } else {
        indexInfo.serialize(ser);
        ser.write<uint64_t>(storageInfoBufferSize);
        if (storageInfoBufferSize > 0) {
            DASSERT(storageInfoBuffer);
            ser.write(storageInfoBuffer.get(), storageInfoBufferSize);
        }
    }
}

void IndexHolder::load(main::ClientContext* context, StorageManager* storageManager) {
    if (loaded) {
        return;
    }
    DASSERT(!index);
    DASSERT(storageInfoBuffer);
    auto indexTypeOptional = StorageManager::Get(*context)->getIndexType(indexInfo.indexType);
    if (!indexTypeOptional.has_value()) {
        throw common::RuntimeException("No index type with name: " + indexInfo.indexType);
    }
    index = indexTypeOptional.value().get().loadFunc(context, storageManager, indexInfo,
        std::span(storageInfoBuffer.get(), storageInfoBufferSize));
    loaded = true;
}

} // namespace storage
} // namespace lbug