mongodb_backend.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "../core/backend_base.h"
#include "../core/backend_registry.h"
 
#include <memory>
#include <string>
#include <atomic>
#include <mutex>
 
namespace database
{
namespace backends
{
 
class mongodb_backend
    : public core::backend_base<mongodb_backend, database_types::mongodb>
{
public:
    static constexpr const char* backend_name() { return "mongodb_backend"; }
 
    mongodb_backend();
 
    ~mongodb_backend() override = default;
 
    // database_backend interface implementation
 
    kcenon::common::Result<core::database_result> select_query(const std::string& query_string) override;
 
    kcenon::common::VoidResult execute_query(const std::string& query_string) override;
 
    kcenon::common::VoidResult begin_transaction() override;
 
    kcenon::common::VoidResult commit_transaction() override;
 
    kcenon::common::VoidResult rollback_transaction() override;
 
    bool in_transaction() const override;
 
    std::string last_error() const override;
 
    std::map<std::string, std::string> connection_info() const override;
 
protected:
    friend class core::backend_base<mongodb_backend, database_types::mongodb>;
 
    kcenon::common::VoidResult do_initialize(const core::connection_config& config);
 
    kcenon::common::VoidResult do_shutdown();
 
private:
    std::string build_connection_uri(const core::connection_config& config) const;
 
    bool parse_query_string(const std::string& query_string,
                            std::string& collection,
                            std::string& filter,
                            std::string& update) const;
 
    void* client_{nullptr};                      
    void* database_{nullptr};                    
    std::string db_name_;                        
    std::atomic<bool> in_transaction_{false};    
    mutable std::string last_error_;             
    core::connection_config connection_config_;  
    mutable std::mutex mongo_mutex_;             
};
 
} // namespace backends
} // namespace database