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

#include "c_api/helpers.h"
#include "c_api/lbug.h"
#include "common/exception/exception.h"
#include "main/lbug.h"
using namespace lbug::main;
using namespace lbug::common;

lbug_state lbug_database_init(const char* database_path, lbug_system_config config,
    lbug_database* out_database) {
    try {
        clearLastCAPIErrorMessage();
        std::string database_path_str = database_path;
        auto systemConfig = SystemConfig(config.buffer_pool_size, config.max_num_threads,
            config.enable_compression, config.read_only, config.max_db_size, config.auto_checkpoint,
            config.checkpoint_threshold, true, config.throw_on_wal_replay_failure,
            config.enable_checksums, config.enable_multi_writes);

#if defined(__APPLE__)
        systemConfig.threadQos = config.thread_qos;
#endif
        out_database->_database = new Database(database_path_str, systemConfig);
    } catch (Exception& e) {
        out_database->_database = nullptr;
        setLastCAPIErrorMessage(e.what());
        return LbugError;
    }
    return LbugSuccess;
}

void lbug_database_destroy(lbug_database* database) {
    if (database == nullptr) {
        return;
    }
    if (database->_database != nullptr) {
        delete static_cast<Database*>(database->_database);
    }
}

lbug_system_config lbug_default_system_config() {
    SystemConfig config = SystemConfig();
    auto cSystemConfig = lbug_system_config();
    cSystemConfig.buffer_pool_size = config.bufferPoolSize;
    cSystemConfig.max_num_threads = config.maxNumThreads;
    cSystemConfig.enable_compression = config.enableCompression;
    cSystemConfig.read_only = config.readOnly;
    cSystemConfig.max_db_size = config.maxDBSize;
    cSystemConfig.auto_checkpoint = config.autoCheckpoint;
    cSystemConfig.checkpoint_threshold = config.checkpointThreshold;
    cSystemConfig.throw_on_wal_replay_failure = config.throwOnWalReplayFailure;
    cSystemConfig.enable_checksums = config.enableChecksums;
    cSystemConfig.enable_multi_writes = config.enableMultiWrites;
#if defined(__APPLE__)
    cSystemConfig.thread_qos = config.threadQos;
#endif
    return cSystemConfig;
}