Added JSON datatype test cases in ResultSet, TVP and Regression scenarios.

Author: Divang Sharma

src/test/java/com/microsoft/sqlserver/jdbc/resultset/ResultSetTest.java

@@ -100,7 +100,7 @@ public void testJdbc41ResultSetMethods() throws SQLException {
                     + "col2 varchar(512), " + "col3 float, " + "col4 decimal(10,5), " + "col5 uniqueidentifier, "
                     + "col6 xml, " + "col7 varbinary(max), " + "col8 text, " + "col9 ntext, " + "col10 varbinary(max), "
                     + "col11 date, " + "col12 time, " + "col13 datetime2, " + "col14 datetimeoffset, "
-                    + "col15 decimal(10,9), " + "col16 decimal(38,38), "
+                    + "col15 decimal(10,9), " + "col16 decimal(38,38), " + "col17 json, "
                     + "order_column int identity(1,1) primary key)");
             try {
 
@@ -120,12 +120,13 @@ public void testJdbc41ResultSetMethods() throws SQLException {
                                 + "'2017-05-19T10:47:15.1234567'," // col13
                                 + "'2017-05-19T10:47:15.1234567+02:00'," // col14
                                 + "0.123456789, " // col15
-                                + "0.1234567890123456789012345678901234567" // col16
+                                + "0.1234567890123456789012345678901234567, " // col16
+                                + "'{\"test\":\"123\"}'" // col17
                                 + ")");
 
                 stmt.executeUpdate("Insert into " + AbstractSQLGenerator.escapeIdentifier(tableName) + " values("
                         + "null, " + "null, " + "null, " + "null, " + "null, " + "null, " + "null, " + "null, "
-                        + "null, " + "null, " + "null, " + "null, " + "null, " + "null, " + "null, " + "null)");
+                        + "null, " + "null, " + "null, " + "null, " + "null, " + "null, " + "null, " + "null, " + "null)");
 
                 try (ResultSet rs = stmt.executeQuery("select * from "
                         + AbstractSQLGenerator.escapeIdentifier(tableName) + " order by order_column")) {
@@ -223,7 +224,11 @@ public void testJdbc41ResultSetMethods() throws SQLException {
                             .compareTo(new BigDecimal("0.12345678901234567890123456789012345670")));
                     assertEquals(0, rs.getObject("col16", BigDecimal.class)
                             .compareTo(new BigDecimal("0.12345678901234567890123456789012345670")));
-
+    
+                    String expectedJsonValue = "{\"test\":\"123\"}";        
+                    assertEquals(expectedJsonValue, rs.getObject(17).toString());
+                    assertEquals(expectedJsonValue, rs.getObject("col17").toString());
+                
                     // test null values, mostly to verify primitive wrappers do not return default values
                     assertTrue(rs.next());
                     assertNull(rs.getObject("col1", Boolean.class));
@@ -284,6 +289,9 @@ public void testJdbc41ResultSetMethods() throws SQLException {
                     assertNull(rs.getObject(16, BigDecimal.class));
                     assertNull(rs.getObject("col16", BigDecimal.class));
 
+                    assertNull(rs.getObject(17));
+                    assertNull(rs.getObject("col17"));
+
                     assertFalse(rs.next());
                 }
             } finally {

src/test/java/com/microsoft/sqlserver/jdbc/tvp/TVPTypesTest.java

@@ -379,6 +379,38 @@ public void testTVPXMLStoredProcedure() throws SQLException {
         }
     }
 
+    /**
+     * JSON with StoredProcedure
+     * 
+     * @throws SQLException
+     */
+    @Test
+    public void testTVPJSONStoredProcedure() throws SQLException {
+        createTables("json");
+        createTVPS("json");
+        createProcedure();
+
+        value = "{\"severity\":\"TRACE\",\"duration\":200,\"date\":\"2024-12-17T15:45:56\"}";
+
+        tvp = new SQLServerDataTable();
+        tvp.addColumnMetadata("c1",  microsoft.sql.Types.JSON);
+        tvp.addRow(value);
+
+        final String sql = "{call " + AbstractSQLGenerator.escapeIdentifier(procedureName) + "(?)}";
+
+        try (SQLServerCallableStatement callableStmt = (SQLServerCallableStatement) connection.prepareCall(sql)) {
+            callableStmt.setStructured(1, tvpName, tvp);
+            callableStmt.execute();
+
+            try (Connection con = getConnection(); Statement stmt = con.createStatement();
+                    ResultSet rs = stmt.executeQuery(
+                            "select c1 from " + AbstractSQLGenerator.escapeIdentifier(tableName) + " ORDER BY rowId")) {
+                while (rs.next())
+                    assertEquals(rs.getString(1), value);
+            }
+        }
+    }
+
     /**
      * Text with StoredProcedure
      * 

src/test/java/com/microsoft/sqlserver/jdbc/unit/statement/RegressionTest.java

@@ -238,6 +238,30 @@ public void testXmlQuery() throws SQLException {
         }
     }
 
+    /**
+     * Tests Json query
+     * 
+     * @throws SQLException
+     */
+    @Test
+    public void testJsonQuery() throws SQLException {
+        try (Connection connection = getConnection(); Statement stmt = connection.createStatement()) {
+            tableName = RandomUtil.getIdentifier("try_SQLJSON_Table");
+            TestUtils.dropTableIfExists(AbstractSQLGenerator.escapeIdentifier(tableName), stmt);
+            stmt.execute("CREATE TABLE " + AbstractSQLGenerator.escapeIdentifier(tableName)
+                        + " ([c1] int, [c2] json, [c3] json)");
+
+            String sql = "UPDATE " + AbstractSQLGenerator.escapeIdentifier(tableName) + " SET [c2] = ?, [c3] = ?";
+            try (SQLServerPreparedStatement pstmt = (SQLServerPreparedStatement) connection.prepareStatement(sql)) {
+                pstmt.setObject(1, null);
+                pstmt.setObject(2, null);
+                pstmt.executeUpdate();
+            } finally {
+                TestUtils.dropTableIfExists(AbstractSQLGenerator.escapeIdentifier(tableName), stmt);
+            }
+        }
+    }
+
     private void createTable(Statement stmt) throws SQLException {
 
         String sql = "CREATE TABLE " + AbstractSQLGenerator.escapeIdentifier(tableName)