027 db transaction pattern

✓ Passing This code compiles and runs correctly.

Code

~import std/control
~import app/db
const query_succeeded = true;
~app/db:connect(url: "postgres://localhost/test"): c |> app/db:query(conn: c, sql: "SELECT * FROM users"): tx |> if(query_succeeded)
        | then |> app/db:commit(tx) |> app/db:disconnect(conn: c)
        | else |> app/db:rollback(tx) |> app/db:disconnect(conn: c)

input.kz

Actual

Connecting to: postgres://localhost/test
Query: SELECT * FROM users
Committing transaction
Disconnecting

Expected output

Connecting to: postgres://localhost/test
Query: SELECT * FROM users
Committing transaction
Disconnecting

Flows

flow ~connect click a branch to expand · @labels scroll to their anchor

connect (url: "postgres://localhost/test")

Imported Files

// Library module: db
// Database operations with layered cleanup obligations
//
// Pattern: connect → query → (commit OR rollback) → disconnect
// Two obligations:
//   1. connected! on Connection - must call disconnect
//   2. transaction! on Transaction - must call commit or rollback

const std = @import("std");

const Connection = struct {
    id: i32,
};

const Transaction = struct {
    conn: *Connection,
};

// Connect to database - creates connected! obligation
~pub tor connect { url: string } -> *Connection<connected!>

~proc connect|zig {
    std.debug.print("Connecting to: {s}\n", .{url});
    const allocator = std.heap.page_allocator;
    const c = allocator.create(Connection) catch unreachable;
    c.* = Connection{ .id = 1 };
    return c;
}

// Start a query/transaction - creates transaction! obligation
// The connection must be in [connected] state (required, but not consumed)
// The connected! obligation is tracked separately and discharged by disconnect()
~pub tor query { conn: *Connection<connected>, sql: string } -> *Transaction<transaction!>

~proc query|zig {
    std.debug.print("Query: {s}\n", .{sql});
    const allocator = std.heap.page_allocator;
    const t = allocator.create(Transaction) catch unreachable;
    t.* = Transaction{ .conn = conn };
    return t;
}

// Commit - CONSUMES transaction! obligation
~pub tor commit { tx: *Transaction<!transaction> }

~proc commit|zig {
    std.debug.print("Committing transaction\n", .{});
}

// Rollback - CONSUMES transaction! obligation (alternative to commit)
~pub tor rollback { tx: *Transaction<!transaction> }

~proc rollback|zig {
    std.debug.print("Rolling back transaction\n", .{});
}

// Disconnect - CONSUMES connected! obligation
~pub tor disconnect { conn: *Connection<!connected> }

~proc disconnect|zig {
    std.debug.print("Disconnecting\n", .{});
}

db.kz

Test Configuration

MUST_RUN

← 026 auto discharge warn 028 ambiguous without default →