fix(FIR-43901): correct parsing of nullable bigint columns

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 bigint 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", () => {

test/unit/v2/statement.test.ts

@@ -321,6 +321,18 @@ describe("parse values", () => {
  const res: Record<string, Buffer> = hydrateRow(row, meta, {});
  expect(res["bytea"]).toEqual(Buffer.from("hello_world"));
  });
+ it("parses bigint 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)
+ );
+ });
  it("parses struct into object", () => {
  const row = {
  s: { a: [1, 2], b: "\\x68656c6c6f5f776f726c64" }