Method run

packages/sql/pg/src/PgClient.ts:666–683

(query: string, params: ReadonlyArray<unknown>)

  private readonly reserve: Effect.Effect<Pg.ClientBase, SqlError, Scope.Scope>

  private run(query: string, params: ReadonlyArray<unknown>) {
    return this.runWithClient<ReadonlyArray<any>>((client, resume) => {
      client.query(query, params as any, (err, result) => {
        if (err) {
          resume(
            Effect.fail(new SqlError({ reason: classifyError(err, "Failed to execute statement", "execute") }))
          )
        } else {
          // Multi-statement queries return an array of results
          resume(Effect.succeed(
            Array.isArray(result)
              ? result.map((r) => r.rows ?? [])
              : result.rows ?? []
          ))
        }
      })
    })
  }

  execute(
    sql: string,