Method #ensureBegun

packages/adapter-ppg/src/ppg.ts:141–156

()

  }

  async #ensureBegun(): Promise<void> {
    if (this.#begun) return

    let beginSql = 'BEGIN'
    if (this.#isolationLevel) {
      beginSql += ` ISOLATION LEVEL ${isolationLevelToSql(this.#isolationLevel)}`
    }

    try {
      await this.#session.query(beginSql)
      this.#begun = true
    } catch (error) {
      this.#session.close()
      throw convertDriverError(error)
    }
  }

  async commit(): Promise<void> {
    if (this.#finished) {