Function doExecuteSql

console/src/api/materialize/executeSql.tsx:102–196

(
  environmentdHttpAddress: string,
  request: SqlRequest,
  requestOptions?: RequestInit,
)

}

const doExecuteSql = async (
  environmentdHttpAddress: string,
  request: SqlRequest,
  requestOptions?: RequestInit,
): Promise<ExecuteSqlOutput> => {
  const url = buildExecuteSqlUrl(environmentdHttpAddress);
  // Optional session vars that will be set before running the request.
  //
  // Note: the JSON object is automatically URI encoded by the URL object.
  const options = buildSessionVariables({
    cluster: request.cluster,
    cluster_replica: request.replica,
    transaction_isolation:
      request.transactionIsolation ?? "strict serializable",
  });
  url.searchParams.append("options", JSON.stringify(options));

  const { headers, ...requestOpts } = requestOptions ?? {};
  const response = await apiClient.mzApiFetch(
    new Request(url.toString(), {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        ...headers,
      },
      body: JSON.stringify({
        queries: request.queries,
      }),
      ...requestOpts,
    }),
  );

  const responseText = await response.text();

  if (!response.ok) {
    if (response.status === 401) {
      throw new Error(UNAUTHORIZED_ERROR);
    }
    if (response.status === 403 && isJsonObject(responseText)) {
      const responseError = JSON.parse(responseText);
      return {
        errorMessage: responseError.message,
        code: responseError.code,
        detail: responseError.detail,
        status: response.status,
      };
    }
    return {
      status: response.status,
      errorMessage: responseText || DEFAULT_QUERY_ERROR,
    };
  } else {
    const parsedResponse = JSON.parse(responseText);
    const { results } = parsedResponse;
    const outResults = [];
    for (const oneResult of results) {
      // Queries like `CREATE TABLE` or `CREATE CLUSTER` returns a null inside the results array
      const { error: resultsError, rows } = oneResult || {};