54 lines
2.1 KiB
TypeScript
54 lines
2.1 KiB
TypeScript
import { MigrationInterface, QueryRunner, Table } from "typeorm";
|
|
import InternalException from "../exceptions/internalException";
|
|
import BackupHelper from "../helpers/backupHelper";
|
|
import { getTypeByORM, isIncrementPrimary, getDefaultByORM } from "./ormHelper";
|
|
|
|
export class BackupAndResetDatabase1749296262915 implements MigrationInterface {
|
|
name = "BackupAndResetDatabase1749296262915";
|
|
|
|
public async up(queryRunner: QueryRunner): Promise<void> {
|
|
let migrations = await queryRunner.query("SELECT name FROM migrations");
|
|
if (
|
|
(await queryRunner.hasTable("user")) &&
|
|
migrations.findIndex((m: any) => m.name == "MemberExtendData1748953828644") == -1
|
|
) {
|
|
throw new InternalException(
|
|
"Cannot update due to skiped version. Update to v1.6.0 Version first to prevent data loss and get access to the newer Versions."
|
|
);
|
|
}
|
|
|
|
if (await queryRunner.hasTable("user")) {
|
|
await BackupHelper.createBackup({ collectIds: false });
|
|
}
|
|
await queryRunner.clearDatabase();
|
|
|
|
await queryRunner.createTable(
|
|
new Table({
|
|
name: "migrations",
|
|
columns: [
|
|
{ name: "id", ...getTypeByORM("int"), ...isIncrementPrimary },
|
|
{ name: "timestamp", ...getTypeByORM("bigint") },
|
|
{ name: "name", ...getTypeByORM("varchar") },
|
|
],
|
|
}),
|
|
true
|
|
);
|
|
|
|
await queryRunner.createTable(
|
|
new Table({
|
|
name: "typeorm_metadata",
|
|
columns: [
|
|
{ name: "type", ...getTypeByORM("varchar") },
|
|
{ name: "database", ...getTypeByORM("varchar", true), default: getDefaultByORM("null") },
|
|
{ name: "schema", ...getTypeByORM("varchar", true), default: getDefaultByORM("null") },
|
|
{ name: "table", ...getTypeByORM("varchar", true), default: getDefaultByORM("null") },
|
|
{ name: "name", ...getTypeByORM("varchar", true), default: getDefaultByORM("null") },
|
|
{ name: "value", ...getTypeByORM("text", true), default: getDefaultByORM("null") },
|
|
],
|
|
}),
|
|
true
|
|
);
|
|
}
|
|
|
|
public async down(queryRunner: QueryRunner): Promise<void> {}
|
|
}
|