Function #runQuery

packages/pglite/src/base.ts:210–284

* Internal method to execute a query * Not protected by the transaction mutex, so it can be used inside a transaction * @param query The query to execute * @param params Optional parameters for the query * @returns The result of the query

(
    query: string,
    params: any[] = [],
    options?: QueryOptions,
  )

   * @returns The result of the query
   */
  async #runQuery<T>(
    query: string,
    params: any[] = [],
    options?: QueryOptions,
  ): Promise<Results<T>> {
    return await this._runExclusiveQuery(async () => {
      // We need to parse, bind and execute a query with parameters
      this.#log('runQuery', query, params, options)
      await this._handleBlob(options?.blob)

      let results

      try {
        const { messages: parseResults } = await this.#execProtocolNoSync(
          serializeProtocol.parse({ text: query, types: options?.paramTypes }),
          options,
        )

        const dataTypeIDs = parseDescribeStatementResults(
          (
            await this.#execProtocolNoSync(
              serializeProtocol.describe({ type: 'S' }),
              options,
            )
          ).messages,
        )

        const values = params.map((param, i) => {
          const oid = dataTypeIDs[i]
          if (param === null || param === undefined) {
            return null
          }
          const serialize = options?.serializers?.[oid] ?? this.serializers[oid]
          if (serialize) {
            return serialize(param)
          } else {
            return param.toString()
          }
        })

        results = [
          ...parseResults,
          ...(
            await this.#execProtocolNoSync(
              serializeProtocol.bind({
                values,
              }),
              options,
            )
          ).messages,
          ...(
            await this.#execProtocolNoSync(
              serializeProtocol.describe({ type: 'P' }),
              options,
            )
          ).messages,
          ...(
            await this.#execProtocolNoSync(