execute() — drizzle-orm Function Reference

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

Function typescript DrizzleORM DatabaseDrivers called by 1

Entity Profile

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

Dependency Diagram

graph TD
  ca3aa3d1_6d7c_d183_8476_5322d34cdde5["execute()"]
  e574fe1d_06cd_6ecc_c962_0122e9875903["PglitePreparedQuery"]
  ca3aa3d1_6d7c_d183_8476_5322d34cdde5 -->|defined in| e574fe1d_06cd_6ecc_c962_0122e9875903
  5baf95e7_94fb_2adf_e658_9c8532475fac["transaction()"]
  5baf95e7_94fb_2adf_e658_9c8532475fac -->|calls| ca3aa3d1_6d7c_d183_8476_5322d34cdde5
  style ca3aa3d1_6d7c_d183_8476_5322d34cdde5 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

drizzle-orm/src/pglite/session.ts lines 82–102

	async execute(placeholderValues: Record<string, unknown> | undefined = {}): Promise<T['execute']> {
		const params = fillPlaceholders(this.params, placeholderValues);

		this.logger.logQuery(this.queryString, params);

		const { fields, client, queryConfig, joinsNotNullableMap, customResultMapper, queryString, rawQueryConfig } = this;

		if (!fields && !customResultMapper) {
			return this.queryWithCache(queryString, params, async () => {
				return await client.query<any[]>(queryString, params, rawQueryConfig);
			});
		}

		const result = await this.queryWithCache(queryString, params, async () => {
			return await client.query<any[]>(queryString, params, queryConfig);
		});

		return customResultMapper
			? customResultMapper(result.rows)
			: result.rows.map((row) => mapResultRow<T['execute']>(fields!, row, joinsNotNullableMap));
	}