sql_cursor.hxx

Go to the documentation of this file.

 
#ifndef PQXX_INTERNAL_SQL_CURSOR_HXX
#define PQXX_INTERNAL_SQL_CURSOR_HXX
 
namespace pqxx::internal
{
 
class PQXX_LIBEXPORT sql_cursor final : public cursor_base
{
public:
  sql_cursor(
    transaction_base &t, std::string_view query, std::string_view cname,
    cursor_base::access_policy ap, cursor_base::update_policy up,
    cursor_base::ownership_policy op, bool hold, sl = sl::current());
 
  sql_cursor(
    transaction_base &t, std::string_view cname,
    cursor_base::ownership_policy op, sl = sl::current());
 
  sql_cursor(sql_cursor const &) = delete;
  sql_cursor(sql_cursor &&) = delete;
  ~sql_cursor() noexcept;
 
  sql_cursor &operator=(sql_cursor const &) = delete;
  sql_cursor &operator=(sql_cursor &&) = delete;
 
  result fetch(difference_type rows, difference_type &displacement, sl);
  PQXX_INLINE_COV result fetch(difference_type rows, sl loc)
  {
    difference_type d = 0;
    return fetch(rows, d, loc);
  }
  difference_type
  move(difference_type rows, difference_type &displacement, sl);
  PQXX_INLINE_COV difference_type move(difference_type rows, sl loc)
  {
    difference_type d = 0;
    return move(rows, d, loc);
  }
 
 
  PQXX_INLINE_COV [[nodiscard]] difference_type pos() const noexcept
  {
    return m_pos;
  }
 
 
  PQXX_INLINE_COV [[nodiscard]] difference_type endpos() const noexcept
  {
    return m_endpos;
  }
 
  PQXX_INLINE_COV [[nodiscard]] result const &empty_result() const noexcept
  {
    return m_empty_result;
  }
 
  void close(sl loc);
 
  PQXX_PURE [[nodiscard]] constexpr sl created_loc() const noexcept
  {
    return m_created_loc;
  }
 
private:
  difference_type adjust(difference_type hoped, difference_type actual);
  static std::string stridestring(difference_type);
  void init_empty_result(transaction_base &, sl);
 
  connection &m_home;
 
  result m_empty_result;
 
  result m_cached_current_row;
 
  cursor_base::ownership_policy m_ownership;
 
  int m_at_end;
 
  difference_type m_pos;
 
  difference_type m_endpos = -1;
 
  sl m_created_loc;
};
 
 
PQXX_LIBEXPORT result_size_type obtain_stateless_cursor_size(sql_cursor &, sl);
PQXX_LIBEXPORT result stateless_cursor_retrieve(
  sql_cursor &, result::difference_type size,
  result::difference_type begin_pos, result::difference_type end_pos, sl);
} // namespace pqxx::internal
#endif