Compare commits

..

No commits in common. 'dev' and 'fix-callback' have entirely different histories.

  1. 1
      .gitignore
  2. 11
      .vscode/settings.json
  3. 33
      lib/sql3.hpp
  4. 45
      src/sql3.cpp
  5. 7
      test/test.cpp
  6. BIN
      test/test.o

1
.gitignore vendored

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

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

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

@ -1,8 +1,6 @@
#include "../lib/sqlite3.hpp"
#include "../lib/sql3.hpp"
namespace marcelb::SQlite3 {
SQLite3::SQLite3(const string _path, bool _keepOpen) {
sql3::sql3(const string _path, bool _keepOpen) {
path = _path;
keepOpen = _keepOpen;
@ -11,20 +9,21 @@ SQLite3::SQLite3(const string _path, bool _keepOpen) {
throw string("[ERROR] Unable to open database ");
}
}
}
bool SQLite3::open() {
bool sql3::open() {
uint operationStatus = sqlite3_open(path.c_str(), &db);
return operationStatus != SQLITE_OK;
}
bool SQLite3::close() {
bool sql3::close() {
uint operationStatus = sqlite3_close(db);
db = NULL;
return operationStatus != SQLITE_OK;
}
map<string, vector<string>> SQLite3::query(const string sql_command) {
map<string, vector<string>> sql3::query(const string sql_command) {
io.lock();
if (!keepOpen) {
if (open()) {
@ -35,16 +34,15 @@ map<string, vector<string>> SQLite3::query(const string sql_command) {
bool r = true;
char *messaggeError;
uint exec_status;
exec_status = sqlite3_exec(db, sql_command.c_str(), callback, NULL, &messaggeError);
uint exec_stuts;
exec_stuts = sqlite3_exec(db, sql_command.c_str(), callback, NULL, &messaggeError);
string result;
if (exec_status != SQLITE_OK) {
if (exec_stuts != SQLITE_OK) {
sqlite3_free(messaggeError);
r = false;
}
else {
result = responseDatabase;
Answer = responseDatabase;
responseDatabase.clear();
}
@ -63,16 +61,16 @@ map<string, vector<string>> SQLite3::query(const string sql_command) {
}
else {
_parsed = parse(result);
mapit();
_parsed = parsed;
parsed.clear();
}
io.unlock();
return _parsed;
}
map<string, vector<string>> SQLite3::parse(const string& result) {
string a = result;
map<string, vector<string>> parsed;
void sql3::mapit() {
string a = Answer;
while (a.find("\n") < a.length()) {
uint lineend = a.find("\n");
@ -83,25 +81,27 @@ map<string, vector<string>> SQLite3::parse(const string& result) {
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;
}
SQLite3::~SQLite3() {
sql3::~sql3() {
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");
@ -109,6 +109,3 @@ static int callback(void* data, int argc, char** argv, char** azColName) {
}
return 0;
}
}

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

Binary file not shown.
Loading…
Cancel
Save