readMigrationFiles() — drizzle-orm Function Reference

Architecture documentation for the readMigrationFiles() function in migrator.ts from the drizzle-orm codebase.

Function typescript DrizzleORM SQLDialects called by 1

Entity Profile

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

Dependency Diagram

graph TD
  a11a46ec_ad0f_bc02_ae19_8353b0190f09["readMigrationFiles()"]
  0e92b232_8d9a_aa9d_3673_15b989e5e855["migrator.ts"]
  a11a46ec_ad0f_bc02_ae19_8353b0190f09 -->|defined in| 0e92b232_8d9a_aa9d_3673_15b989e5e855
  0f158df0_ad98_5b1b_6efc_788f1c0477cf["migrate()"]
  0f158df0_ad98_5b1b_6efc_788f1c0477cf -->|calls| a11a46ec_ad0f_bc02_ae19_8353b0190f09
  style a11a46ec_ad0f_bc02_ae19_8353b0190f09 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

drizzle-orm/src/expo-sqlite/migrator.ts lines 12–39

async function readMigrationFiles({ journal, migrations }: MigrationConfig): Promise<MigrationMeta[]> {
	const migrationQueries: MigrationMeta[] = [];

	for await (const journalEntry of journal.entries) {
		const query = migrations[`m${journalEntry.idx.toString().padStart(4, '0')}`];

		if (!query) {
			throw new Error(`Missing migration: ${journalEntry.tag}`);
		}

		try {
			const result = query.split('--> statement-breakpoint').map((it) => {
				return it;
			});

			migrationQueries.push({
				sql: result,
				bps: journalEntry.breakpoints,
				folderMillis: journalEntry.when,
				hash: '',
			});
		} catch {
			throw new Error(`Failed to parse migration: ${journalEntry.tag}`);
		}
	}

	return migrationQueries;
}