Add transaction begin/commit helpers

diff --git a/src/db.c b/src/db.c
index 92ef0d8ede5710dc20a6457529e3e18cfb6e7b4c..9bf76360a9be75b91fdb9350e22a9fd37fdc19d8 100644 (file)
--- a/src/db.c
+++ b/src/db.c
@@ -133,6 +133,18 @@ if (db && *db) {
 return TRUE;
 }
 
+gboolean
+db_transaction_begin(sqlite3 *db)
+{
+return db_exec_sql(db, "begin;");
+}
+
+gboolean
+db_transaction_commit(sqlite3 *db)
+{
+return db_exec_sql(db, "commit;");
+}
+
 /**
  * Connect to given sqlite database
  *
@@ -165,5 +177,3 @@ sqlite3_exec(*db, "PRAGMA cache_size = 8000;", NULL, NULL, NULL);
 return TRUE;
 }
 
-
-

diff --git a/src/db.h b/src/db.h
index 94ff03b122172d8c7cedcb01e4308bd00937c036..0949279d38fc33ffc6b4abc6d49cac3adabeca81 100644 (file)
--- a/src/db.h
+++ b/src/db.h
@@ -33,6 +33,9 @@ gboolean db_close(sqlite3 **db);
 gboolean db_exec_sql(sqlite3 *db, const gchar *sql);
 gboolean db_exec(sqlite3 *db, sqlite3_stmt *sql);
 
+gboolean db_transaction_begin(sqlite3 *db);
+gboolean db_transaction_commit(sqlite3 *db);
+
 void db_create_tables(sqlite3 *db);
 void db_create_indexes(sqlite3 *db);