return 0;
}
-sqlite3* dbCreate(std::string path)
+sqlite3* dbCreate(std::string path, std::string query)
{
sqlite3 *sqlite = NULL;
bool is_db_corrupted = false;
_ERR("Sqlite error : [%d, %s]", ret, path.c_str());
return NULL;
}
- return dbCreate(path);
+ return dbCreate(path, query);
}
ret = sqlite3_exec(sqlite, "PRAGMA journal_mode = PERSIST", NULL, NULL, NULL);
if (ret != SQLITE_OK) {
sqlite = NULL;
return sqlite;
}
- ret = sqlite3_exec(sqlite, CREATE_TAC_DB_TABLE, NULL, NULL, NULL);
+ ret = sqlite3_exec(sqlite, query.c_str(), NULL, NULL, NULL);
if (ret != SQLITE_OK) {
_ERR("Sqlite error : [%d, %s]", ret, path.c_str());
sqlite3_close(sqlite);
sqlite = NULL;
return sqlite;
}
- return dbCreate(path);
+ return dbCreate(path, query);
}
return sqlite;
}
}
}
-void dbClose(sqlite3 *tac_db)
+void dbClose(sqlite3 *sqlite)
{
- if (tac_db) {
- sqlite3_exec(tac_db, "COMMIT;", NULL, NULL, NULL);
- sqlite3_close(tac_db);
- tac_db = NULL;
+ if (sqlite) {
+ sqlite3_exec(sqlite, "COMMIT;", NULL, NULL, NULL);
+ sqlite3_close(sqlite);
+ sqlite = NULL;
}
}
-void dbRollback(sqlite3 *tac_db)
+void dbRollback(sqlite3 *sqlite)
{
- if (tac_db) {
- sqlite3_exec(tac_db, "ROLLBACK;", NULL, NULL, NULL);
- sqlite3_close(tac_db);
- tac_db = NULL;
+ if (sqlite) {
+ sqlite3_exec(sqlite, "ROLLBACK;", NULL, NULL, NULL);
+ sqlite3_close(sqlite);
+ sqlite = NULL;
}
}
-bool dbUpdate(sqlite3 *tac_db, std::string path, std::string query)
+bool dbUpdate(sqlite3 *sqlite, std::string path, std::string query)
{
sqlite3_stmt *stmt = NULL;
- int ret = sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
- ret = sqlite3_prepare(tac_db, query.c_str(), QUERY_MAX_LEN , &stmt, NULL);
+ int ret = sqlite3_exec(sqlite, "BEGIN;", NULL, NULL, NULL);
+ ret = sqlite3_prepare(sqlite, query.c_str(), QUERY_MAX_LEN , &stmt, NULL);
if (ret != SQLITE_OK) {
- _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(tac_db));
- dbClose(tac_db);
+ _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(sqlite));
+ dbClose(sqlite);
return false;
}
ret = sqlite3_step(stmt);
if (ret != SQLITE_DONE && ret != SQLITE_ROW && ret != SQLITE_OK) {
- _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(tac_db));
+ _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(sqlite));
dbFinalize(stmt);
- dbClose(tac_db);
+ dbClose(sqlite);
return false;
}
dbFinalize(stmt);
return true;
}
-bool dbInsert(sqlite3 *tac_db, std::string path, std::string query)
+bool dbInsert(sqlite3 *sqlite, std::string path, std::string query)
{
sqlite3_stmt *stmt = NULL;
- int ret = sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
- ret = sqlite3_prepare(tac_db, query.c_str(), QUERY_MAX_LEN , &stmt, NULL);
+ int ret = sqlite3_exec(sqlite, "BEGIN;", NULL, NULL, NULL);
+ ret = sqlite3_prepare(sqlite, query.c_str(), QUERY_MAX_LEN , &stmt, NULL);
if (ret != SQLITE_OK) {
- _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(tac_db));
- dbClose(tac_db);
+ _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(sqlite));
+ dbClose(sqlite);
return false;
}
ret = sqlite3_step(stmt);
if (ret != SQLITE_DONE && ret != SQLITE_ROW && ret != SQLITE_OK) {
- _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(tac_db));
+ _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(sqlite));
dbFinalize(stmt);
- dbClose(tac_db);
+ dbClose(sqlite);
return false;
}
dbFinalize(stmt);
return true;
}
-std::vector<std::string> dbSelect(sqlite3 *tac_db, std::string path, std::string query)
+std::vector<std::string> dbSelect(sqlite3 *sqlite, std::string path, std::string query)
{
std::vector<std::string> updateDB;
sqlite3_stmt* stmt = NULL;
const char* str = NULL;
- int ret = sqlite3_prepare_v2(tac_db, query.c_str(), strlen(query.c_str()), &stmt, NULL);
+ int ret = sqlite3_prepare_v2(sqlite, query.c_str(), strlen(query.c_str()), &stmt, NULL);
if (ret != SQLITE_OK) {
- _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(tac_db));
- dbClose(tac_db);
+ _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(sqlite));
+ dbClose(sqlite);
return updateDB;
}
while (sqlite3_step(stmt) == SQLITE_ROW) {
return updateDB;
}
-bool dbDelete(sqlite3 *tac_db, std::string path, std::string query)
+bool dbDelete(sqlite3 *sqlite, std::string path, std::string query)
{
sqlite3_stmt *stmt = NULL;
- int ret = sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
- ret = sqlite3_prepare(tac_db, query.c_str(), QUERY_MAX_LEN , &stmt, NULL);
+ int ret = sqlite3_exec(sqlite, "BEGIN;", NULL, NULL, NULL);
+ ret = sqlite3_prepare(sqlite, query.c_str(), QUERY_MAX_LEN , &stmt, NULL);
if (ret != SQLITE_OK) {
- _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(tac_db));
- dbClose(tac_db);
+ _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(sqlite));
+ dbClose(sqlite);
return false;
}
ret = sqlite3_step(stmt);
if (ret != SQLITE_DONE && ret != SQLITE_ROW && ret != SQLITE_OK) {
- _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(tac_db));
+ _ERR("Sqlite error : [%d, %s]", ret, sqlite3_errmsg(sqlite));
dbFinalize(stmt);
- dbClose(tac_db);
+ dbClose(sqlite);
return false;
}
dbFinalize(stmt);