Connection.hpp

Go to the documentation of this file.

#pragma once
#ifndef _MDBX_CONTAINERS_CONNECTION_HPP_INCLUDED
#define _MDBX_CONTAINERS_CONNECTION_HPP_INCLUDED

 
namespace mdbxc {

    class Connection : private TransactionTracker {
        friend class BaseTable;
    public:

        Connection() = default;

        explicit Connection(const Config& config);

        ~Connection();
        
        static std::shared_ptr<Connection> create(const Config& config);

        void configure(const Config& config);

        void connect();
        
        void connect(const Config& config);

        void disconnect();

        bool is_connected() const;

        Transaction transaction(TransactionMode mode = TransactionMode::WRITABLE);
        
        void begin(TransactionMode mode = TransactionMode::WRITABLE);
        
        void commit();

        void rollback();
        
        std::shared_ptr<Transaction> current_txn() const;

        MDBX_env* env_handle() noexcept;
 
    private:
        friend class Transaction;
 
        MDBX_env *m_env = nullptr;          
        mutable std::mutex m_mdbx_mutex;    
        std::unordered_map<std::thread::id, std::shared_ptr<Transaction>> m_transactions;
#       if __cplusplus >= 201703L
        using config_t = std::optional<Config>;
#       else
        using config_t = std::unique_ptr<Config>;
#       endif
        config_t m_config;                  

        void initialize();
        
        void cleanup(bool use_throw = true);

        void db_init();
 
    }; // Connection
 
} // namespace mdbxc
 
#ifdef MDBX_CONTAINERS_HEADER_ONLY
#include "Connection.ipp"
#endif
 
#endif // _MDBX_CONTAINERS_CONNECTION_HPP_INCLUDED