tiny.sql.RowIdTable

1pub const Table = struct {2    rows: tree.Tree,34    pub fn open(database: *file.Database, options: Options) Error!Table {5        return .{ .rows = try tree.Tree.open(database, options.tree) };6    }78    pub fn reader(self: *const Table, snapshot: file.Snapshot) Error!Reader {9        return .{ .rows = try self.rows.reader(snapshot) };10    }1112    pub fn lastRowId(self: *const Table) Error!?i64 {13        var read = try self.rows.database.beginRead();14        defer read.deinit();15        const opened = try self.reader(read.snapshot());16        return try opened.lastRowId();17    }1819    pub fn put(self: *Table, rowid: i64, values: []const row.Value, options: file.CommitOptions) Error!file.Commit {20        const phase = trace.scope("table.put");21        defer phase.end();2223        var write = try tree.Write.beginTree(&self.rows);24        defer write.deinit();25        try self.putIn(&write, rowid, values);26        return try write.commit(options);27    }2829    pub fn putIn(self: *Table, write: *tree.Write, rowid: i64, values: []const row.Value) Error!void {30        var key_bytes: [key.rowid_size]u8 = undefined;31        var row_bytes: [page.size]u8 = undefined;32        const encoded_key = try key.encodeRowId(&key_bytes, rowid);33        const encoded_row = try row.encode(&row_bytes, values);34        try write.put(&self.rows, encoded_key, encoded_row);35    }3637    pub fn putEncoded(self: *Table, rowid: i64, bytes: []const u8, options: file.CommitOptions) Error!file.Commit {38        const phase = trace.scope("table.put_encoded");39        defer phase.end();4041        var write = try tree.Write.beginTree(&self.rows);42        defer write.deinit();43        try self.putEncodedIn(&write, rowid, bytes);44        return try write.commit(options);45    }4647    pub fn putEncodedIn(self: *Table, write: *tree.Write, rowid: i64, bytes: []const u8) Error!void {48        _ = try row.View.init(bytes);49        var key_bytes: [key.rowid_size]u8 = undefined;50        try write.put(&self.rows, try key.encodeRowId(&key_bytes, rowid), bytes);51    }5253    pub fn get(self: *const Table, allocator: Allocator, rowid: i64) Error!?[]u8 {54        var read = try self.rows.database.beginRead();55        defer read.deinit();56        const opened = try self.reader(read.snapshot());57        return try opened.get(allocator, rowid);58    }5960    pub fn valueLength(self: *const Table, rowid: i64) Error!?usize {61        var read = try self.rows.database.beginRead();62        defer read.deinit();63        const opened = try self.reader(read.snapshot());64        return try opened.valueLength(rowid);65    }6667    pub fn getInto(self: *const Table, rowid: i64, target: []u8) Error!?[]u8 {68        var read = try self.rows.database.beginRead();69        defer read.deinit();70        const opened = try self.reader(read.snapshot());71        return try opened.getInto(rowid, target);72    }7374    pub fn delete(self: *Table, rowid: i64, options: file.CommitOptions) Error!file.Commit {75        const phase = trace.scope("table.delete");76        defer phase.end();7778        var write = try tree.Write.beginTree(&self.rows);79        defer write.deinit();80        try self.deleteIn(&write, rowid);81        return try write.commit(options);82    }8384    pub fn deleteIn(self: *Table, write: *tree.Write, rowid: i64) Error!void {85        var key_bytes: [key.rowid_size]u8 = undefined;86        try write.delete(&self.rows, try key.encodeRowId(&key_bytes, rowid));87    }8889    /// Starts a scan of the rows from `start` up to `end` in `target`.90    pub fn scan(91        self: *const Table,92        target: *Scan,93        allocator: Allocator,94        start: ?i64,95        end: ?i64,96    ) Error!void {97        try self.scanProjected(target, allocator, start, end, .value);98    }99100    pub fn scanProjected(101        self: *const Table,102        target: *Scan,103        allocator: Allocator,104        start: ?i64,105        end: ?i64,106        projection: Projection,107    ) Error!void {108        var read = try self.rows.database.beginRead();109        defer read.deinit();110        const opened = try self.reader(read.snapshot());111        try opened.scanProjected(target, allocator, start, end, projection);112    }113114    pub fn summarize(self: *const Table) Error!tree.Summary {115        var read = try self.rows.database.beginRead();116        defer read.deinit();117        const opened = try self.reader(read.snapshot());118        return try opened.summarize();119    }120121    pub fn count(self: *const Table) Error!usize {122        var read = try self.rows.database.beginRead();123        defer read.deinit();124        const opened = try self.reader(read.snapshot());125        return try opened.count();126    }127128    pub fn summarizeIn(self: *const Table, write: *const tree.Write) Error!tree.Summary {129        const phase = trace.scope("table.summarize_in");130        defer phase.end();131132        return try self.rows.summarizeIn(write);133    }134};

1pub const RowIdTable = table.Table;