Function query

packages/sql/pg/test/Client.integration.test.ts:464–469

(sql: string, _params: ReadonlyArray<unknown>, callback: (error: null, result: unknown) => void)

      on() {},
      off() {},
      query(sql: string, _params: ReadonlyArray<unknown>, callback: (error: null, result: unknown) => void) {
        if (sql === "BEGIN" && ++beginCalls === 2) {
          Deferred.doneUnsafe(secondBegin, Effect.void)
        }
        callback(null, { rows: [] })
      }
    }

    const sql = yield* PgClient.fromClient({