データベーストランザクション：あなたの知識はおそらく間違っている

-- トランザクションA
BEGIN;
SELECT balance FROM accounts WHERE id = 1;  -- 1000を返す

-- トランザクションB（Aの読み取りの間にコミット）
UPDATE accounts SET balance = 500 WHERE id = 1;
COMMIT;

-- トランザクションAに戻る
SELECT balance FROM accounts WHERE id = 1;  -- 500を返す！
COMMIT;

// 危険：残高がチェックと更新の間に変わる可能性がある
var balance = await db.QuerySingleAsync<decimal>("SELECT balance FROM accounts WHERE id = @id", new { id });
if (balance >= amount)
{
    await db.ExecuteAsync("UPDATE accounts SET balance = balance - @amount WHERE id = @id", new { id, amount });
}
// 競合状態：SELECTとUPDATEの間に残高が変わった可能性がある

-- トランザクションA
BEGIN;
SELECT COUNT(*) FROM orders WHERE status = 'pending';  -- 10を返す

-- トランザクションB
INSERT INTO orders (status) VALUES ('pending');
COMMIT;

-- トランザクションAに戻る
SELECT COUNT(*) FROM orders WHERE status = 'pending';  -- 11を返す！
COMMIT;

BEGIN ISOLATION LEVEL SERIALIZABLE;

SELECT balance FROM accounts WHERE id = 1;
-- 並行する変更があれば、このトランザクションは中断される
UPDATE accounts SET balance = balance - 100 WHERE id = 1;

COMMIT;  -- 別のトランザクションがこのデータに触れていれば失敗

BEGIN;
SELECT balance FROM accounts WHERE id = 1 FOR UPDATE;
-- 行がロックされた。他のトランザクションは待機する。
UPDATE accounts SET balance = balance - 100 WHERE id = 1;
COMMIT;

BEGIN ISOLATION LEVEL REPEATABLE READ;
-- すべての読み取りはトランザクション開始時の一貫したスナップショットを見る
SELECT * FROM orders WHERE created_at > NOW() - INTERVAL '1 day';
SELECT * FROM order_items WHERE order_id IN (...);
-- クエリ中にデータが変わっても一貫性が保証される
COMMIT;

var ids = await db.QueryAsync<int>("SELECT id FROM products WHERE category = 'electronics'");
foreach (var batch in ids.Chunk(1000))
{
    await using var tx = await connection.BeginTransactionAsync();
    await db.ExecuteAsync(
        "UPDATE products SET price = price * 1.1 WHERE id = ANY(@ids)",
        new { ids = batch.ToArray() }
    );
    await tx.CommitAsync();
}

BEGIN;

INSERT INTO orders (customer_id, total) VALUES (1, 100);
-- 注文が作成された

SAVEPOINT before_items;

INSERT INTO order_items (order_id, product_id, quantity) VALUES (1, 999, 1);
-- おっと、製品999は存在しない、これは失敗するかもしれない

ROLLBACK TO SAVEPOINT before_items;
-- order_itemsの挿入だけがロールバックされる
-- ordersの挿入はまだ保留中

INSERT INTO order_items (order_id, product_id, quantity) VALUES (1, 1, 1);
-- 有効な製品で再試行

COMMIT;
-- 注文と修正されたアイテムの両方がコミットされる

// 悪い例：予測不可能なロック順序
foreach (var item in items.OrderBy(i => i.Price))
{
    await db.ExecuteAsync("UPDATE products SET stock = stock - 1 WHERE id = @id", new { id = item.Id });
}

// 良い例：予測可能なロック順序
foreach (var item in items.OrderBy(i => i.Id))
{
    await db.ExecuteAsync("UPDATE products SET stock = stock - 1 WHERE id = @id", new { id = item.Id });
}

// これはほとんどのドライバでトランザクションではない
await db.ExecuteAsync("UPDATE accounts SET balance = balance - 100 WHERE id = 1");
await db.ExecuteAsync("UPDATE accounts SET balance = balance + 100 WHERE id = 2");
// 2番目の文が失敗しても、1番目は既にコミットされている

await using var tx = await connection.BeginTransactionAsync();
// これで本当のトランザクション
await tx.CommitAsync();

await using var tx = await connection.BeginTransactionAsync();

var order = await CreateOrder(tx);
var paymentResult = await paymentApi.Charge(order.Total);  // StripeへのHTTP呼び出し！
// Stripeが遅い場合、トランザクションは数秒間オープン
// Stripeがタイムアウトした場合、コミットするかロールバックするか？

await tx.CommitAsync();

try
{
    await db.ExecuteAsync("INSERT INTO orders ...");
}
catch (Exception)
{
    // ログして続行
}
await db.ExecuteAsync("INSERT INTO order_items ...");
await tx.CommitAsync();
// 最初の挿入が失敗した場合、孤立したアイテムをコミットしている