npm package diff
Package: @forge/sql
Versions: 2.2.0-next.2 - 2.2.0-next.3
File: package/out/migration.js
Index: package/out/migration.js
===================================================================
--- package/out/migration.js
+++ package/out/migration.js
@@ -1,9 +1,9 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.migrationRunner = exports.MigrationRunner = void 0;
const sql_1 = require("./sql");
-const response_handler_1 = require("./utils/response-handler");
+const errors_1 = require("./errors");
const SCHEMA_VERSION_TABLE_CREATE_QUERY = 'CREATE TABLE IF NOT EXISTS __migrations (id BIGINT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(255) NOT NULL, migratedAt TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP);';
const INSERT_SCHEMA_VERSION_QUERY = 'INSERT INTO __migrations (name) VALUES (?);';
const LIST_MIGRATIONS_QUERY = 'SELECT id, name, migratedAt FROM __migrations;';
class MigrationRunner {
@@ -46,15 +46,15 @@
try {
await this.sqlClient.executeRaw(migration.statement);
}
catch (error) {
- throw new response_handler_1.MigrationExecutionError(migration.name, migrationsToRun.map((m) => m.name));
+ throw new errors_1.MigrationExecutionError(migration.name, migrationsToRun.map((m) => m.name));
}
try {
await this.sqlClient.prepare(INSERT_SCHEMA_VERSION_QUERY).bindParams(migration.name).execute();
}
catch (error) {
- throw new response_handler_1.MigrationCheckPointError(migration.name, migrationsToRun.map((m) => m.name));
+ throw new errors_1.MigrationCheckPointError(migration.name, migrationsToRun.map((m) => m.name));
}
migrationsSuccessfullyRun.push(migration.name);
}
return migrationsSuccessfullyRun;