1 files changed, 61 insertions, 0 deletions
diff --git a/src/resultset.cpp b/src/resultset.cpp
new file mode 100644
index 0000000..9528a2a
--- /dev/null
+++ b/src/resultset.cpp
@@ -0,0 +1,61 @@
+//
+// Copyright (c) 2022 Klemens Morgenstern (klemens.morgenstern@gmx.net)
+//
+// Distributed under the Boost Software License, Version 1.0. (See accompanying
+// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+
+#include <boost/sqlite/resultset.hpp>
+
+BOOST_SQLITE_BEGIN_NAMESPACE
+
+
+bool resultset::read_next(
+              system::error_code & ec,
+              error_info & ei) // could also return row* instead!
+{
+    if (done_)
+        return false;
+    auto cc = sqlite3_step(impl_.get());
+    if (cc == SQLITE_DONE)
+    {
+        done_ = true;
+        return false;
+    }
+    else if (cc != SQLITE_ROW)
+    {
+        BOOST_SQLITE_ASSIGN_EC(ec, cc);
+        ei.set_message(sqlite3_errmsg(sqlite3_db_handle(impl_.get())));
+    }
+    return !done_;
+}
+
+bool resultset::read_next()
+{
+    system::error_code ec;
+    error_info ei;
+    auto tmp = read_next(ec, ei);
+    if (ec)
+        throw_exception(system::system_error(ec, ei.message()));
+    return tmp;
+}
+
+resultset::iterator resultset::iterator::operator++()
+{
+  if (sentinel_)
+    return *this;
+
+  auto cc = sqlite3_step(row_.stm_);
+  if (cc == SQLITE_DONE)
+    sentinel_ = true;
+  else if (cc != SQLITE_ROW)
+  {
+    system::error_code ec;
+    BOOST_SQLITE_ASSIGN_EC(ec, cc);
+    throw_exception(system::system_error(ec, sqlite3_errmsg(sqlite3_db_handle(row_.stm_))));
+  }
+  return *this;
+}
+
+BOOST_SQLITE_END_NAMESPACE
+