Method run

packages/sql-pg/src/PgClient.ts:180–195

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

      }

      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({ cause: err, message: "Failed to execute statement" })))
            } 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,