blob: 5679eb789543fe6c9972e0630b7e979d4d54bb80 (
plain)
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
|
public class Database {
private Sqlite.Database db;
private Sqlite.Statement insert_stmt;
private Sqlite.Statement product_stmt;
uint64 user = 0;
private static string insert_query = "INSERT INTO purchases ('user', 'product') VALUES (?, ?)";
private static string product_query = "SELECT name FROM products WHERE id = ?";
public Database(string file) {
int rc;
rc = Sqlite.Database.open (file, out db);
if(rc != Sqlite.OK) {
error("could not open database!");
}
rc = this.db.prepare_v2(insert_query, -1, out insert_stmt);
if(rc != Sqlite.OK) {
error("could not prepare insert statement!");
}
rc = this.db.prepare_v2(product_query, -1, out product_stmt);
if(rc != Sqlite.OK) {
error("could not prepare article statement!");
}
}
public bool login(uint64 id) {
this.user = id;
return true;
}
public bool logout() {
this.user = 0;
return true;
}
public bool buy(uint64 article) {
if(is_logged_in()) {
this.insert_stmt.reset();
this.insert_stmt.bind_text(1, "%llu".printf(user));
this.insert_stmt.bind_text(2, "%llu".printf(article));
int rc = this.insert_stmt.step();
if(rc != Sqlite.DONE)
error("[interner Fehler: %d]".printf(rc));
else
return true;
} else {
return false;
}
}
public string get_product_name(uint64 article) {
this.product_stmt.reset();
this.product_stmt.bind_text(1, "%llu".printf(article));
int rc = this.product_stmt.step();
switch(rc) {
case Sqlite.ROW:
return this.product_stmt.column_text(0);
case Sqlite.DONE:
return "unbekanntes Produkt: %llu".printf(article);
default:
return "[interner Fehler: %d]".printf(rc);
}
}
public bool is_logged_in() {
return (user != 0);
}
}
|
