Method executeRaw

cli/api/dbadapters/bigquery.ts:132–155

(
    statement: string,
    options: {
      params?: { [name: string]: any };
      rowLimit?: number;
      bigquery?: IBigQueryExecutionOptions;
    } = { rowLimit: 1000 }
  )

  }

  public async executeRaw(
    statement: string,
    options: {
      params?: { [name: string]: any };
      rowLimit?: number;
      bigquery?: IBigQueryExecutionOptions;
    } = { rowLimit: 1000 }
  ): Promise<IExecutionResultRaw> {
    if (!statement) {
      throw new Error("Query string cannot be empty");
    }
    return this.pool
      .addSingleTask({
        generator: async () => {
          const [rows, , apiResponse] = await this.getClient().query({
            ...this.prepareQueryOptions(statement, options.rowLimit, options.bigquery, options.params),
            skipParsing: true
          } as any);
          const schema = apiResponse?.schema?.fields?.map((field: any) => convertField(field));
          return { rows, schema, metadata: {} };
        }
      })
      .promise();
  }

  public async withClientLock<T>(callback: (client: IDbClient) => Promise<T>) {
    return await callback(this);