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
68
69
70
71
72
73
74
75
76
77
78
79
|
#include <string.h>
#include "db.h"
#include "util.h"
const char *
get_db_path()
{
return check_get_env("NEWSRAFT_DB_PATH");
}
bool
db_init()
{
int result = sqlite3_open(get_db_path(), &db);
if (result != SQLITE_OK) {
fprintf(stderr, "Can't open database: %s", sqlite3_errmsg(db));
sqlite3_close(db);
return false;
}
return true;
}
void
db_clean()
{
sqlite3_close(db);
}
struct feed *
get_db_feeds()
{
char *query;
size_t total_feeds = get_feed_count();
if (total_feeds == 0) {
return NULL;
}
struct feed *feeds = calloc(sizeof(struct feed), total_feeds);
query = "select feed_url,title from feeds;";
int result = sqlite3_prepare_v2(db, query, -1, &statement, NULL);
if (result == SQLITE_OK) {
for (size_t i = 0; sqlite3_step(statement) != SQLITE_DONE; i++) {
char *url = (char*)sqlite3_column_text(statement, 0);
char *title = (char*)sqlite3_column_text(statement, 1);
feeds[i] = create_feed(url, title);
}
}
#ifdef DEBUG
for (size_t i = 0; i < total_feeds; i++) {
printf("%s, %s\n", feeds[i].title, feeds[i].url);
}
#endif
sqlite3_finalize(statement);
return feeds;
}
size_t
get_feed_count()
{
char* query = "select count(*) from feeds;";
int result = sqlite3_prepare_v2(db, query, -1, &statement, NULL);
int total_feeds = 0;
if (result == SQLITE_OK) {
while(sqlite3_step(statement) != SQLITE_DONE) {
total_feeds = sqlite3_column_int(statement, 0);
printf("%d\n", total_feeds);
}
}
sqlite3_finalize(statement);
return total_feeds;
}
//size_t get_item_count() {
//}
|
