/
ai_sampletext
/
DiplomWork
Обзор
Документация
Войти
/
ai_sampletext
/
DiplomWork
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
node_modules/drizzle-orm/libsql/migrator.js
36 строк
1 KB
boolyshareyo
Initial commit
08 июн 2026, 16:00
08 июн 2026, 16:00
6216a29
Код
Авторство
О чём код?
import { readMigrationFiles } from "../migrator.js"; import { sql } from "../sql/sql.js"; async function migrate(db, config) { const migrations = readMigrationFiles(config); const migrationsTable = config.migrationsTable ?? "__drizzle_migrations"; const migrationTableCreate = sql` CREATE TABLE IF NOT EXISTS ${sql.identifier(migrationsTable)} ( id SERIAL PRIMARY KEY, hash text NOT NULL, created_at numeric ) `; await db.session.run(migrationTableCreate); const dbMigrations = await db.values( sql`SELECT id, hash, created_at FROM ${sql.identifier(migrationsTable)} ORDER BY created_at DESC LIMIT 1` ); const lastDbMigration = dbMigrations[0] ?? void 0; const statementToBatch = []; for (const migration of migrations) { if (!lastDbMigration || Number(lastDbMigration[2]) < migration.folderMillis) { for (const stmt of migration.sql) { statementToBatch.push(db.run(sql.raw(stmt))); } statementToBatch.push( db.run( sql`INSERT INTO ${sql.identifier(migrationsTable)} ("hash", "created_at") VALUES(${migration.hash}, ${migration.folderMillis})` ) ); } } await db.session.migrate(statementToBatch); } export { migrate }; //# sourceMappingURL=migrator.js.map