]> pd.if.org Git - zpackage/blob - lib/db.c
add new db init program
[zpackage] / lib / db.c
1 /*
2  * add a file/files to an sqlite db
3  * in the 'files' table.
4  */
5
6 #include <stdio.h>
7 #include <sys/types.h>
8 #include <sys/stat.h>
9 #include <fcntl.h>
10 #include <unistd.h>
11
12 #include <sys/mman.h>
13
14 #include <sqlite3.h>
15 #include "sha256.h"
16
17
18 static int callback(void *NotUsed, int argc, char **argv, char **azColName){
19         int i;
20         for(i=0; i<argc; i++){
21                 printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
22         }
23         printf("\n");
24         return 0;
25 }
26
27 #if 0
28 static char *create_table = "create table if not exists files (hash text primary key, size integer, compression text, content blob)";
29 #endif
30
31 struct dbh {
32         sqlite3 *db;
33         char *errmsg;
34         int rc;
35 };
36
37 #define SQLERROR(x) fprintf(stderr, "%s %d: %s\n", __func__, __LINE__, (x))
38 int begin(sqlite3 *db) {
39         int rc;
40         char *err;
41
42         rc = sqlite3_exec(db, "begin;", callback, 0, &err);
43         if (rc != SQLITE_OK) {
44                 SQLERROR(err);
45                 sqlite3_free(err);
46         }
47         return rc;
48 }
49
50 int commit(sqlite3 *db) {
51         int rc;
52         char *err;
53
54         rc = sqlite3_exec(db, "commit;", callback, 0, &err);
55         if (rc != SQLITE_OK) {
56                 SQLERROR(err);
57                 sqlite3_free(err);
58         }
59         return rc;
60 }
61
62 int rollback(sqlite3 *db) {
63         int rc;
64         char *err;
65
66         rc = sqlite3_exec(db, "rollback;", callback, 0, &err);
67         if (rc != SQLITE_OK) {
68                 SQLERROR(err);
69                 sqlite3_free(err);
70         }
71         return rc;
72 }