diff --git a/lib/services/large_result_set.js b/lib/services/large_result_set.js index 7eb5304e9..5fdaeeaa8 100644 --- a/lib/services/large_result_set.js +++ b/lib/services/large_result_set.js @@ -67,6 +67,9 @@ function LargeResultSetService(connectionConfig, httpClient) // invoked when the request completes const callback = function callback(err, response, body) { + if (response) { + Logger.getInstance().trace(`Response: content-type is ${response.response.getResponseHeader('Content-Type')} and content-encoding is ${response.response.getResponseHeader('Content-Encoding')}`) + } // err happens on timeouts and response is passed when server responded if (err || isUnsuccessfulResponse(response)) { diff --git a/test/integration/testLargeResultSet.js b/test/integration/testLargeResultSet.js index 805dbb34f..6ca43cfa4 100644 --- a/test/integration/testLargeResultSet.js +++ b/test/integration/testLargeResultSet.js @@ -4,10 +4,11 @@ const assert = require('assert'); const async = require('async'); const testUtil = require('./testUtil'); +const { configureLogger } = require('../configureLogger'); const sourceRowCount = 10000; -describe('Large result Set Tests', function () +describe.only('Large result Set Tests', function () { let connection; const selectAllFromOrders = `select randstr(1000,random()) from table(generator(rowcount=>${sourceRowCount}))`; @@ -16,8 +17,13 @@ describe('Large result Set Tests', function () { connection = testUtil.createConnection(); await testUtil.connectAsync(connection); + // setting ROWS_PER_RESULTSET causes invalid, not encoded chunks from GCP + await testUtil.executeCmdAsync(connection, 'alter session set ROWS_PER_RESULTSET = 1000000'); }); + beforeEach(() => configureLogger('TRACE')); + afterEach(() => configureLogger('ERROR')); + after(async () => { await testUtil.destroyConnectionAsync(connection);