Method execute

packages/sql/src/SqlEntityManager.ts:150–176

(
    query: string | NativeQueryBuilder | RawQueryFragment,
    params: any[] = [],
    methodOrOptions: 'all' | 'get' | 'run' | EmExecuteOptions = 'all',
    loggerContext?: LoggingOptions,
  )

    options: EmExecuteOptions,
  ): Promise<T>;
  async execute<T extends QueryResult | EntityData<AnyEntity> | EntityData<AnyEntity>[] = EntityData<AnyEntity>[]>(
    query: string | NativeQueryBuilder | RawQueryFragment,
    params: any[] = [],
    methodOrOptions: 'all' | 'get' | 'run' | EmExecuteOptions = 'all',
    loggerContext?: LoggingOptions,
  ): Promise<T> {
    const opts: EmExecuteOptions =
      typeof methodOrOptions === 'string' ? { method: methodOrOptions, loggerContext } : methodOrOptions;
    const context = this.getContext(false);
    // Per-field fallback to fork-level abort, matching `EntityManager.prepareOptions` semantics.
    const fork = context.getAbortOptions();
    const hasAbort = opts.signal != null || opts.inflightQueryAbortStrategy != null || fork != null;
    // Connection layer carries abort piggy-backed on `loggerContext`; merge only when needed.
    const merged: (LoggingOptions & Partial<AbortQueryOptions>) | undefined =
      hasAbort || opts.loggerContext ? { ...(opts.loggerContext as Dictionary | undefined) } : undefined;
    if (merged && hasAbort) {
      merged.signal = opts.signal ?? fork?.signal;
      merged.inflightQueryAbortStrategy = opts.inflightQueryAbortStrategy ?? fork?.inflightQueryAbortStrategy;
    }
    return this.getDriver().execute(
      query,
      params,
      opts.method ?? 'all',
      context.getTransactionContext(),
      merged,
    ) as Promise<T>;
  }

  /**
   * @inheritDoc