RdbColumnContainer.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/exceptions.h"
#include "catapult/functions.h"
#include "catapult/types.h"
 
namespace catapult {
    namespace cache {
        class RdbDataIterator;
        class RocksDatabase;
    }
}
 
namespace catapult { namespace cache {
 
    class RdbColumnContainer {
    public:
        RdbColumnContainer(RocksDatabase& database, size_t columnId);
 
    public:
        size_t size() const;
 
        void setSize(size_t newSize);
 
        template<typename TValue>
        bool prop(const std::string& propertyName, TValue& value) const {
            bool result = false;
            load(propertyName, [&result, &value](const char* buffer) {
                if (!buffer)
                    return;
 
                result = true;
                value = reinterpret_cast<const TValue&>(*buffer);
            });
 
            return result;
        }
 
        template<typename TValue>
        void setProp(const std::string& propertyName, const TValue& value) {
            std::string strValue(sizeof(TValue), 0);
            reinterpret_cast<TValue&>(strValue[0]) = value;
            save(propertyName, strValue);
        }
 
        RocksDatabase& database() {
            return m_database;
        }
 
    protected:
        void find(const RawBuffer& key, RdbDataIterator& iterator) const;
 
        void insert(const RawBuffer& key, const std::string& value);
 
        void remove(const RawBuffer& key);
 
        size_t prune(uint64_t pruningBoundary);
 
    private:
        void load(const std::string& propertyName, const consumer<const char*>& sink) const;
 
        void save(const std::string& propertyName, const std::string& strValue);
 
    private:
        RocksDatabase& m_database;
        size_t m_columnId;
        size_t m_size;
    };
}}