fix closing segfault
This commit is contained in:
@@ -27,18 +27,7 @@ Store::Store(bool mem_store)
|
|||||||
m_ok &= CreateStatements();
|
m_ok &= CreateStatements();
|
||||||
}
|
}
|
||||||
|
|
||||||
Store::~Store() {
|
Store::~Store() {}
|
||||||
m_db.Close();
|
|
||||||
if (!m_db.OK()) {
|
|
||||||
fprintf(stderr, "error closing database: %s\n", m_db.ErrStr());
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (m_db_path != ":memory:") {
|
|
||||||
std::error_code ec;
|
|
||||||
std::filesystem::remove(m_db_path, ec);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
bool Store::IsValid() const {
|
bool Store::IsValid() const {
|
||||||
return m_db.OK() && m_ok;
|
return m_db.OK() && m_ok;
|
||||||
@@ -2363,7 +2352,8 @@ bool Store::CreateStatements() {
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
Store::Database::Database(const char *path) {
|
Store::Database::Database(const char *path)
|
||||||
|
: m_db_path(path) {
|
||||||
if (path != ":memory:"s) {
|
if (path != ":memory:"s) {
|
||||||
std::error_code ec;
|
std::error_code ec;
|
||||||
if (std::filesystem::exists(path, ec) && !std::filesystem::remove(path, ec)) {
|
if (std::filesystem::exists(path, ec) && !std::filesystem::remove(path, ec)) {
|
||||||
@@ -2380,9 +2370,18 @@ Store::Database::~Database() {
|
|||||||
|
|
||||||
int Store::Database::Close() {
|
int Store::Database::Close() {
|
||||||
if (m_db == nullptr) return m_err;
|
if (m_db == nullptr) return m_err;
|
||||||
m_signal_close.emit();
|
|
||||||
m_err = sqlite3_close(m_db);
|
m_err = sqlite3_close(m_db);
|
||||||
m_db = nullptr;
|
m_db = nullptr;
|
||||||
|
|
||||||
|
if (!OK()) {
|
||||||
|
fprintf(stderr, "error closing database: %s\n", ErrStr());
|
||||||
|
} else {
|
||||||
|
if (m_db_path != ":memory:") {
|
||||||
|
std::error_code ec;
|
||||||
|
std::filesystem::remove(m_db_path, ec);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return m_err;
|
return m_err;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -2423,17 +2422,9 @@ sqlite3 *Store::Database::obj() {
|
|||||||
return m_db;
|
return m_db;
|
||||||
}
|
}
|
||||||
|
|
||||||
Store::Database::type_signal_close Store::Database::signal_close() {
|
|
||||||
return m_signal_close;
|
|
||||||
}
|
|
||||||
|
|
||||||
Store::Statement::Statement(Database &db, const char *command)
|
Store::Statement::Statement(Database &db, const char *command)
|
||||||
: m_db(&db) {
|
: m_db(&db) {
|
||||||
if (m_db->SetError(sqlite3_prepare_v2(m_db->obj(), command, -1, &m_stmt, nullptr)) != SQLITE_OK) return;
|
if (m_db->SetError(sqlite3_prepare_v2(m_db->obj(), command, -1, &m_stmt, nullptr)) != SQLITE_OK) return;
|
||||||
m_db->signal_close().connect([this] {
|
|
||||||
sqlite3_finalize(m_stmt);
|
|
||||||
m_stmt = nullptr;
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Store::Statement::~Statement() {
|
Store::Statement::~Statement() {
|
||||||
|
@@ -121,13 +121,7 @@ private:
|
|||||||
sqlite3 *m_db;
|
sqlite3 *m_db;
|
||||||
int m_err = SQLITE_OK;
|
int m_err = SQLITE_OK;
|
||||||
mutable char m_err_scratch[256] { 0 };
|
mutable char m_err_scratch[256] { 0 };
|
||||||
|
std::filesystem::path m_db_path;
|
||||||
// stupid shit i dont like to allow closing properly
|
|
||||||
using type_signal_close = sigc::signal<void>;
|
|
||||||
type_signal_close m_signal_close;
|
|
||||||
|
|
||||||
public:
|
|
||||||
type_signal_close signal_close();
|
|
||||||
};
|
};
|
||||||
|
|
||||||
class Statement {
|
class Statement {
|
||||||
|
Reference in New Issue
Block a user