Cursor.h

Go to the documentation of this file.

#ifndef LINTEL_SQLITE_CURSOR_H
#define LINTEL_SQLITE_CURSOR_H
 
#include <sqlite3.h>
 
#include <cstddef>
#include <string>
#include <vector>
 
#include "lintel/core/persistence/Arguments.h"
 
namespace lintel {
namespace sqlite {
  class Connection;
 
  class Cursor
  {
  private:
    sqlite3 *m_db;
    sqlite3_stmt *m_stmt;
    bool m_exhausted;
    std::size_t m_fetchSize;
 
  public:
    static constexpr std::size_t kDefaultFetchSize = 64;
 
    explicit Cursor(const Connection &connection,
      const std::string &query,
      const std::vector<std::string> &params,
      std::size_t fetchSize = kDefaultFetchSize);
 
    Cursor(Cursor &cursor) = delete;
 
    ~Cursor();
 
    [[nodiscard]] std::vector<db::Arguments> fetchNext(std::size_t maxRows);
  };
}// namespace sqlite
 
}// namespace lintel
#endif// LINTEL_SQLITE_CURSOR_H