Method run

packages/migrations/src/MigrationRunner.ts:21–56

(
    migration: Migration,
    method: 'up' | 'down',
    afterRun?: (tx?: Transaction) => Promise<void>,
  )

  }

  async run(
    migration: Migration,
    method: 'up' | 'down',
    afterRun?: (tx?: Transaction) => Promise<void>,
  ): Promise<void> {
    migration.reset();

    if (!this.options.transactional || !migration.isTransactional()) {
      // Without a pinned transaction the set/reset statements may land on different pooled
      // connections than the DDL, so refuse rather than silently running in the default schema.
      if (this.#runSchema) {
        throw new Error(
          'Runtime schema (migrations.schema / migrator.up({ schema })) is only supported with transactional migrations',
        );
      }

      const queries = await this.getQueries(migration, method);
      await Utils.runSerial(queries, sql => this.driver.execute(sql));
      await afterRun?.();
    } else {
      await this.#connection.transactional(
        async tx => {
          migration.setTransactionContext(tx);

          try {
            const queries = await this.getQueries(migration, method);
            await Utils.runSerial(queries, sql => this.driver.execute(sql, undefined, 'all', tx));
            await afterRun?.(tx);
          } finally {
            await this.resetSessionSchema(tx);
          }
        },
        { ctx: this.#masterTransaction },
      );
    }
  }

  private async resetSessionSchema(ctx?: Transaction): Promise<void> {
    if (!this.#runSchema) {