redis_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 redis_backend
    : public core::backend_base<redis_backend, database_types::redis>
{
public:
    static constexpr const char* backend_name() { return "redis_backend"; }
 
    redis_backend();
 
    ~redis_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<redis_backend, database_types::redis>;
 
    kcenon::common::VoidResult do_initialize(const core::connection_config& config);
 
    kcenon::common::VoidResult do_shutdown();
 
private:
    bool parse_redis_query(const std::string& query_string,
                           std::string& key,
                           std::string& value) const;
 
    void* context_{nullptr};                     
    std::string host_;                           
    int port_{6379};                             
    std::atomic<bool> in_transaction_{false};    
    mutable std::string last_error_;             
    core::connection_config connection_config_;  
    mutable std::mutex redis_mutex_;             
};
 
} // namespace backends
} // namespace database