Add namespace, clear

dev
marcelb 1 week ago
parent 9fa9178e32
commit 5fde5c52aa
  1. 1
      .gitignore
  2. 11
      .vscode/settings.json
  3. 29
      lib/sqlite3.hpp
  4. 45
      src/sqlite3.cpp
  5. 7
      test/test.cpp
  6. BIN
      test/test.o

1
.gitignore vendored

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

@ -1,6 +1,15 @@
{ {
"files.associations": { "files.associations": {
"string": "cpp", "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"
} }
} }

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

@ -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; path = _path;
keepOpen = _keepOpen; keepOpen = _keepOpen;
@ -9,21 +11,20 @@ sql3::sql3(const string _path, bool _keepOpen) {
throw string("[ERROR] Unable to open database "); throw string("[ERROR] Unable to open database ");
} }
} }
} }
bool sql3::open() { bool SQLite3::open() {
uint operationStatus = sqlite3_open(path.c_str(), &db); uint operationStatus = sqlite3_open(path.c_str(), &db);
return operationStatus != SQLITE_OK; return operationStatus != SQLITE_OK;
} }
bool sql3::close() { bool SQLite3::close() {
uint operationStatus = sqlite3_close(db); uint operationStatus = sqlite3_close(db);
db = NULL; db = NULL;
return operationStatus != SQLITE_OK; return operationStatus != SQLITE_OK;
} }
map<string, vector<string>> sql3::query(const string sql_command) { map<string, vector<string>> SQLite3::query(const string sql_command) {
io.lock(); io.lock();
if (!keepOpen) { if (!keepOpen) {
if (open()) { if (open()) {
@ -34,15 +35,16 @@ map<string, vector<string>> sql3::query(const string sql_command) {
bool r = true; bool r = true;
char *messaggeError; char *messaggeError;
uint exec_stuts; uint exec_status;
exec_stuts = sqlite3_exec(db, sql_command.c_str(), callback, NULL, &messaggeError); exec_status = sqlite3_exec(db, sql_command.c_str(), callback, NULL, &messaggeError);
if (exec_stuts != SQLITE_OK) { string result;
if (exec_status != SQLITE_OK) {
sqlite3_free(messaggeError); sqlite3_free(messaggeError);
r = false; r = false;
} }
else { else {
Answer = responseDatabase; result = responseDatabase;
responseDatabase.clear(); responseDatabase.clear();
} }
@ -61,16 +63,16 @@ map<string, vector<string>> sql3::query(const string sql_command) {
} }
else { else {
mapit(); _parsed = parse(result);
_parsed = parsed;
parsed.clear();
} }
io.unlock(); io.unlock();
return _parsed; 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()) { while (a.find("\n") < a.length()) {
uint lineend = a.find("\n"); uint lineend = a.find("\n");
@ -81,27 +83,25 @@ void sql3::mapit() {
string key = oneline.substr(0, sep); string key = oneline.substr(0, sep);
string value = oneline.substr(sep + 3, oneline.length()); string value = oneline.substr(sep + 3, oneline.length());
value = value.substr(0, value.length()); value = value.substr(0, value.length());
parsed[key].push_back(value); parsed[key].push_back(value);
} }
return parsed;
} }
sql3::~sql3() { SQLite3::~SQLite3() {
if(close()) { 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) { static int callback(void* data, int argc, char** argv, char** azColName) {
int i; int i;
// fprintf(stderr, "%s: ", (const char*)data); // ovo je ispisivalo čudne stringove toplo se nadam da nam ne treba
char res[1000]; char res[1000];
for (i = 0; i < argc; i++) { for (i = 0; i < argc; i++) {
sprintf(res, "%s = %s", azColName[i], argv[i] ? argv[i] : "NULL"); sprintf(res, "%s = %s", azColName[i], argv[i] ? argv[i] : "NULL");
@ -109,3 +109,6 @@ static int callback(void* data, int argc, char** argv, char** azColName) {
} }
return 0; return 0;
} }
}

@ -1,13 +1,14 @@
#include <iostream> #include <iostream>
using namespace std;
#include "../lib/sql3.hpp"
using namespace std; #include "../lib/sqlite3.hpp"
using namespace marcelb::SQlite3;
int main() { int main() {
try { try {
sql3 mydb("../example/example.db", false); SQLite3 mydb("../example/example.db", false);
// cout << mydb.ask("Select * from Tab1"); // cout << mydb.ask("Select * from Tab1");
// cout << mydb.ask("INSERT INTO Tab1 VALUES(3,'Pakora', 'marijanab@bitelex.ml');"); // cout << mydb.ask("INSERT INTO Tab1 VALUES(3,'Pakora', 'marijanab@bitelex.ml');");

Binary file not shown.
Loading…
Cancel
Save