transaction() — drizzle-orm Function Reference

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

Function typescript DrizzleORM SchemaDefinitions calls 1 called by 1

Entity Profile

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

Dependency Diagram

graph TD
  9cf8769a_3525_edaa_da2d_2dd8178f00fe["transaction()"]
  f805b419_0d99_6c9e_b545_711ef568e8d9["TiDBServerlessSession"]
  9cf8769a_3525_edaa_da2d_2dd8178f00fe -->|defined in| f805b419_0d99_6c9e_b545_711ef568e8d9
  5d48132d_b5b9_3197_a6a8_8a5b72503bc8["transaction()"]
  5d48132d_b5b9_3197_a6a8_8a5b72503bc8 -->|calls| 9cf8769a_3525_edaa_da2d_2dd8178f00fe
  5d48132d_b5b9_3197_a6a8_8a5b72503bc8["transaction()"]
  9cf8769a_3525_edaa_da2d_2dd8178f00fe -->|calls| 5d48132d_b5b9_3197_a6a8_8a5b72503bc8
  style 9cf8769a_3525_edaa_da2d_2dd8178f00fe fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

drizzle-orm/src/tidb-serverless/session.ts lines 173–191

	override async transaction<T>(
		transaction: (tx: TiDBServerlessTransaction<TFullSchema, TSchema>) => Promise<T>,
	): Promise<T> {
		const nativeTx = await this.baseClient.begin();
		try {
			const session = new TiDBServerlessSession(this.baseClient, this.dialect, nativeTx, this.schema, this.options);
			const tx = new TiDBServerlessTransaction<TFullSchema, TSchema>(
				this.dialect,
				session as MySqlSession<any, any, any, any>,
				this.schema,
			);
			const result = await transaction(tx);
			await nativeTx.commit();
			return result;
		} catch (err) {
			await nativeTx.rollback();
			throw err;
		}
	}