d/j2: Some work on the SQL editors (#2771)

common/sqlite/sqlite.cpp

@@ -0,0 +1,55 @@
+#include "sqlite.h"
+
+#include "common/log/log.h"
+
+bool sqlite::SQLiteDatabase::open_db(const std::string& path) {
+  if (is_open()) {
+    return true;
+  }
+  sqlite3* db;
+
+  // NOTE - this opens with SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE
+  const auto status_code = sqlite3_open(path.data(), &db);
+  if (status_code) {
+    lg::error("Unable to open SQLite database: {}", sqlite3_errmsg(db));
+    sqlite3_close(db);
+    return false;
+  }
+
+  // Otherwise, track it
+  m_db = std::shared_ptr<sqlite3>(db, SQLite3DatabaseDeleter());
+  return true;
+}
+
+// TODO - allow passing in a `std::function<int(void*, int, char**, char**)>` to format the results
+// for now we do something that works in general (converts to vectors)
+
+sqlite::GenericResponse sqlite::SQLiteDatabase::run_query(const std::string& sql) {
+  GenericResponse resp;
+  if (!is_open()) {
+    return resp;
+  }
+
+  char* errMsg = 0;
+
+  const auto rc = sqlite3_exec(
+      m_db.value().get(), sql.data(),
+      [](void* data, int argc, char** argv, char** azColName) {
+        GenericResponse* resp = static_cast<GenericResponse*>(data);
+        std::vector<std::string> row = {};
+        for (int i = 0; i < argc; i++) {
+          row.push_back(argv[i] ? argv[i] : "NULL");
+        }
+        resp->rows.push_back(row);
+        return 0;
+      },
+      &resp, &errMsg);
+
+  if (rc != SQLITE_OK) {
+    fprintf(stderr, "SQL error: %s\n", errMsg);
+    sqlite3_free(errMsg);
+    // TODO - store error on response
+    return resp;
+  }
+  return resp;
+}