Method query

packages/query-plan-executor/src/logic/app.ts:85–120

* Executes a query plan and returns the result. * * @param queryPlan - The query plan to execute * @param scope - Placeholder values for the query * @param comments - Pre-computed SQL commenter tags from the client * @param resourceLimits - Resource limits for the query * @param tr

(
    queryPlan: QueryPlanNode,
    scope: Record<string, unknown>,
    comments: Record<string, string> | undefined,
    resourceLimits: ResourceLimits,
    transactionId: string | null,
  )

   * @param transactionId - Transaction ID if running within a transaction
   */
  async query(
    queryPlan: QueryPlanNode,
    scope: Record<string, unknown>,
    comments: Record<string, string> | undefined,
    resourceLimits: ResourceLimits,
    transactionId: string | null,
  ): Promise<unknown> {
    const queryable =
      transactionId !== null ? await this.#transactionManager.getTransaction({ id: transactionId }, 'query') : this.#db

    // Create constant commenter plugin if comments were provided
    const sqlCommenter: QueryInterpreterSqlCommenter | undefined =
      comments && Object.keys(comments).length > 0
        ? {
            plugins: [() => comments],
            // For pre-computed comments, we use a placeholder queryInfo since the actual
            // query info was already used on the client side to compute the comments
            queryInfo: { type: 'single', action: 'queryRaw', query: {} },
          }
        : undefined

    const result = await Promise.race([
      this.#interpreter.run(queryPlan, {
        queryable,
        transactionManager:
          transactionId === null ? { enabled: true, manager: this.#transactionManager } : { enabled: false },
        scope,
        sqlCommenter,
      }),
      timers.setTimeout(resourceLimits.queryTimeout.total('milliseconds'), undefined, { ref: false }).then(() => {
        throw new ResourceLimitError('Query timeout exceeded')
      }),
    ])

    return normalizeJsonProtocolValues(result)
  }

  /**
   * Starts a new transaction.