using Sqlite; namespace Qlite { public class Table { protected Database db; public string name { get; private set; } protected Column[] columns; public Table(Database db, string name) { this.db = db; this.name = name; } public void init(Column[] columns) { this.columns = columns; } private void ensure_init() throws DatabaseError { if (columns == null) throw new DatabaseError.NOT_INITIALIZED(@"Table $name was not initialized, call init()"); } public QueryBuilder select(Column[]? columns = null) throws DatabaseError { ensure_init(); return db.select(columns).from(this); } public InsertBuilder insert() throws DatabaseError { ensure_init(); return db.insert().into(this); } public UpdateBuilder update() throws DatabaseError { ensure_init(); return db.update(this); } public DeleteBuilder delete() throws DatabaseError { ensure_init(); return db.delete().from(this); } public Row? row_with(Column column, T value) throws DatabaseError { ensure_init(); if (!column.unique && !column.primary_key) throw new DatabaseError.NON_UNIQUE(@"$(column.name) is not suited to identify a row, but used with row_with()"); return select().with(column, "=", value).row(); } public bool is_known_column(string column) throws DatabaseError { ensure_init(); foreach (Column c in columns) { if (c.name == column) return true; } return false; } public void create_table_at_version(long version) throws DatabaseError { 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 += ")"; db.exec(sql); } public void add_columns_for_version(long old_version, long new_version) throws DatabaseError { ensure_init(); foreach (Column c in columns) { if (c.min_version <= new_version && c.max_version >= new_version && c.min_version > old_version && c.max_version < old_version) { db.exec(@"ALTER TABLE $name ADD COLUMN $c"); } } } public void delete_columns_for_version(long old_version, long new_version) throws DatabaseError { // TODO: Rename old table, create table at new_version, transfer data } } }