Constructors
constructor
- new MigrationRunner(pgp: IDatabase<__type>, migrations: Migration[], schemaName?: string, skipSetup?: boolean): MigrationRunner
-
Parameters
-
pgp: IDatabase<__type>
-
-
Default value schemaName: string = "public"
-
Default value skipSetup: boolean = false
Properties
Private isSetUp
isSetUp: boolean = false
Protected pgp
pgp: IDatabase<__type>
Protected schemaName
schemaName: string
Methods
Protected applyMigration
- applyMigration(pgp: IDatabase<__type>, migration: Migration, sequenceName: string, blockNumber: number): Promise<void>
-
Parameters
-
pgp: IDatabase<__type>
-
-
sequenceName: string
-
blockNumber: number
Returns Promise<void>
Protected checkOrCreateSchema
- checkOrCreateSchema(): Promise<void>
Protected checkOrCreateTables
- checkOrCreateTables(): Promise<void>
Private checkSchema
- checkSchema(schema: string): Promise<void>
-
Parameters
Returns Promise<void>
Private checkTable
- checkTable(table: string): Promise<void>
-
Parameters
Returns Promise<void>
Private findDups
- findDups(arr: any[]): any
Private getMigrationHistory
- getMigrationHistory(): Promise<string[]>
-
Returns Promise<string[]>
Protected getUnappliedMigrations
- getUnappliedMigrations(initial?: boolean): Promise<Migration[]>
-
Parameters
-
Default value initial: boolean = false
Returns Promise<Migration[]>
Protected installCyanAudit
- installCyanAudit(): Promise<void>
migrate
- migrate(sequenceName?: string, blockNumber?: number, pgp?: IDatabase<__type>, initial?: boolean): Promise<void>
-
Parameters
-
Default value sequenceName: string = "default"
-
Default value blockNumber: number = 0
-
Default value pgp: IDatabase<__type> = this.pgp
-
Default value initial: boolean = false
Returns Promise<void>
Protected refreshCyanAudit
- refreshCyanAudit(pgp?: IDatabase<__type>): Promise<void>
-
Parameters
-
Default value pgp: IDatabase<__type> = this.pgp
Returns Promise<void>
Protected registerMigration
- registerMigration(pgp: IDatabase<__type>, migrationName: string, sequenceName: string, blockNumber: number): Promise<void>
-
Parameters
-
pgp: IDatabase<__type>
-
migrationName: string
-
sequenceName: string
-
blockNumber: number
Returns Promise<void>
Private throwIfNotSetup
- throwIfNotSetup(): Promise<void>
Private validateMigrationHistory
- validateMigrationHistory(migrationHistory: string[], initial?: boolean): void
-
Parameters
-
migrationHistory: string[]
-
Default value initial: boolean = false
Returns void