sqlite_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 sqlite_backend
    : public core::backend_base<sqlite_backend, database_types::sqlite>
{
public:
    static constexpr const char* backend_name() { return "sqlite_backend"; }
 
    sqlite_backend();
 
    ~sqlite_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;
 
    [[nodiscard]] kcenon::common::Result<core::database_result> select_prepared(
        const std::string& query,
        const std::vector<core::database_value>& params) override;
 
    [[nodiscard]] kcenon::common::VoidResult execute_prepared(
        const std::string& query,
        const std::vector<core::database_value>& params) 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<sqlite_backend, database_types::sqlite>;
 
    kcenon::common::VoidResult do_initialize(const core::connection_config& config);
 
    kcenon::common::VoidResult do_shutdown();
 
private:
    unsigned int execute_modification_query(const std::string& query_string);
 
    core::database_value convert_sqlite_value(void* stmt, int column_index);
 
    void* connection_{nullptr};                      
    std::atomic<bool> in_transaction_{false};        
    mutable std::string last_error_;                 
    core::connection_config connection_config_;      
    mutable std::recursive_mutex sqlite_mutex_;      
};
 
} // namespace backends
} // namespace database