sqlite_registry_store.hpp

Go to the documentation of this file.

#pragma once
 
#include <optional>
#include <string>
#include <vector>
 
#include "registry_store.hpp"
 
struct sqlite3;
 
namespace dcn::storage
{
    class SQLiteRegistryStore final : public IRegistryStore
    {
        public:
            explicit SQLiteRegistryStore(const std::string & db_path);
            ~SQLiteRegistryStore() override;
 
            SQLiteRegistryStore(const SQLiteRegistryStore &) = delete;
            SQLiteRegistryStore & operator=(const SQLiteRegistryStore &) = delete;
 
            SQLiteRegistryStore(SQLiteRegistryStore &&) = delete;
            SQLiteRegistryStore & operator=(SQLiteRegistryStore &&) = delete;
 
            bool hasConnector(const std::string & name) const override;
            std::optional<ConnectorRecordHandle> getConnectorRecordHandle(
                const std::string & name) const override;
            std::optional<evmc::bytes32> getConnectorFormatHash(const std::string & name) const override;
            bool addConnector(
                const chain::Address & address,
                const ConnectorRecord & record,
                const evmc::bytes32 & format_hash,
                const std::vector<ScalarLabel> & canonical_scalar_labels) override;
            bool addConnectorsBatch(
                const std::vector<ConnectorBatchItem> & items,
                bool all_or_nothing = true) override;
            std::size_t getFormatConnectorNamesCount(const evmc::bytes32 & format_hash) const override;
            NameCursorPage getFormatConnectorNamesCursor(
                const evmc::bytes32 & format_hash,
                const std::optional<NameCursor> & after,
                std::size_t limit) const override;
            std::optional<std::vector<ScalarLabel>> getScalarLabelsByFormatHash(
                const evmc::bytes32 & format_hash) const override;
 
            bool hasTransformation(const std::string & name) const override;
            std::optional<TransformationRecordHandle> getTransformationRecordHandle(
                const std::string & name) const override;
            bool addTransformation(
                const chain::Address & address,
                const TransformationRecord & record) override;
            bool addTransformationsBatch(
                const std::vector<TransformationBatchItem> & items,
                bool all_or_nothing = true) override;
 
            bool hasCondition(const std::string & name) const override;
            std::optional<ConditionRecordHandle> getConditionRecordHandle(
                const std::string & name) const override;
            bool addCondition(
                const chain::Address & address,
                const ConditionRecord & record) override;
            bool addConditionsBatch(
                const std::vector<ConditionBatchItem> & items,
                bool all_or_nothing = true) override;
 
            NameCursorPage getOwnedConnectorsCursor(
                const chain::Address & owner,
                const std::optional<NameCursor> & after,
                std::size_t limit) const override;
            NameCursorPage getOwnedTransformationsCursor(
                const chain::Address & owner,
                const std::optional<NameCursor> & after,
                std::size_t limit) const override;
            NameCursorPage getOwnedConditionsCursor(
                const chain::Address & owner,
                const std::optional<NameCursor> & after,
                std::size_t limit) const override;
 
            bool checkpointWal(WalCheckpointMode mode) const override;
 
        private:
            sqlite3 * _db = nullptr;
 
            bool _initializeSchema() const;
            bool _exec(const char * sql) const;
            bool _beginTransaction() const;
            bool _commitTransaction() const;
            void _rollbackTransaction() const;
 
            NameCursorPage _getOwnedCursorFromTable(
                const char * table_name,
                const chain::Address & owner,
                const std::optional<NameCursor> & after,
                std::size_t limit) const;
    };
}