tiny.smg.storage.database.read

1const std = @import("std");2const storage = @import("../root.zig");3const database = @import("root.zig");4const rows = storage.rows;56pub const GraphCounts = struct {7    nodes: usize,8    edges: usize,9};1011pub fn graphCounts(opened: *database.Database) database.Error!GraphCounts {12    return try catalogGraphCounts(&opened.connection.catalog, opened.allocator);13}1415pub fn readerGraphCounts(reader: *database.Reader) database.Error!GraphCounts {16    return try catalogGraphCounts(&reader.catalog, reader.allocator);17}1819pub fn databaseNodes(opened: *database.Database, row_allocator: std.mem.Allocator, value_allocator: std.mem.Allocator) database.Error![]rows.NodeRow {20    return try rows.scanNodeRows(&opened.connection.catalog, opened.allocator, row_allocator, value_allocator);21}2223pub fn databaseEdges(opened: *database.Database, row_allocator: std.mem.Allocator, value_allocator: std.mem.Allocator) database.Error![]rows.EdgeRow {24    return try rows.scanEdgeRows(&opened.connection.catalog, opened.allocator, row_allocator, value_allocator);25}2627pub fn databaseConceptDocuments(opened: *database.Database, row_allocator: std.mem.Allocator, value_allocator: std.mem.Allocator) database.Error![]rows.ConceptDocumentRow {28    return try rows.scanConceptDocumentRows(&opened.connection.catalog, opened.allocator, row_allocator, value_allocator);29}3031pub fn readerNodes(reader: *database.Reader, row_allocator: std.mem.Allocator, value_allocator: std.mem.Allocator) database.Error![]rows.NodeRow {32    return try rows.scanNodeRows(&reader.catalog, reader.allocator, row_allocator, value_allocator);33}3435pub fn readerEdges(reader: *database.Reader, row_allocator: std.mem.Allocator, value_allocator: std.mem.Allocator) database.Error![]rows.EdgeRow {36    return try rows.scanEdgeRows(&reader.catalog, reader.allocator, row_allocator, value_allocator);37}3839pub fn readerConceptDocuments(reader: *database.Reader, row_allocator: std.mem.Allocator, value_allocator: std.mem.Allocator) database.Error![]rows.ConceptDocumentRow {40    return try rows.scanConceptDocumentRows(&reader.catalog, reader.allocator, row_allocator, value_allocator);41}4243pub fn readerNodesInto(reader: *database.Reader, value_allocator: std.mem.Allocator, out: []rows.NodeRow) database.Error!void {44    try rows.scanNodeRowsInto(&reader.catalog, reader.allocator, value_allocator, out);45}4647pub fn readerEdgesInto(reader: *database.Reader, value_allocator: std.mem.Allocator, out: []rows.EdgeRow) database.Error!void {48    try rows.scanEdgeRowsInto(&reader.catalog, reader.allocator, value_allocator, out);49}5051fn catalogGraphCounts(catalog: anytype, allocator: std.mem.Allocator) database.Error!GraphCounts {52    return .{53        .nodes = try relationCount(54            catalog,55            allocator,56            rows.nodes_relation,57        ),58        .edges = try relationCount(59            catalog,60            allocator,61            rows.edges_relation,62        ),63    };64}6566fn relationCount(67    catalog: anytype,68    allocator: std.mem.Allocator,69    name: []const u8,70) database.Error!usize {71    var handle = catalog.openRelation(allocator, name) catch |err| switch (err) {72        error.RelationNotFound => return 0,73        else => return err,74    };75    defer handle.deinit();76    return try handle.relation.table.count();77}

1pub const read = @import("read.zig");