tiny.smg.storage.database.edits

1const sql = @import("sql");2const storage = @import("../root.zig");3const database = @import("root.zig");4const rows = storage.rows;56pub fn apply(opened: *database.Database, edits: rows.GraphEdits) database.Error!void {7    if (edits.isEmpty()) return;8    var node_session: ?sql.RelationSession = null;9    defer if (node_session) |*session| session.deinit();10    if (edits.node_puts.len != 0 or edits.node_deletes.len != 0) {11        var session = try sql.RelationSession.open(opened.allocator, &opened.connection.catalog, rows.nodes_relation);12        errdefer session.deinit();13        for (edits.node_puts) |put| try rows.putNodeRow(opened.allocator, &session, put.rowid, put.node);14        for (edits.node_deletes) |rowid| try session.delete(rowid);15        node_session = session;16    }17    var edge_session: ?sql.RelationSession = null;18    defer if (edge_session) |*session| session.deinit();19    if (edits.edge_puts.len != 0 or edits.edge_deletes.len != 0) {20        var session = try sql.RelationSession.open(opened.allocator, &opened.connection.catalog, rows.edges_relation);21        errdefer session.deinit();22        for (edits.edge_puts) |put| try rows.putEdgeRow(opened.allocator, &session, put.rowid, put.edge);23        for (edits.edge_deletes) |rowid| try session.delete(rowid);24        edge_session = session;25    }26    var concept_session: ?sql.RelationSession = null;27    defer if (concept_session) |*session| session.deinit();28    if (edits.concept_document_puts.len != 0 or edits.concept_document_deletes.len != 0) {29        var session = try sql.RelationSession.open(opened.allocator, &opened.connection.catalog, rows.concept_documents_relation);30        errdefer session.deinit();31        for (edits.concept_document_deletes) |rowid| try session.delete(rowid);32        for (edits.concept_document_puts) |put| try rows.putConceptDocumentRow(&session, put);33        concept_session = session;34    }3536    var limits = sql.DatabaseWrite.Limits{37        .relations = 0,38        .edits = 0,39        .payload_bytes = 0,40        .assignments = 0,41    };42    if (node_session) |*session| limits = try limits.combine(try session.stagingLimits());43    if (edge_session) |*session| limits = try limits.combine(try session.stagingLimits());44    if (concept_session) |*session| limits = try limits.combine(try session.stagingLimits());45    var workspace = try sql.DatabaseWrite.Workspace.allocate(46        opened.allocator,47        limits,48    );49    defer workspace.deallocate(opened.allocator);50    var write = try opened.connection.beginWrite(&workspace, opened.allocator, .{51        .limits = limits,52        .durability = .buffered,53    });54    var write_live = true;55    errdefer if (write_live) write.deinit();56    if (node_session) |*session| {57        try write.stageRelation(session);58        node_session = null;59    }60    if (edge_session) |*session| {61        try write.stageRelation(session);62        edge_session = null;63    }64    if (concept_session) |*session| {65        try write.stageRelation(session);66        concept_session = null;67    }68    var flush = try write.flush();69    write_live = false;70    flush.deinit();71}

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