fix: correct parsing of nullable bigint columns

Author: ptiurin

src/statement/hydrateResponse.ts

@@ -49,6 +49,10 @@ const getHydratedValue = (
   type: string,
   executeQueryOptions: ExecuteQueryOptions
 ): any => {
+  // strip null to ensure correct type checking in the following steps
+  if (type.endsWith("null")) {
+    type = type.replace("null", "").trim();
+  }
   if (isStructType(type)) {
     return hydrateStruct(
       value as Record<string, unknown>,

test/integration/v2/fetchTypes.test.ts

@@ -42,6 +42,26 @@ describe("test type casting on fetch", () => {
     const row = data[0];
     expect((row as unknown[])[0]).toEqual(new BigNumber("9223372036854775807"));
   });
+  it("select nullable bigint", async () => {
+    const firebolt = Firebolt({
+      apiEndpoint: process.env.FIREBOLT_API_ENDPOINT as string
+    });
+    // Max value for a signed 64-bit integer (bigint)
+    const testQuery = `
+      WITH a AS (
+        SELECT 9223372036854775807::bigint UNION ALL SELECT null::bigint
+      )
+      SELECT * FROM a
+    `;
+    const connection = await firebolt.connect(connectionParams);
+
+    const statement = await connection.execute(testQuery);
+
+    const { data, meta } = await statement.fetchResult();
+    expect(meta[0].type).toEqual("long null");
+    const row = data[0];
+    expect((row as unknown[])[0]).toEqual(new BigNumber("9223372036854775807"));
+  });
   it("select negative bigint", async () => {
     const firebolt = Firebolt({
       apiEndpoint: process.env.FIREBOLT_API_ENDPOINT as string

test/unit/v1/statement.test.ts

@@ -313,6 +313,18 @@ describe("parse values", () => {
       new BigNumber(1000000000000000000000000000000000000)
     );
   });
+  it("parses biging null into BigNumber container", () => {
+    allure.description("Verify nullable bigint is parsed correctly");
+    const row = {
+      big: "1000000000000000000000000000000000000"
+    };
+    const meta = [{ name: "big", type: "long null" }];
+    const res: Record<string, BigNumber> = hydrateRow(row, meta, {});
+    expect(res["big"] instanceof BigNumber).toBe(true);
+    expect(res["big"]).toEqual(
+      new BigNumber(1000000000000000000000000000000000000)
+    );
+  });
 });
 
 describe("set statements", () => {