1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
#include "storage_sqlite.h"
#include "log.h"
#include "storage.h"
#include <sqlite3.h>
#include <stdlib.h>
#include <string.h>
#define sqlite_errno(var, fn) \
do { \
log_err("%s: %s\n", fn, sqlite3_errstr(var)); \
var = -var; \
} while (0)
#define sqlite_errno_if(expr, fn) \
do { \
int CONCAT(ret, __LINE__) = expr; \
if (CONCAT(ret, __LINE__)) \
sqlite_errno(CONCAT(ret, __LINE__), fn); \
} while (0)
int storage_settings_create_sqlite(struct storage_settings *settings, const char *path)
{
settings->sqlite.path = strdup(path);
if (!settings->sqlite.path) {
log_errno("strdup");
return -1;
}
settings->type = STORAGE_TYPE_SQLITE;
return 0;
}
void storage_settings_destroy_sqlite(const struct storage_settings *settings)
{
free(settings->sqlite.path);
}
struct storage_sqlite {
sqlite3 *db;
};
int storage_create_sqlite(struct storage *storage, const struct storage_settings *settings)
{
int ret = 0;
storage->sqlite = malloc(sizeof(storage->sqlite));
if (!storage->sqlite) {
log_errno("malloc");
return -1;
}
ret = sqlite3_open(settings->sqlite.path, &storage->sqlite->db);
if (ret) {
sqlite_errno(ret, "sqlite3_open");
return ret;
}
return 0;
}
void storage_destroy_sqlite(struct storage *storage)
{
sqlite_errno_if(sqlite3_close(storage->sqlite->db), "sqlite3_close");
free(storage->sqlite);
}
|
