feat: clean cached rows and responses after conversion

src/bigquery.ts

@@ -362,17 +362,17 @@
   private _universeDomain: string;
   private _enableQueryPreview: boolean;
 
   createQueryStream(options?: Query | string): ResourceStream<RowMetadata> {
     // placeholder body, overwritten in constructor
     return new ResourceStream<RowMetadata>({}, () => {});
   }
 
   getDatasetsStream(options?: GetDatasetsOptions): ResourceStream<Dataset> {
     // placeholder body, overwritten in constructor
     return new ResourceStream<Dataset>({}, () => {});
   }
 
   getJobsStream(options?: GetJobsOptions): ResourceStream<Job> {
     // placeholder body, overwritten in constructor
     return new ResourceStream<Job>({}, () => {});
   }
@@ -1569,7 +1569,7 @@
     const parameterMode = is.array(params) ? 'positional' : 'named';
     const queryParameters: bigquery.IQueryParameter[] = [];
     if (parameterMode === 'named') {
       const namedParams = params as {[param: string]: any};
       for (const namedParameter of Object.getOwnPropertyNames(namedParams)) {
         const value = namedParams[namedParameter];
         let queryParameter;
@@ -2212,12 +2212,13 @@
 
       options = extend({job}, queryOpts, options);
       if (res && res.jobComplete) {
         let rows: any = [];
         if (res.schema && res.rows) {
           rows = BigQuery.mergeSchemaWithRows_(res.schema, res.rows, {
             wrapIntegers: options.wrapIntegers || false,
             parseJSON: options.parseJSON,
           });
+          delete res.rows;
         }
         this.trace_('[runJobsQuery] job complete');
         options._cachedRows = rows;

src/job.ts

@@ -55,7 +55,7 @@
     /**
      * internal properties
      */
     _cachedRows?: any[];
     _cachedResponse?: bigquery.IQueryResponse;
   };
 
@@ -134,7 +134,7 @@
   location?: string;
   projectId?: string;
   getQueryResultsStream(
     options?: QueryResultsOptions
   ): ResourceStream<RowMetadata> {
     // placeholder body, overwritten in constructor
     return new ResourceStream<RowMetadata>({}, () => {});
@@ -565,16 +565,19 @@
     const timeoutOverride =
       typeof qs.timeoutMs === 'number' ? qs.timeoutMs : false;
 
-    if (options._cachedRows) {
+    const cachedRows = options._cachedRows;
+    const cachedResponse = options._cachedResponse;
+    delete options._cachedRows;
+    delete options._cachedResponse;
+    if (cachedRows) {
       let nextQuery: QueryResultsOptions | null = null;
       if (options.pageToken) {
         nextQuery = Object.assign({}, options, {
           pageToken: options.pageToken,
         });
-        delete nextQuery._cachedRows;
-        delete nextQuery._cachedResponse;
       }
-      callback!(null, options._cachedRows, nextQuery, options._cachedResponse);
+      delete cachedResponse?.rows;
+      callback!(null, cachedRows, nextQuery, cachedResponse);
       return;
     }
 
@@ -620,7 +623,7 @@
           });
           delete nextQuery.startIndex;
         }
-
+        delete resp.rows;
         callback!(null, rows, nextQuery, resp);
       }
     );