nikola/treender
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Wrap sqlite.h in sql.hpp

Browse Source
This commit is contained in:
Nikola Petrov
2025-01-28 00:47:37 +01:00
parent 9a37e8b581
commit 9edd3fc156
5 changed files with 91 additions and 108 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
server/src/server.cpp
View File

@@ -3,8 +3,6 @@
#include "sql.hpp"
#include "values/DnaManager.hpp"
#include <sqlite3.h>
#include <iostream>
#include <map>
@@ -40,30 +38,30 @@ void call(int sock, sockaddr_in newSocketInfo)
sqlite3 *db;
sqlite3_stmt *stmt;
int rc = sqlite3_open(DB_NAME, &db);
int rc = sql::open(DB_NAME, &db);
if (rc)
{
fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
fprintf(stderr, "Can't open database: %s\n", sql::errmsg(db));
ok = false;
}
sqlite3_prepare_v2(db, max_gen, -1, &stmt, NULL);
sqlite3_bind_int64(stmt, 1, id);
sql::prepare_v2(db, max_gen, -1, &stmt, NULL);
sql::bind_int64(stmt, 1, id);
int64_t gen = 0;
while (sqlite3_step(stmt) != SQLITE_DONE)
while (sql::step(stmt) != SQL_DONE)
{
int num_cols = sqlite3_column_count(stmt);
int num_cols = sql::column_count(stmt);
int type = sqlite3_column_type(stmt, 0);
int type = sql::column_type(stmt, 0);
if (type == SQLITE_NULL)
if (type == SQL_NULL)
break;
gen = sqlite3_column_int64(stmt, 0);
gen = sql::column_int64(stmt, 0);
gen++;
}
sqlite3_finalize(stmt);
sql::finalize(stmt);
sqlite3_prepare_v2(db, insert_data, -1, &stmt, NULL);
sql::prepare_v2(db, insert_data, -1, &stmt, NULL);
while (ok)
{
@@ -85,21 +83,21 @@ void call(int sock, sockaddr_in newSocketInfo)
for (size_t i = 0; i < list.size(); i++)
{
sqlite3_bind_int64(stmt, 1, id);
sqlite3_bind_int64(stmt, 2, gen);
sqlite3_bind_int64(stmt, 3, list[i].hash);
sqlite3_bind_int64(stmt, 4, list[i].index);
sqlite3_bind_int64(stmt, 5, list[i].liked);
sqlite3_step(stmt);
sqlite3_reset(stmt);
sql::bind_int64(stmt, 1, id);
sql::bind_int64(stmt, 2, gen);
sql::bind_int64(stmt, 3, list[i].hash);
sql::bind_int64(stmt, 4, list[i].index);
sql::bind_int64(stmt, 5, list[i].liked);
sql::step(stmt);
sql::reset(stmt);
}
gen++;
}
sqlite3_finalize(stmt);
sql::finalize(stmt);
sqlite3_close(db);
sql::close(db);
printf("del\n");
TcpSocket::closet(sock);
}