onMutate() — drizzle-orm Function Reference

Architecture documentation for the onMutate() function in mysql-common-cache.ts from the drizzle-orm codebase.

Function typescript DrizzleORM SQLDialects

Entity Profile

DrizzleORM→ SQLDialects→ onMutate() — drizzle-orm Function Reference

Dependency Diagram

graph TD
  2d31e9c7_3522_1366_3101_c4a3b8e55741["onMutate()"]
  208fff58_f804_2a07_330d_076472ff343f["TestGlobalCache"]
  2d31e9c7_3522_1366_3101_c4a3b8e55741 -->|defined in| 208fff58_f804_2a07_330d_076472ff343f
  style 2d31e9c7_3522_1366_3101_c4a3b8e55741 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

integration-tests/tests/mysql/mysql-common-cache.ts lines 43–68

	override async onMutate(params: MutationOption): Promise<void> {
		const tagsArray = params.tags ? Array.isArray(params.tags) ? params.tags : [params.tags] : [];
		const tablesArray = params.tables ? Array.isArray(params.tables) ? params.tables : [params.tables] : [];

		const keysToDelete = new Set<string>();

		for (const table of tablesArray) {
			const tableName = is(table, Table) ? getTableName(table) : table as string;
			const keys = this.usedTablesPerKey[tableName] ?? [];
			for (const key of keys) keysToDelete.add(key);
		}

		if (keysToDelete.size > 0 || tagsArray.length > 0) {
			for (const tag of tagsArray) {
				await this.kv.delete(tag);
			}

			for (const key of keysToDelete) {
				await this.kv.delete(key);
				for (const table of tablesArray) {
					const tableName = is(table, Table) ? getTableName(table) : table as string;
					this.usedTablesPerKey[tableName] = [];
				}
			}
		}
	}