Dictionary.h

Go to the documentation of this file.

/******************************************************************************/
/******************************************************************************/

#if !defined(PROJECT_CPP_DICTIONARY_H)
#define PROJECT_CPP_DICTIONARY_H

#include "../dictionary/dictionary.h"
#include "../dictionary/dictionary_types.h"
#include "../key_value/kv_system.h"
#include "../dictionary/ion_master_table.h"

#include "Cursor.h"

template<typename K, typename V>
class Dictionary {
public:

ion_dictionary_handler_t    handler;
ion_dictionary_t            dict;
ion_key_type_t              key_type;
ion_key_size_t              key_size;
ion_value_size_t            value_size;
ion_dictionary_size_t       dict_size;
ion_status_t                last_status;

~Dictionary(
) {
    this->deleteDictionary();
}

ion_err_t
initializeDictionary(
    ion_dictionary_id_t     dict_id,
    ion_key_type_t          k_type,
    ion_key_size_t          k_size,
    ion_value_size_t        v_size,
    ion_dictionary_size_t   dictionary_size
) {
    key_type    = k_type;
    key_size    = k_size;
    value_size  = v_size;
    dict_size   = dictionary_size;

    ion_err_t err = dictionary_create(&handler, &dict, dict_id, k_type, k_size, v_size, dictionary_size);

    last_status.error = err;

    return err;
}

ion_status_t
insert(
    K   key,
    V   value
) {
    ion_key_t   ion_key     = &key;
    ion_value_t ion_value   = &value;

    ion_status_t status     = dictionary_insert(&dict, ion_key, ion_value);

    this->last_status = status;

    return status;
}

V
get(
    K key
) {
    ion_key_t   ion_key = &key;
    ion_byte_t  ion_value[dict.instance->record.value_size];

    this->last_status = dictionary_get(&dict, ion_key, ion_value);

    return *((V *) ion_value);
}

ion_status_t
deleteRecord(
    K key
) {
    ion_key_t       ion_key = &key;
    ion_status_t    status  = dictionary_delete(&dict, ion_key);

    this->last_status = status;

    return status;
}

ion_status_t
update(
    K   key,
    V   value
) {
    ion_key_t       ion_key     = &key;
    ion_value_t     ion_value   = &value;
    ion_status_t    status      = dictionary_update(&dict, ion_key, ion_value);

    this->last_status = status;

    return status;
}

ion_err_t
deleteDictionary(
) {
    ion_err_t err = dictionary_delete_dictionary(&dict);

    last_status.error = err;

    return err;
}

ion_err_t
destroyDictionary(
    ion_dictionary_id_t id
) {
    ion_err_t error = dictionary_destroy_dictionary(&handler, id);

    last_status.error = error;

    return error;
}

ion_err_t
open(
    ion_dictionary_config_info_t config_info
) {
    ion_err_t err = dictionary_open(&handler, &dict, &config_info);

    key_type            = config_info.type;
    key_size            = config_info.key_size;
    value_size          = config_info.value_size;
    dict_size           = config_info.dictionary_size;
    last_status.error   = err;

    return err;
}

ion_err_t
close(
) {
    ion_err_t err = dictionary_close(&dict);

    last_status.error = err;

    return err;
}

Cursor<K, V> *
range(
    K   min_key,
    K   max_key
) {
    ion_predicate_t predicate;
    ion_key_t       ion_min_key = &min_key;
    ion_key_t       ion_max_key = &max_key;

    dictionary_build_predicate(&predicate, predicate_range, ion_min_key, ion_max_key);
    return new Cursor<K, V>(&dict, &predicate);
}

Cursor<K, V> *
equality(
    K key
) {
    ion_predicate_t predicate;
    ion_key_t       ion_key = &key;

    dictionary_build_predicate(&predicate, predicate_equality, ion_key);
    return new Cursor<K, V>(&dict, &predicate);
}

Cursor<K, V> *
allRecords(
) {
    ion_predicate_t predicate;

    dictionary_build_predicate(&predicate, predicate_all_records);
    return new Cursor<K, V>(&dict, &predicate);
}
};

#endif /* PROJECT_CPP_DICTIONARY_H */