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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
|
using Sqlite;
namespace Qlite {
public class Table {
protected Database db;
public string name { get; private set; }
protected Column[]? columns;
private string constraints = "";
private string[] post_statements = {};
public Table(Database db, string name) {
this.db = db;
this.name = name;
}
public void init(Column[] columns, string constraints = "") {
this.columns = columns;
this.constraints = constraints;
}
public void unique(Column[] columns, string? on_conflict = null) {
constraints += ", UNIQUE (";
bool first = true;
foreach (Column c in columns) {
if (!first) constraints += ", ";
constraints += c.name;
first = false;
}
constraints += ")";
if (on_conflict != null) {
constraints += " ON CONFLICT " + (!)on_conflict;
}
}
public void add_post_statement(string stmt) {
post_statements += stmt;
}
public void index(string index_name, Column[] columns, bool unique = false) {
string stmt = @"CREATE $(unique ? "UNIQUE" : "") INDEX IF NOT EXISTS $index_name ON $name (";
bool first = true;
foreach (Column c in columns) {
if (!first) stmt += ", ";
stmt += c.name;
first = false;
}
stmt += ")";
add_post_statement(stmt);
}
private void ensure_init() {
if (columns == null) error("Table %s was not initialized, call init()", name);
}
public QueryBuilder select(Column[]? columns = null) {
ensure_init();
return db.select(columns).from(this);
}
public InsertBuilder insert() {
ensure_init();
return db.insert().into(this);
}
public UpdateBuilder update() {
ensure_init();
return db.update(this);
}
public UpsertBuilder upsert() {
ensure_init();
return db.upsert(this);
}
public DeleteBuilder delete() {
ensure_init();
return db.delete().from(this);
}
public RowOption row_with<T>(Column<T> column, T value) {
ensure_init();
if (!column.unique && !column.primary_key) error("%s is not suited to identify a row, but used with row_with()", column.name);
return select().with(column, "=", value).row();
}
public bool is_known_column(string column) {
ensure_init();
foreach (Column c in columns) {
if (c.name == column) return true;
}
return false;
}
public void create_table_at_version(long version) {
ensure_init();
string sql = @"CREATE TABLE IF NOT EXISTS $name (";
for (int i = 0; i < columns.length; i++) {
Column c = columns[i];
if (c.min_version <= version && c.max_version >= version) {
sql += @"$(i > 0 ? "," : "") $c";
}
}
sql += @"$constraints)";
try {
db.exec(sql);
} catch (Error e) {
error("Qlite Error: Create table at version");
}
}
public void add_columns_for_version(long old_version, long new_version) {
ensure_init();
foreach (Column c in columns) {
if (c.min_version <= new_version && c.max_version >= new_version && c.min_version > old_version) {
try {
db.exec(@"ALTER TABLE $name ADD COLUMN $c");
} catch (Error e) {
error("Qlite Error: Add columns for version");
}
}
}
}
public void delete_columns_for_version(long old_version, long new_version) {
bool column_deletion_required = false;
string column_list = "";
foreach (Column c in columns) {
if (c.min_version <= new_version && c.max_version >= new_version) {
if (column_list == "") {
column_list = c.name;
} else {
column_list += ", " + c.name;
}
}
if (!(c.min_version <= new_version && c.max_version >= new_version) && c.min_version <= old_version && c.max_version >= old_version) {
column_deletion_required = true;
}
}
if (column_deletion_required) {
try {
db.exec(@"ALTER TABLE $name RENAME TO _$(name)_$old_version");
create_table_at_version(new_version);
db.exec(@"INSERT INTO $name ($column_list) SELECT $column_list FROM _$(name)_$old_version");
db.exec(@"DROP TABLE _$(name)_$old_version");
} catch (Error e) {
error("Qlite Error: Delete volumns for version change");
}
}
}
internal void post() {
foreach (string stmt in post_statements) {
try {
db.exec(stmt);
} catch (Error e) {
error("Qlite Error: Post");
}
}
}
}
}
|
