database.h

Go to the documentation of this file.

// SPDX-License-Identifier: Apache-2.0
#pragma once
 
#include <cstddef>
#include <filesystem>
#include <functional>
#include <mutex>
#include <string_view>
 
struct sqlite3;
struct sqlite3_stmt;
 
namespace entropic {
 
class SqliteDatabase {
public:
    explicit SqliteDatabase(const std::filesystem::path& db_path);
 
    ~SqliteDatabase();
 
    SqliteDatabase(const SqliteDatabase&) = delete;
    SqliteDatabase& operator=(const SqliteDatabase&) = delete;
 
    bool initialize();
 
    void close();
 
    bool is_open() const;
 
    bool execute(std::string_view sql,
                 std::function<void(sqlite3_stmt*)> binder = nullptr);
 
    bool execute_raw(std::string_view sql);
 
    bool fetch_one(std::string_view sql,
                   std::function<void(sqlite3_stmt*)> binder,
                   std::function<void(sqlite3_stmt*)> extractor);
 
    size_t fetch_all(std::string_view sql,
                     std::function<void(sqlite3_stmt*)> binder,
                     std::function<void(sqlite3_stmt*)> row_handler);
 
    sqlite3* raw_handle() const;
 
private:
    bool run_migrations();
 
    sqlite3_stmt* prepare(std::string_view sql);
 
    std::filesystem::path db_path_; 
    sqlite3* db_ = nullptr;        
    mutable std::mutex mutex_;      
};
 
} // namespace entropic