Implement JSON data type

tobiasstrebitzer · adsharma · commit 42d1f7652707 · 2026-04-08T07:59:56.000-07:00
diff --git a/src_cpp/node_util.cpp b/src_cpp/node_util.cpp
@@ -198,6 +198,15 @@ Napi::Value Util::ConvertToNapiObject(const Value& value, Napi::Env env) {
         auto valString = value.toString();
         return Napi::String::New(env, valString).ToNumber();
     }
+    case LogicalTypeID::JSON: {
+        auto valString = value.getValue<std::string>();
+        auto global = env.Global();
+        auto jsonObj = global.Get("JSON").As<Napi::Object>();
+        auto parseFunc = jsonObj.Get("parse").As<Napi::Function>();
+        auto jsonString = Napi::String::New(env, valString);
+        auto result = parseFunc.Call(global, {jsonString});
+        return result;
+    }
     default:
         throw Exception("Unsupported type: " + dataType.toString());
     }
diff --git a/test/test_data_type.js b/test/test_data_type.js
@@ -544,3 +544,20 @@ describe("DECIMAL", function () {
     );
   });
 });
+
+describe("JSON", function () {
+  it("should convert JSON type", async function () {
+    await conn.query("INSTALL JSON");
+    await conn.query("LOAD EXTENSION JSON");
+    const queryResult = await conn.query("RETURN json_object('level', 1, 'ms', 32, 'flags', json_array(0, 1, 3)) AS data;");
+    const result = await queryResult.getAll();
+    assert.equal(result.length, 1);
+    assert.equal(Object.keys(result[0]).length, 1);
+    assert.isTrue("data" in result[0]);
+    assert.equal(typeof result[0]["data"], "object");
+    assert.equal(result[0]["data"]["level"], 1);
+    assert.equal(result[0]["data"]["ms"], 32);
+    assert.isTrue(Array.isArray(result[0]["data"]["flags"]));
+    assert.deepEqual(result[0]["data"]["flags"], [0, 1, 3]);
+  });
+});
