feat(snowflake-driver): Upgrade snowflake-sdk to 1.13.1 (fix Node.js …

…20+ crash) (#8713)

This upgrade is required to fix a compatibility issue for Snowflake SDK and Node.js 20+. 

References:

- snowflakedb/snowflake-connector-nodejs#588
- snowflakedb/snowflake-connector-nodejs#703

packages/cubejs-snowflake-driver/package.json

@@ -29,7 +29,7 @@
     "@cubejs-backend/shared": "^0.36.0",
     "@google-cloud/storage": "^5.8.5",
     "date-fns-timezone": "^0.1.4",
-    "snowflake-sdk": "^1.8.0"
+    "snowflake-sdk": "^1.13.1"
   },
   "license": "Apache-2.0",
   "publishConfig": {
@@ -40,7 +40,6 @@
   },
   "devDependencies": {
     "@cubejs-backend/linter": "^0.36.0",
-    "@types/snowflake-sdk": "^1.6.8",
     "typescript": "~5.2.2"
   }
 }

packages/cubejs-snowflake-driver/src/SnowflakeDriver.ts

@@ -8,7 +8,7 @@ import {
   getEnv,
   assertDataSource,
 } from '@cubejs-backend/shared';
-import snowflake, { Column, Connection, Statement } from 'snowflake-sdk';
+import snowflake, { Column, Connection, RowStatement } from 'snowflake-sdk';
 import {
   BaseDriver,
   DownloadTableCSVData,
@@ -22,7 +22,6 @@ import {
   DownloadQueryResultsResult,
   DownloadQueryResultsOptions,
   DriverCapabilities,
-  QueryTablesResult,
 } from '@cubejs-backend/base-driver';
 import { formatToTimeZone } from 'date-fns-timezone';
 import { Storage } from '@google-cloud/storage';
@@ -228,6 +227,11 @@ export class SnowflakeDriver extends BaseDriver implements DriverInterface {
       privateKey += '\n';
     }
 
+    snowflake.configure({
+      // TODO: Remove after release of https://github.com/snowflakedb/snowflake-connector-nodejs/pull/912
+      logLevel: 'OFF' as any
+    });
+
     this.config = {
       readOnly: false,
       account: getEnv('snowflakeAccount', { dataSource }),
@@ -700,7 +704,7 @@ export class SnowflakeDriver extends BaseDriver implements DriverInterface {
     _options: StreamOptions,
   ): Promise<StreamTableDataWithTypes> {
     const connection = await this.getConnection();
-    const stmt = await new Promise<Statement>((resolve, reject) => connection.execute({
+    const stmt = await new Promise<RowStatement>((resolve, reject) => connection.execute({
       sqlText: query,
       binds: <string[] | undefined>values,
       fetchAsString: [
@@ -742,7 +746,7 @@ export class SnowflakeDriver extends BaseDriver implements DriverInterface {
     };
   }
 
-  private getTypes(stmt: Statement) {
+  private getTypes(stmt: RowStatement) {
     return stmt.getColumns().map((column) => {
       const type = {
         name: column.getName().toLowerCase(),

packages/cubejs-testing-drivers/package.json

@@ -89,7 +89,10 @@
     "testMatch": [
       "<rootDir>/dist/test/**/*.(test|spec).(ts|js)"
     ],
-    "snapshotResolver": "<rootDir>/test/snapshotResolver.js"
+    "snapshotResolver": "<rootDir>/test/snapshotResolver.js",
+    "moduleNameMapper": {
+      "^axios$": "axios/dist/node/axios.cjs"
+    }
   },
   "eslintConfig": {
     "extends": "../cubejs-linter"