ResultSetMetaData.getColumnClassName now returns the correct class name for BLOB and CLOB.

h2/src/main/org/h2/value/DataType.java

@@ -604,11 +604,11 @@ public class DataType {
             // "java.lang.String";
             return String.class.getName(); 
         case Value.BLOB:
-            // "java.sql.Blob";
-            return java.sql.Blob.class.getName(); 
+            // "java.io.InputStream";
+            return java.io.InputStream.class.getName(); 
         case Value.CLOB:
-            // "java.sql.Clob";
-            return java.sql.Clob.class.getName(); 
+            // "java.io.Reader";
+            return java.io.Reader.class.getName(); 
         case Value.DOUBLE:
             // "java.lang.Double";
             return Double.class.getName(); 

h2/src/test/org/h2/test/jdbc/TestMetaData.java

@@ -32,6 +32,7 @@ public class TestMetaData extends TestBase {
         deleteDb("metaData");
         conn = getConnection("metaData");
 
+        testColumnLobMeta();
         testColumnMetaData();
         testColumnPrecision();
         testColumnDefault();
@@ -196,6 +197,20 @@ public class TestMetaData extends TestBase {
 
     }
     
+    private void testColumnLobMeta() throws Exception {
+        Statement stat = conn.createStatement();
+        stat.executeUpdate("CREATE TABLE t (blob BLOB, clob CLOB)");
+        stat.execute("INSERT INTO t VALUES('', '')");
+        ResultSet rs = stat.executeQuery("SELECT blob,clob FROM t");
+        ResultSetMetaData rsmd = rs.getMetaData();
+        assertEquals("java.io.InputStream", rsmd.getColumnClassName(1));
+        assertEquals("java.io.Reader", rsmd.getColumnClassName(2));
+        rs.next();
+        assertEquals("java.io.ByteArrayInputStream", rs.getObject(1).getClass().getName());
+        assertEquals("java.io.BufferedReader", rs.getObject(2).getClass().getName());
+        stat.executeUpdate("DROP TABLE t");
+    }
+
     private void testColumnMetaData() throws Exception {
         String statement = "select substring('Hello',0,1)";
         ResultSet rs = conn.prepareStatement(statement).executeQuery();