|
|
@ -54,16 +54,11 @@ export class MigrationService { |
|
|
|
// Run pending migrations in order
|
|
|
|
for (const migration of this.migrations) { |
|
|
|
if (!executedMigrations.has(migration.name)) { |
|
|
|
try { |
|
|
|
await sqlExec(migration.sql); |
|
|
|
await sqlExec("INSERT INTO migrations (name) VALUES (?)", [ |
|
|
|
migration.name, |
|
|
|
]); |
|
|
|
logger.log(`Migration ${migration.name} executed successfully`); |
|
|
|
} catch (error) { |
|
|
|
logger.error(`Error executing migration ${migration.name}:`, error); |
|
|
|
throw error; |
|
|
|
} |
|
|
|
await sqlExec(migration.sql); |
|
|
|
await sqlExec("INSERT INTO migrations (name) VALUES (?)", [ |
|
|
|
migration.name, |
|
|
|
]); |
|
|
|
logger.log(`Migration ${migration.name} executed successfully`); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|