executeStreamingSql method

Future<PartialResultSet> executeStreamingSql(
  1. ExecuteSqlRequest request,
  2. String session, {
  3. String? $fields,
})

Like ExecuteSql, except returns the result set as a stream.

Unlike ExecuteSql, there is no limit on the size of the returned result set. However, no individual row in the result set can exceed 100 MiB, and no column value can exceed 10 MiB.

request - The metadata request object.

Request parameters:

session - Required. The session in which the SQL query should be performed. Value must have pattern ^projects/\[^/\]+/instances/\[^/\]+/databases/\[^/\]+/sessions/\[^/\]+$.

$fields - Selector specifying which fields to include in a partial response.

Completes with a PartialResultSet.

Completes with a commons.ApiRequestError if the API endpoint returned an error.

If the used http.Client completes with an error when making a REST call, this method will complete with the same error.

Implementation

async.Future<PartialResultSet> executeStreamingSql(
  ExecuteSqlRequest request,
  core.String session, {
  core.String? $fields,
}) async {
  final body_ = convert.json.encode(request);
  final queryParams_ = <core.String, core.List<core.String>>{
    if ($fields != null) 'fields': [$fields],
  };

  final url_ =
      'v1/' + core.Uri.encodeFull('$session') + ':executeStreamingSql';

  final response_ = await _requester.request(
    url_,
    'POST',
    body: body_,
    queryParams: queryParams_,
  );
  return PartialResultSet.fromJson(
      response_ as core.Map<core.String, core.dynamic>);
}