FM / d1

/opt/canhelp/node_modules/drizzle-orm/d1/

/opt/canhelp/node_modules/drizzle-orm/d1

Name	Size	Mode	Actions
driver.cjs	2439	0644	edit dl rm
driver.cjs.map	3429	0644	edit dl rm
driver.d.cts	1025	0644	edit dl rm
driver.d.ts	1021	0644	edit dl rm
driver.js	1336	0644	edit dl rm
driver.js.map	3427	0644	edit dl rm
index.cjs	1197	0644	edit dl rm
index.cjs.map	216	0644	edit dl rm
index.d.cts	61	0644	edit dl rm
index.d.ts	59	0644	edit dl rm
index.js	92	0644	edit dl rm
index.js.map	177	0644	edit dl rm
migrator.cjs	2471	0644	edit dl rm
migrator.cjs.map	2541	0644	edit dl rm
migrator.d.cts	257	0644	edit dl rm
migrator.d.ts	255	0644	edit dl rm
migrator.js	1334	0644	edit dl rm
migrator.js.map	2505	0644	edit dl rm
session.cjs	7444	0644	edit dl rm
session.cjs.map	13557	0644	edit dl rm
session.d.cts	3381	0644	edit dl rm
session.d.ts	3371	0644	edit dl rm
session.js	6073	0644	edit dl rm
session.js.map	13536	0644	edit dl rm

Edit: /opt/canhelp/node_modules/drizzle-orm/d1/migrator.js (1334B)

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(${sql.raw(`'${migration.hash}'`)}, ${sql.raw(`${migration.folderMillis}`)})`
        )
      );
    }
  }
  if (statementToBatch.length > 0) {
    await db.session.batch(statementToBatch);
  }
}
export {
  migrate
};
//# sourceMappingURL=migrator.js.map

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(${sql.raw(`'${migration.hash}'`)}, ${sql.raw(`${migration.folderMillis}`)})` ) ); } } if (statementToBatch.length > 0) { await db.session.batch(statementToBatch); } } export { migrate }; //# sourceMappingURL=migrator.js.map