2020-06-04 17:27:05 +02:00
|
|
|
import {Connection} from "mysql";
|
|
|
|
import MysqlConnectionManager from "./MysqlConnectionManager";
|
|
|
|
|
2020-04-22 15:52:17 +02:00
|
|
|
export default abstract class Migration {
|
|
|
|
public readonly version: number;
|
|
|
|
|
2020-07-24 12:13:28 +02:00
|
|
|
public constructor(version: number) {
|
2020-04-22 15:52:17 +02:00
|
|
|
this.version = version;
|
|
|
|
}
|
|
|
|
|
2020-07-24 12:13:28 +02:00
|
|
|
public async shouldRun(currentVersion: number): Promise<boolean> {
|
2020-04-22 15:52:17 +02:00
|
|
|
return this.version > currentVersion;
|
|
|
|
}
|
|
|
|
|
2020-07-24 12:13:28 +02:00
|
|
|
public abstract async install(connection: Connection): Promise<void>;
|
2020-06-04 17:27:05 +02:00
|
|
|
|
2020-07-24 12:13:28 +02:00
|
|
|
public abstract async rollback(connection: Connection): Promise<void>;
|
|
|
|
|
|
|
|
public abstract registerModels(): void;
|
2020-04-22 15:52:17 +02:00
|
|
|
|
2020-06-04 17:27:05 +02:00
|
|
|
protected async query(queryString: string, connection: Connection): Promise<void> {
|
|
|
|
await MysqlConnectionManager.query(queryString, undefined, connection);
|
|
|
|
}
|
2020-04-22 15:52:17 +02:00
|
|
|
}
|