Function transaction

packages/core/fumadb/src/adapters/drizzle/query.ts:405–430

(run)

      await query;
    },
    async transaction(run) {
      // Some SQLite-compatible engines (Cloudflare D1) reject interactive
      // transactions — both raw BEGIN/COMMIT and the driver's `.transaction()`.
      // When disabled, run the operations directly against the same connection:
      // each statement auto-commits, so there is no atomic rollback (the
      // engine's constraint, not ours). libSQL/Postgres keep real transactions.
      if (!interactiveTransactions) {
        return run(fromDrizzle(schema, _db, provider, interactiveTransactions, maxBoundParameters));
      }

      if (provider === "sqlite") {
        await executeRaw("BEGIN");
        try {
          const result = await run(fromDrizzle(schema, _db, provider, interactiveTransactions, maxBoundParameters));
          await executeRaw("COMMIT");
          return result;
        } catch (e) {
          await executeRaw("ROLLBACK");
          throw e;
        }
      }

      return db.transaction((tx) =>
        run(fromDrizzle(schema, tx, provider, interactiveTransactions, maxBoundParameters))
      );
    },
  });
}