transaction() — drizzle-orm Function Reference

Architecture documentation for the transaction() function in session.ts from the drizzle-orm codebase.

Function typescript DrizzleORM DatabaseDrivers calls 2 called by 1

Entity Profile

DrizzleORM→ DatabaseDrivers→ transaction() — drizzle-orm Function Reference

Dependency Diagram

graph TD
  bd152654_7670_2106_bc9f_e0113b3e1db9["transaction()"]
  29288e7e_0269_7fe1_90be_3d868ffe5de0["NeonTransaction"]
  bd152654_7670_2106_bc9f_e0113b3e1db9 -->|defined in| 29288e7e_0269_7fe1_90be_3d868ffe5de0
  0df49818_fd3d_7eaf_026f_4bb7ca00ab17["transaction()"]
  0df49818_fd3d_7eaf_026f_4bb7ca00ab17 -->|calls| bd152654_7670_2106_bc9f_e0113b3e1db9
  afed55a9_87b6_c85c_1288_688d4915117f["execute()"]
  bd152654_7670_2106_bc9f_e0113b3e1db9 -->|calls| afed55a9_87b6_c85c_1288_688d4915117f
  0df49818_fd3d_7eaf_026f_4bb7ca00ab17["transaction()"]
  bd152654_7670_2106_bc9f_e0113b3e1db9 -->|calls| 0df49818_fd3d_7eaf_026f_4bb7ca00ab17
  style bd152654_7670_2106_bc9f_e0113b3e1db9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

drizzle-orm/src/neon-serverless/session.ts lines 290–302

	override async transaction<T>(transaction: (tx: NeonTransaction<TFullSchema, TSchema>) => Promise<T>): Promise<T> {
		const savepointName = `sp${this.nestedIndex + 1}`;
		const tx = new NeonTransaction<TFullSchema, TSchema>(this.dialect, this.session, this.schema, this.nestedIndex + 1);
		await tx.execute(sql.raw(`savepoint ${savepointName}`));
		try {
			const result = await transaction(tx);
			await tx.execute(sql.raw(`release savepoint ${savepointName}`));
			return result;
		} catch (e) {
			await tx.execute(sql.raw(`rollback to savepoint ${savepointName}`));
			throw e;
		}
	}