Add namespace, clear

.gitignore

@@ -0,0 +1 @@
+*.o

.vscode/settings.json

@@ -1,6 +1,15 @@
 {
     "files.associations": {
         "string": "cpp",
-        "vector": "cpp"
+        "vector": "cpp",
+        "*.tcc": "cpp",
+        "deque": "cpp",
+        "unordered_map": "cpp",
+        "system_error": "cpp",
+        "iostream": "cpp",
+        "type_traits": "cpp",
+        "tuple": "cpp",
+        "array": "cpp",
+        "utility": "cpp"
     }
 }

lib/sqlite3.hpp

@@ -1,5 +1,5 @@
-#ifndef _SQL3_
-#define _SQL3_
+#ifndef _MARCELB_SQLITE3_
+#define _MARCELB_SQLITE3_
 
 #include <stdio.h>
 #include <sqlite3.h>
@@ -8,36 +8,38 @@
 #include <string>
 #include <vector>
 #include <map>
-// #include <algorithm>
 #include <iostream>
-
+#include <mutex>
 using namespace std;
 
+namespace marcelb::SQlite3 {
+
 static string responseDatabase;
 static int callback(void* data, int argc, char** argv, char** azColName);
 
-class sql3 {
-    public:
-
+class SQLite3 {
+    mutex io;
     sqlite3* db;
     string path;
     bool keepOpen;
-    string Answer;
-    map<string, vector<string>> parsed;
 
-    sql3(const string path, bool _keepOpen = false);
     bool open();
     bool close();
-    bool run(const string sql_command);
-    string answer();
-    void mapit();
+    map<string, vector<string>> parse(const string& result);
+
+public:
+
+    // string Answer;
+    // map<string, vector<string>> parsed;
+    
+    SQLite3(const string path, bool _keepOpen = false);
 
-    string ask(const string sql_command);
     map<string, vector<string>> query(const string sql_command);
 
-    ~sql3();
+    ~SQLite3();
 
 };
 
+}
 
 #endif

src/sqlite3.cpp

@@ -1,6 +1,8 @@
-#include "../lib/sql3.hpp"
+#include "../lib/sqlite3.hpp"
 
-sql3::sql3(const string _path, bool _keepOpen) {
+namespace marcelb::SQlite3 {
+
+SQLite3::SQLite3(const string _path, bool _keepOpen) {
    path = _path;
    keepOpen = _keepOpen;
 
@@ -9,83 +11,68 @@ sql3::sql3(const string _path, bool _keepOpen) {
          throw string("[ERROR] Unable to open database ");
       }
    }
-
 }
 
-bool sql3::open() {
+bool SQLite3::open() {
    uint operationStatus = sqlite3_open(path.c_str(), &db);
    return operationStatus != SQLITE_OK;
 }
 
-bool sql3::close() {
+bool SQLite3::close() {
    uint operationStatus = sqlite3_close(db);
    db = NULL;
    return operationStatus != SQLITE_OK;
 }
 
-bool sql3::run(const string sql_command) {
-
+map<string, vector<string>> SQLite3::query(const string sql_command) {
+   io.lock();
    if (!keepOpen) {
       if (open()) {
+         io.unlock();
          throw string("[ERROR] Unable to open database ");
       }
    }
 
    bool r = true;
    char *messaggeError;
-   uint exec_stuts;
-   exec_stuts = sqlite3_exec(db, sql_command.c_str(), callback, NULL, &messaggeError);
+   uint exec_status;
+   exec_status = sqlite3_exec(db, sql_command.c_str(), callback, NULL, &messaggeError);
 
-   if (exec_stuts != SQLITE_OK) {
-      // printf("[ERROR] Ne mogu čitati bazu podataka!");
+   string result;
+   if (exec_status != SQLITE_OK) {
       sqlite3_free(messaggeError);
       r = false;
    }
    else  {
-      Answer = responseDatabase;
+      result = responseDatabase;
       responseDatabase.clear();
    }
 
    if (!keepOpen) {
       if(close()) {
+         io.unlock();
          throw string("[ERROR] Unable to close database ");
       }
    }
 
-   return r;
-}
-
-string sql3::answer() {
-   string _Answer = Answer;
-   Answer.clear();
-   return _Answer;
-}
+   map<string, vector<string>> _parsed;
 
-string sql3::ask(const string sql_command) {
-   if (!run(sql_command)) {
+   if (!r) {
+      io.unlock();
       throw string("[ERROR] Unable to read database ");
-      //return {};
-   }
-   else {
-      return answer();
    }
-}
 
-map<string, vector<string>> sql3::query(const string sql_command) {
-   if (!run(sql_command)) {
-      throw string("[ERROR] Unable to read database ");
-      //return {};
-   }
    else {
-      mapit();
-      map<string, vector<string>> _parsed = parsed;
-      parsed.clear();
-      return _parsed;
+      _parsed = parse(result);
    }
+   io.unlock();
+   return _parsed;
 }
 
-void sql3::mapit() {
-   string a = Answer;
+
+map<string, vector<string>> SQLite3::parse(const string& result) {
+   string a = result;
+   map<string, vector<string>> parsed;
 
    while (a.find("\n") < a.length()) {
       uint lineend = a.find("\n");
@@ -96,27 +83,25 @@ void sql3::mapit() {
       string key = oneline.substr(0, sep);
       string value = oneline.substr(sep + 3, oneline.length());
       value = value.substr(0, value.length());
-      
       parsed[key].push_back(value);
    }
 
-
+   return parsed;
 }
 
-sql3::~sql3() {
+SQLite3::~SQLite3() {
    if(close()) {
-      throw string("[ERROR] Unable to close database ");
+      // throw string("[ERROR] Unable to close database ");
    }
 }
 
 
 /**
- * Callback funkcija za sqlite3 
+ * Callback funkcija za SQLite3 
 */
 
 static int callback(void* data, int argc, char** argv, char** azColName) {
    int i;
-   // fprintf(stderr, "%s: ", (const char*)data); // ovo je ispisivalo čudne stringove toplo se nadam da nam ne treba
    char res[1000];
    for (i = 0; i < argc; i++) {
       sprintf(res, "%s = %s", azColName[i], argv[i] ? argv[i] : "NULL");
@@ -124,3 +109,6 @@ static int callback(void* data, int argc, char** argv, char** azColName) {
    }
    return 0;
 }
+
+
+}

test/test.cpp

@@ -1,25 +1,32 @@
 #include <iostream>
+using namespace std;
 
-#include "../lib/sql3.hpp"
 
-using namespace std;
+#include "../lib/sqlite3.hpp"
+using namespace marcelb::SQlite3;
 
 int main() {
+    try {
 
-    sql3 mydb("../example/example.db", false);
+    SQLite3 mydb("../example/example.db", false);
 
     // cout << mydb.ask("Select * from Tab1");
     // cout << mydb.ask("INSERT INTO Tab1 VALUES(3,'Pakora', 'marijanab@bitelex.ml');");
 
     auto res = mydb.query("Select * from Tab1");
-    // auto res = mydb.query("INSERT INTO Tab1 VALUES(4,'Mare', 'marijanab@bitelex.co');");
+    // cout << endl <<  res["NAME"][1];
 
-    for (auto i : res) 
-        for (auto j: i.second)
-            cout << i.first << " : " << j << endl;
+    // cout << endl <<  res["MAIL"][1];
 
+    for (auto i : res) {
+        for (auto j: i.second) {
+            cout << i.first << " : " << j << endl; 
+        }
+    }
 
-    // cout << endl <<  res["NAME"][1];
+    } catch (const string err) {
+        cout << err << endl;
+    }
 
     return 0;
 }