369 lines
14 KiB
C++
369 lines
14 KiB
C++
#include "Database.h"
|
|
#include "BoostLog.h"
|
|
#include <sqlite3.h>
|
|
#include <sstream>
|
|
|
|
bool Database::open(const std::string &path) {
|
|
bool ret = true;
|
|
int result = sqlite3_open(path.c_str(), &m_sqlite3);
|
|
if (result != SQLITE_OK) {
|
|
ret = false;
|
|
LOG(error) << "open database failed.";
|
|
}
|
|
initialize();
|
|
return ret;
|
|
}
|
|
|
|
static int selectTaskCallback(void *data, int argc, char **argv, char **columnName) {
|
|
auto tasks = reinterpret_cast<Tasks *>(data);
|
|
Task task;
|
|
for (int i = 0; i < argc; i++) {
|
|
if (argv[i] == nullptr) continue;
|
|
if (strcmp(columnName[i], "id") == 0) {
|
|
task.id = std::atol(argv[i]);
|
|
} else if (strcmp(columnName[i], "create_time") == 0) {
|
|
task.createTime = std::atol(argv[i]);
|
|
} else if (strcmp(columnName[i], "content") == 0) {
|
|
task.content = argv[i];
|
|
} else if (strcmp(columnName[i], "comment") == 0) {
|
|
task.comment = argv[i];
|
|
} else if (strcmp(columnName[i], "finished") == 0) {
|
|
task.finished = std::atol(argv[i]);
|
|
} else if (strcmp(columnName[i], "parent_id") == 0) {
|
|
task.parentId = std::atol(argv[i]);
|
|
}
|
|
}
|
|
tasks->push_back(task);
|
|
return 0;
|
|
}
|
|
|
|
Tasks Database::tasks() {
|
|
Tasks ret;
|
|
char *error = nullptr;
|
|
if (sqlite3_exec(m_sqlite3, "select * from tasks", selectTaskCallback, &ret, &error) != SQLITE_OK) {
|
|
LOG(error) << "sqlite3_exec() failed: " << error << std::endl;
|
|
sqlite3_free(error);
|
|
}
|
|
std::unordered_map<int, Task *> tasks;
|
|
for (auto iterator = ret.begin(); iterator != ret.end();) {
|
|
if (iterator->parentId >= 0) {
|
|
if (tasks.count(iterator->parentId) > 0) {
|
|
auto parentTask = tasks.at(iterator->parentId);
|
|
parentTask->children.push_back(*iterator);
|
|
tasks.insert({iterator->id, &parentTask->children.back()});
|
|
} else {
|
|
LOG(warning) << "task`s parent id " << iterator->parentId << " not existed.";
|
|
}
|
|
iterator = ret.erase(iterator);
|
|
} else {
|
|
tasks.insert({iterator->id, &(*iterator)});
|
|
++iterator;
|
|
}
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
bool Database::addTask(uint64_t createTime, const std::string &content, const std::string &comment, int parentId,
|
|
bool finished) {
|
|
bool ret = true;
|
|
std::ostringstream oss;
|
|
oss << "INSERT INTO tasks (create_time,content,comment,parent_id,finished) VALUES (" << createTime << ",\""
|
|
<< content << "\",\"" << comment << "\"," << parentId << "," << finished << ");";
|
|
auto sql = oss.str();
|
|
char *error = nullptr;
|
|
int result = sqlite3_exec(m_sqlite3, sql.c_str(), NULL, NULL, &error);
|
|
if (result != SQLITE_OK) {
|
|
LOG(error) << "add task failed: " << error << ", sql: " << sql;
|
|
sqlite3_free(error);
|
|
ret = false;
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
bool Database::removeTask(int id) {
|
|
bool ret = true;
|
|
std::ostringstream oss;
|
|
oss << "DELETE FROM tasks WHERE id = " << id << ";";
|
|
auto sql = oss.str();
|
|
char *error = nullptr;
|
|
int result = sqlite3_exec(m_sqlite3, sql.c_str(), NULL, NULL, &error);
|
|
if (result != SQLITE_OK) {
|
|
LOG(error) << "add task failed: " << error << ", sql: " << sql;
|
|
sqlite3_free(error);
|
|
ret = false;
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
void Database::setTaskFinished(int id, bool finished, uint64_t finishedTime) {
|
|
std::ostringstream oss;
|
|
oss << "UPDATE tasks SET finished = " << finished << ", finished_time = " << finishedTime << " WHERE id = " << id;
|
|
auto sql = oss.str();
|
|
int result = sqlite3_exec(m_sqlite3, sql.c_str(), NULL, NULL, NULL);
|
|
if (result != SQLITE_OK) {
|
|
LOG(error) << "add task failed: " << sqlite3_errmsg(m_sqlite3) << ", sql: " << sql;
|
|
return;
|
|
}
|
|
}
|
|
|
|
void Database::updateVisitCount(const std::string &url, const std::string &visitorUuid, const std::string &userAgent,
|
|
int64_t time) {
|
|
sqlite3_stmt *stmt;
|
|
auto strippedUrl = url;
|
|
if (strippedUrl.size() > 1 && strippedUrl.back() == '/') {
|
|
strippedUrl.pop_back();
|
|
}
|
|
const char *query = "SELECT id, page_view_count FROM visit_analysis WHERE url = ? AND visitor_uuid = ?";
|
|
if (sqlite3_prepare_v2(m_sqlite3, query, -1, &stmt, 0) != SQLITE_OK) {
|
|
LOG(error) << "Failed to prepare statement: " << sqlite3_errmsg(m_sqlite3);
|
|
}
|
|
sqlite3_bind_text(stmt, 1, strippedUrl.c_str(), -1, SQLITE_STATIC);
|
|
sqlite3_bind_text(stmt, 2, visitorUuid.c_str(), -1, SQLITE_STATIC);
|
|
int id = -1;
|
|
int page_view_count = 0;
|
|
if (sqlite3_step(stmt) == SQLITE_ROW) {
|
|
id = sqlite3_column_int(stmt, 0);
|
|
page_view_count = sqlite3_column_int(stmt, 1);
|
|
}
|
|
sqlite3_finalize(stmt);
|
|
if (id != -1) { // 更新记录
|
|
const char *updateQuery =
|
|
"UPDATE visit_analysis SET last_user_agent = ?, last_view_time = ?, page_view_count = ? WHERE id = ?";
|
|
if (sqlite3_prepare_v2(m_sqlite3, updateQuery, -1, &stmt, 0) != SQLITE_OK) {
|
|
LOG(error) << "Failed to prepare update statement: " << sqlite3_errmsg(m_sqlite3);
|
|
}
|
|
sqlite3_bind_text(stmt, 1, userAgent.c_str(), -1, SQLITE_STATIC);
|
|
sqlite3_bind_int64(stmt, 2, time);
|
|
sqlite3_bind_int(stmt, 3, page_view_count + 1);
|
|
sqlite3_bind_int(stmt, 4, id);
|
|
if (sqlite3_step(stmt) != SQLITE_DONE) {
|
|
LOG(error) << "Failed to update record: " << sqlite3_errmsg(m_sqlite3);
|
|
}
|
|
sqlite3_finalize(stmt);
|
|
} else { // 插入新记录
|
|
const char *insertQuery = "INSERT INTO visit_analysis (url, visitor_uuid, last_user_agent, last_view_time, "
|
|
"page_view_count) VALUES (?, ?, ?, ?, 1)";
|
|
if (sqlite3_prepare_v2(m_sqlite3, insertQuery, -1, &stmt, 0) != SQLITE_OK) {
|
|
LOG(error) << "Failed to prepare insert statement: " << sqlite3_errmsg(m_sqlite3);
|
|
}
|
|
sqlite3_bind_text(stmt, 1, strippedUrl.c_str(), -1, SQLITE_STATIC);
|
|
sqlite3_bind_text(stmt, 2, visitorUuid.c_str(), -1, SQLITE_STATIC);
|
|
sqlite3_bind_text(stmt, 3, userAgent.c_str(), -1, SQLITE_STATIC);
|
|
sqlite3_bind_int64(stmt, 4, time);
|
|
if (sqlite3_step(stmt) != SQLITE_DONE) {
|
|
LOG(error) << "Failed to insert record: " << sqlite3_errmsg(m_sqlite3) << std::endl;
|
|
}
|
|
sqlite3_finalize(stmt);
|
|
}
|
|
}
|
|
|
|
void Database::clearVisitRecord() {
|
|
char *message = nullptr;
|
|
constexpr auto sql = "DELETE FROM visit_analysis";
|
|
int rc = sqlite3_exec(m_sqlite3, sql, nullptr, nullptr, &message);
|
|
if (rc != SQLITE_OK) {
|
|
LOG(error) << "SQL error: " << message;
|
|
sqlite3_free(message);
|
|
}
|
|
}
|
|
|
|
VisitAnalysis Database::siteVisitAnalysisData() {
|
|
VisitAnalysis ret;
|
|
sqlite3_stmt *stmt = nullptr;
|
|
const char *sql = "SELECT COUNT(DISTINCT visitor_uuid) as unique_visitors, SUM(page_view_count) as "
|
|
"total_page_views FROM visit_analysis";
|
|
if (sqlite3_prepare_v2(m_sqlite3, sql, -1, &stmt, nullptr) != SQLITE_OK) {
|
|
LOG(error) << "Failed to prepare statement: " << sqlite3_errmsg(m_sqlite3);
|
|
return ret;
|
|
}
|
|
if (sqlite3_step(stmt) == SQLITE_ROW) {
|
|
ret.uniqueVisitorCount = sqlite3_column_int(stmt, 0);
|
|
ret.pageViewCount = sqlite3_column_int(stmt, 1);
|
|
} else {
|
|
LOG(error) << "Failed to execute query: " << sqlite3_errmsg(m_sqlite3);
|
|
}
|
|
sqlite3_finalize(stmt);
|
|
return ret;
|
|
}
|
|
|
|
static std::vector<std::string> urlFilter = {
|
|
"/",
|
|
"/search",
|
|
"/LoginPage",
|
|
"/MessageBoard",
|
|
"/我的笔记",
|
|
"/我的博客",
|
|
};
|
|
|
|
std::list<VisitAnalysis> Database::mostViewedUrls(int size) {
|
|
const char *sql = "SELECT url, SUM(page_view_count) AS total_page_view_count "
|
|
"FROM visit_analysis "
|
|
"GROUP BY url "
|
|
"ORDER BY total_page_view_count DESC "
|
|
"LIMIT ?";
|
|
sqlite3_stmt *stmt = nullptr;
|
|
std::list<VisitAnalysis> ret;
|
|
auto rc = sqlite3_prepare_v2(m_sqlite3, sql, -1, &stmt, nullptr);
|
|
if (rc != SQLITE_OK) {
|
|
LOG(error) << "Failed to prepare statement: " << sqlite3_errmsg(m_sqlite3);
|
|
return ret;
|
|
}
|
|
|
|
sqlite3_bind_int(stmt, 1, size + urlFilter.size());
|
|
while ((rc = sqlite3_step(stmt)) == SQLITE_ROW) {
|
|
VisitAnalysis pv;
|
|
pv.url = reinterpret_cast<const char *>(sqlite3_column_text(stmt, 0));
|
|
if (std::find(urlFilter.cbegin(), urlFilter.cend(), pv.url) != urlFilter.cend()) continue;
|
|
pv.pageViewCount = sqlite3_column_int(stmt, 1);
|
|
if (ret.size() < size) {
|
|
ret.push_back(pv);
|
|
}
|
|
}
|
|
|
|
if (rc != SQLITE_DONE) {
|
|
LOG(error) << "Failed to execute statement: " << sqlite3_errmsg(m_sqlite3);
|
|
}
|
|
sqlite3_finalize(stmt);
|
|
return ret;
|
|
}
|
|
|
|
std::list<VisitAnalysis> Database::latestViewedUrls(int size) {
|
|
std::list<VisitAnalysis> ret;
|
|
sqlite3_stmt *stmt;
|
|
const char *sql = R"(
|
|
SELECT url, MAX(last_view_time) as last_view_time
|
|
FROM visit_analysis
|
|
GROUP BY url
|
|
ORDER BY last_view_time DESC
|
|
LIMIT ?
|
|
)";
|
|
|
|
if (sqlite3_prepare_v2(m_sqlite3, sql, -1, &stmt, nullptr) != SQLITE_OK) {
|
|
LOG(error) << "Failed to prepare statement: " << sqlite3_errmsg(m_sqlite3);
|
|
return ret;
|
|
}
|
|
|
|
if (sqlite3_bind_int(stmt, 1, size + urlFilter.size()) != SQLITE_OK) {
|
|
LOG(error) << "Failed to bind parameter: " << sqlite3_errmsg(m_sqlite3);
|
|
sqlite3_finalize(stmt);
|
|
return ret;
|
|
}
|
|
|
|
while (sqlite3_step(stmt) == SQLITE_ROW) {
|
|
VisitAnalysis visit;
|
|
visit.url = reinterpret_cast<const char *>(sqlite3_column_text(stmt, 0));
|
|
if (std::find(urlFilter.cbegin(), urlFilter.cend(), visit.url) != urlFilter.cend()) continue;
|
|
visit.lastViewTime = sqlite3_column_int64(stmt, 1);
|
|
if (ret.size() < size) {
|
|
ret.push_back(visit);
|
|
}
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
VisitAnalysis Database::visitAnalysisData(const std::string &url) {
|
|
VisitAnalysis ret;
|
|
sqlite3_stmt *stmt;
|
|
std::string query =
|
|
"SELECT SUM(page_view_count), COUNT(DISTINCT visitor_uuid) FROM visit_analysis WHERE url = '" + url + "';";
|
|
if (sqlite3_prepare_v2(m_sqlite3, query.c_str(), -1, &stmt, nullptr) == SQLITE_OK) {
|
|
if (sqlite3_step(stmt) == SQLITE_ROW) {
|
|
ret.pageViewCount = sqlite3_column_int(stmt, 0);
|
|
ret.uniqueVisitorCount = sqlite3_column_int(stmt, 1);
|
|
}
|
|
sqlite3_finalize(stmt);
|
|
} else {
|
|
LOG(error) << "Failed to execute query: " << sqlite3_errmsg(m_sqlite3);
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
bool Database::addHomeBoxItem(const std::string &name, const std::string &location, int cost) {
|
|
bool ret = true;
|
|
std::ostringstream oss;
|
|
oss << "INSERT INTO homebox (name,location,cost) VALUES (\"" << name << "\",\"" << location << "\"," << cost
|
|
<< ");";
|
|
auto sql = oss.str();
|
|
char *error = nullptr;
|
|
int result = sqlite3_exec(m_sqlite3, sql.c_str(), NULL, NULL, &error);
|
|
if (result != SQLITE_OK) {
|
|
LOG(error) << "add task failed: " << error << ", sql: " << sql;
|
|
sqlite3_free(error);
|
|
ret = false;
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
static int selectHomeBoxItemCallback(void *data, int argc, char **argv, char **columnName) {
|
|
auto items = reinterpret_cast<HomeBox::Items *>(data);
|
|
HomeBox::Item item;
|
|
for (int i = 0; i < argc; i++) {
|
|
if (argv[i] == nullptr) continue;
|
|
if (strcmp(columnName[i], "id") == 0) {
|
|
item.id = std::atol(argv[i]);
|
|
} else if (strcmp(columnName[i], "name") == 0) {
|
|
item.name = argv[i];
|
|
} else if (strcmp(columnName[i], "location") == 0) {
|
|
item.location = argv[i];
|
|
} else if (strcmp(columnName[i], "cost") == 0) {
|
|
item.cost = std::atol(argv[i]);
|
|
}
|
|
}
|
|
items->push_back(item);
|
|
return 0;
|
|
}
|
|
|
|
HomeBox::Items Database::homeBoxItems() {
|
|
HomeBox::Items ret;
|
|
char *error = nullptr;
|
|
if (sqlite3_exec(m_sqlite3, "select * from homebox", selectHomeBoxItemCallback, &ret, &error) != SQLITE_OK) {
|
|
LOG(error) << "sqlite3_exec() failed: " << error << std::endl;
|
|
sqlite3_free(error);
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
void Database::initialize() {
|
|
const char *sql =
|
|
"CREATE TABLE IF NOT EXISTS tasks (id INTEGER PRIMARY KEY AUTOINCREMENT, create_time INTEGER NOT NULL, "
|
|
"parent_id INTEGER, content VARCHAR(512) NOT NULL, comment VARCHAR(512) NOT NULL, finished BOLL, finished_time "
|
|
"INTEGER);";
|
|
int result = sqlite3_exec(m_sqlite3, sql, NULL, NULL, NULL);
|
|
if (result != SQLITE_OK) {
|
|
LOG(error) << "Failed to create table: " << sqlite3_errmsg(m_sqlite3);
|
|
return;
|
|
}
|
|
|
|
const char *homeBoxSql = "CREATE TABLE IF NOT EXISTS homebox (id INTEGER PRIMARY KEY AUTOINCREMENT, "
|
|
"name VARCHAR(512) NOT NULL, location VARCHAR(512) NOT NULL, cost INTEGER);";
|
|
result = sqlite3_exec(m_sqlite3, homeBoxSql, NULL, NULL, NULL);
|
|
if (result != SQLITE_OK) {
|
|
LOG(error) << "Failed to create table: " << sqlite3_errmsg(m_sqlite3);
|
|
return;
|
|
}
|
|
|
|
char *message = nullptr;
|
|
sql = R"(
|
|
CREATE TABLE IF NOT EXISTS visit_analysis (
|
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
|
url TEXT NOT NULL,
|
|
visitor_uuid TEXT NOT NULL,
|
|
last_user_agent TEXT NOT NULL,
|
|
last_view_time INTEGER NOT NULL,
|
|
page_view_count INTEGER NOT NULL
|
|
);
|
|
)";
|
|
result = sqlite3_exec(m_sqlite3, sql, 0, 0, &message);
|
|
if (result != SQLITE_OK) {
|
|
LOG(error) << "Failed to create table: " << message << std::endl;
|
|
sqlite3_free(message);
|
|
}
|
|
}
|
|
|
|
Database::~Database() {
|
|
if (m_sqlite3 != nullptr) {
|
|
sqlite3_close(m_sqlite3);
|
|
m_sqlite3 = nullptr;
|
|
}
|
|
}
|