@Test
public void insertJsonData() throws SQLException {
    String insertSql = "INSERT INTO " + AbstractSQLGenerator.escapeIdentifier(tableName) + " (data) VALUES (?)";
    String json = "{\"name\":\"John\",\"skills\":[\"Java\",\"SQL\"]}";
    try (PreparedStatement pstmt = connection.prepareStatement(insertSql)) {
        pstmt.setString(1, json);
        pstmt.executeUpdate();
    }
}

@Test
public void getJsonData() throws SQLException {
    String query = "SELECT data FROM " + AbstractSQLGenerator.escapeIdentifier(tableName);
    try (PreparedStatement stmt = connection.prepareStatement(query);
         ResultSet rs = stmt.executeQuery()) {
        while (rs.next()) {
            String json = rs.getString("data");
            System.out.println("JSON: " + json);
        }
    }
}

@Test
public void testJsonStoredProcedureInputOutput() throws SQLException {
    createProcedure();
    String call = "{call " + AbstractSQLGenerator.escapeIdentifier(procedureName) + "(?, ?)}";
    try (CallableStatement cstmt = connection.prepareCall(call)) {
        String inputJson = "{\"key\":\"value\"}";
        cstmt.setString(1, inputJson);
        cstmt.registerOutParameter(2, microsoft.sql.Types.JSON);

        cstmt.execute();
        String outputJson = cstmt.getString(2);
        System.out.println("Output JSON: " + outputJson);
    }
}

@Test
public void testBulkCopyJsonFromCSV() throws Exception {
    String dstTable = RandomUtil.getIdentifier("BulkJsonTest");
    String fileName = filePath + jsonInputFile;
    try (Connection con = getConnection();
         Statement stmt = con.createStatement();
         SQLServerBulkCopy bulkCopy = new SQLServerBulkCopy(con);
         SQLServerBulkCSVFileRecord fileRecord = new SQLServerBulkCSVFileRecord(fileName, encoding, ",", false)) {
        // Create the destination table
        stmt.executeUpdate("CREATE TABLE " + dstTable + " (c1 BIT, c2 nchar(50), c3 JSON)");
        fileRecord.addColumnMetadata(1, "c1", java.sql.Types.BIT, 0, 0);
        fileRecord.addColumnMetadata(2, "c2", java.sql.Types.NCHAR, 10, 0);
        fileRecord.addColumnMetadata(3, "c3", microsoft.sql.Types.JSON, 0, 0);
        fileRecord.setEscapeColumnDelimitersCSV(true);
        bulkCopy.setDestinationTableName(dstTable);
        bulkCopy.writeToServer(fileRecord);
    }
}