summaryrefslogtreecommitdiff
path: root/src/lib/sqlite_statement.cc
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2025-01-19 00:21:11 +0100
committerCarl Hetherington <cth@carlh.net>2025-01-22 14:34:25 +0100
commit16b3f6c6245acf9689349dbd2af7d4411f861767 (patch)
tree14bedff2389bf48c643e1a7d34c82d8265251801 /src/lib/sqlite_statement.cc
parent9964a038c1a1ed86510439a33b7022807af31d8d (diff)
Move sqlite database open/close to a new SQLiteDatabase.
Diffstat (limited to 'src/lib/sqlite_statement.cc')
-rw-r--r--src/lib/sqlite_statement.cc9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/lib/sqlite_statement.cc b/src/lib/sqlite_statement.cc
index b3ec1fb81..d130da507 100644
--- a/src/lib/sqlite_statement.cc
+++ b/src/lib/sqlite_statement.cc
@@ -20,6 +20,7 @@
#include "exceptions.h"
+#include "sqlite_database.h"
#include "sqlite_statement.h"
@@ -27,13 +28,13 @@ using std::function;
using std::string;
-SQLiteStatement::SQLiteStatement(sqlite3* db, string const& statement)
+SQLiteStatement::SQLiteStatement(SQLiteDatabase& db, string const& statement)
: _db(db)
{
#ifdef DCPOMATIC_HAVE_SQLITE3_PREPARE_V3
- auto rc = sqlite3_prepare_v3(_db, statement.c_str(), -1, 0, &_stmt, nullptr);
+ auto rc = sqlite3_prepare_v3(_db.db(), statement.c_str(), -1, 0, &_stmt, nullptr);
#else
- auto rc = sqlite3_prepare_v2(_db, statement.c_str(), -1, &_stmt, nullptr);
+ auto rc = sqlite3_prepare_v2(_db.db(), statement.c_str(), -1, &_stmt, nullptr);
#endif
if (rc != SQLITE_OK) {
throw SQLError(_db, rc, statement);
@@ -83,7 +84,7 @@ SQLiteStatement::execute(function<void(SQLiteStatement&)> row, function<void()>
break;
case SQLITE_ERROR:
case SQLITE_MISUSE:
- throw SQLError(_db, sqlite3_errmsg(_db));
+ throw SQLError(_db, sqlite3_errmsg(_db.db()));
}
}
}