Mapping to json node

snowflakedb · Mar 28, 2024 · 10d8062 · 10d8062
1 parent 882c810
commit 10d8062
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/main/java/net/snowflake/client/jdbc/SnowflakeBaseResultSet.java b/src/main/java/net/snowflake/client/jdbc/SnowflakeBaseResultSet.java
@@ -1552,8 +1552,11 @@ public <T> Map<String, T> getMap(int columnIndex, Class<T> type) throws SQLExcep
     Object object = getObject(columnIndex);
     Map<String, Object> map;
     if (object instanceof JsonSqlInput) {
+      map = new HashMap<>();
       JsonNode jsonNode = ((JsonSqlInput) object).getInput();
-      map = OBJECT_MAPPER.convertValue(jsonNode, new TypeReference<Map<String, Object>>() {});
+      jsonNode
+          .fieldNames()
+          .forEachRemaining(node -> map.put(node.toString(), jsonNode.get(node.toString())));
     } else {
       map = (Map<String, Object>) object;
     }
@@ -1565,7 +1568,7 @@ public <T> Map<String, T> getMap(int columnIndex, Class<T> type) throws SQLExcep
         if (object instanceof JsonSqlInput) {
           sqlInput =
               new JsonSqlInput(
-                  (((JsonSqlInput) object).getInput()).get(entry.getKey()),
+                  (JsonNode) entry.getValue(),
                   session,
                   sfBaseResultSet.getConverters(),
                   sfBaseResultSet