1 files changed, 21 insertions, 102 deletions

@@ -1,48 +1,19 @@
 #include "database.h"
-#include <sqlite3.h>
-#include <stdexcept>
 #include <sstream>
 #include "query.h"
 #include "version.h"
 
 namespace verbly {
 
-  database::database(std::string path)
+  database::database(
+    std::string path) :
+      ppdb_(std::move(path), hatkirby::dbmode::read)
   {
-    if (sqlite3_open_v2(path.c_str(), &ppdb_, SQLITE_OPEN_READONLY, NULL) != SQLITE_OK)
-    {
-      // We still have to free the resources allocated. In the event that
-      // allocation failed, ppdb will be null and sqlite3_close_v2 will just
-      // ignore it.
-      std::string errmsg(sqlite3_errmsg(ppdb_));
-      sqlite3_close_v2(ppdb_);
-
-      throw database_error("Could not open verbly datafile", errmsg);
-    }
-
-    std::string queryString = "SELECT major, minor FROM version";
-
-    sqlite3_stmt* ppstmt;
-    if (sqlite3_prepare_v2(ppdb_, queryString.c_str(), queryString.length(), &ppstmt, NULL) != SQLITE_OK)
-    {
-      std::string errorMsg = sqlite3_errmsg(ppdb_);
-      sqlite3_finalize(ppstmt);
-
-      throw database_error("Error reading database version", errorMsg);
-    }
-
-    if (sqlite3_step(ppstmt) != SQLITE_ROW)
-    {
-      std::string errorMsg = sqlite3_errmsg(ppdb_);
-      sqlite3_finalize(ppstmt);
-
-      throw database_error("Error reading database version", errorMsg);
-    }
+    hatkirby::row version =
+      ppdb_.queryFirst("SELECT major, minor FROM version");
 
-    major_ = sqlite3_column_int(ppstmt, 0);
-    minor_ = sqlite3_column_int(ppstmt, 1);
-
-    sqlite3_finalize(ppstmt);
+    major_ = mpark::get<int>(version[0]);
+    minor_ = mpark::get<int>(version[1]);
 
     if (major_ != DATABASE_MAJOR_VERSION)
     {
@@ -50,28 +21,6 @@ namespace verbly {
     }
   }
 
-  database::database(database&& other) : database()
-  {
-    swap(*this, other);
-  }
-
-  database& database::operator=(database&& other)
-  {
-    swap(*this, other);
-
-    return *this;
-  }
-
-  void swap(database& first, database& second)
-  {
-    std::swap(first.ppdb_, second.ppdb_);
-  }
-
-  database::~database()
-  {
-    sqlite3_close_v2(ppdb_);
-  }
-
   query<notion> database::notions(filter where, order sortOrder, int limit) const
   {
     return query<notion>(*this, ppdb_, std::move(where), std::move(sortOrder), limit);
@@ -104,65 +53,35 @@ namespace verbly {
 
   std::set<std::string> database::selrestrs(int partId) const
   {
-    std::string queryString = "SELECT selrestr FROM selrestrs WHERE part_id = ?";
-
-    sqlite3_stmt* ppstmt;
-    if (sqlite3_prepare_v2(ppdb_, queryString.c_str(), queryString.length(), &ppstmt, NULL) != SQLITE_OK)
-    {
-      std::string errorMsg = sqlite3_errmsg(ppdb_);
-      sqlite3_finalize(ppstmt);
-
-      throw database_error("Error preparing query", errorMsg);
-    }
-
-    if (sqlite3_bind_int(ppstmt, 1, partId) != SQLITE_OK)
-    {
-      std::string errorMsg = sqlite3_errmsg(ppdb_);
-      sqlite3_finalize(ppstmt);
-
-      throw database_error("Error binding value to query", errorMsg);
-    }
+    std::vector<hatkirby::row> rows =
+      ppdb_.queryAll(
+        "SELECT selrestr FROM selrestrs WHERE part_id = ?",
+        { partId });
 
     std::set<std::string> result;
-    while (sqlite3_step(ppstmt) == SQLITE_ROW)
+
+    for (hatkirby::row& r : rows)
     {
-      result.insert(reinterpret_cast<const char*>(sqlite3_column_blob(ppstmt, 0)));
+      result.emplace(std::move(mpark::get<std::string>(r[0])));
     }
 
-    sqlite3_finalize(ppstmt);
-
     return result;
   }
 
   std::set<std::string> database::synrestrs(int partId) const
   {
-    std::string queryString = "SELECT synrestr FROM synrestrs WHERE part_id = ?";
-
-    sqlite3_stmt* ppstmt;
-    if (sqlite3_prepare_v2(ppdb_, queryString.c_str(), queryString.length(), &ppstmt, NULL) != SQLITE_OK)
-    {
-      std::string errorMsg = sqlite3_errmsg(ppdb_);
-      sqlite3_finalize(ppstmt);
-
-      throw database_error("Error preparing query", errorMsg);
-    }
-
-    if (sqlite3_bind_int(ppstmt, 1, partId) != SQLITE_OK)
-    {
-      std::string errorMsg = sqlite3_errmsg(ppdb_);
-      sqlite3_finalize(ppstmt);
-
-      throw database_error("Error binding value to query", errorMsg);
-    }
+    std::vector<hatkirby::row> rows =
+      ppdb_.queryAll(
+        "SELECT synrestr FROM synrestrs WHERE part_id = ?",
+        { partId });
 
     std::set<std::string> result;
-    while (sqlite3_step(ppstmt) == SQLITE_ROW)
+
+    for (hatkirby::row& r : rows)
     {
-      result.insert(reinterpret_cast<const char*>(sqlite3_column_blob(ppstmt, 0)));
+      result.emplace(std::move(mpark::get<std::string>(r[0])));
     }
 
-    sqlite3_finalize(ppstmt);
-
     return result;
   }