Oracle中的Clob与String类型转换

转载请注明出处:http://blog.csdn.net/sunyujia/

在论坛上看到的一个问题,其实我从来没有用过Clob,因为确实没这个需求,但是为了抢分,如何最快的找到解决方案呢,第一时间想到spring,因为spring对orm工具有封装, 像ibatis,hibernate等,在spring.jar中大概翻了一下包,根据包名和类名发现如下可疑类org.springframework.orm.ibatis.support.ClobStringTypeHandler 根据源码跟踪到了 org.springframework.jdbc.support.lob.OracleLobHandler 这个类才是内有乾坤,有我想要的一切东西,嘿嘿,不好意思了,统统抄来.

在spring包中有个org.springframework.jdbc.support.lob.AbstractLobHandler这里面定义了基本的Clob和Blog处理方法

org.springframework.jdbc.support.lob.DefaultLobHandler是默认的实现,除了Oracle其他数据库使用此实现

org.springframework.jdbc.support.lob.OracleLobHandler是专门用于Oracle的实现,可见Oracle的BT,为了不造成直接包依赖,相关的调用都是利用反射完成的.有兴趣的朋友可以去阅读下这两个类,以便了解Oracle的特殊性.

经过分析,将Clob的创建,以及与String的互转代码放出来供大家使用.当然不可能完全copy了,我做了些简化处理,不过已经测试了,没用问题.更多细节请查阅spring的org.springframework.jdbc.support.lob包源码.

SqlUtil类是我为了方便测试写的,大家靠代码就能够猜出来其内容了,所以就不全贴了,只贴本文的主题部分.

1.     /**
2.      *
3.      * Description:创建Clob或者Blob
4.      *
5.      * @param conn数据库连接对象
6.      * @param lobClassName
7.      *            oracle.sql.CLOB或者oracle.sql.BLOB
8.      * @return oracle.sql.CLOB或者oracle.sql.BLOB对象
9.      * @throws Exception
10.      * @blog blog.csdn.ne t/sunyujia/
11.      * @mail [e-mail]
12.      * @since：Oct 1, 2008 6:42:08 PM
13.      */
14.     public static Object createOracleLob(Connection conn, String lobClassName)
15.             throws Exception {
16.         Class lobClass = conn.getClass().getClassLoader().loadClass(
17.                 lobClassName);
18.         final Integer DURATION_SESSION = new Integer(lobClass.getField(
19.                 "DURATION_SESSION").getInt(null));
20.         final Integer MODE_READWRITE = new Integer(lobClass.getField(
21.                 "MODE_READWRITE").getInt(null));
22.         Method createTemporary = lobClass.getMethod("createTemporary",
23.                 new Class[] { Connection.class, boolean.class, int.class });
24.         Object lob = createTemporary.invoke(null, new Object[] { conn, false,
25.                 DURATION_SESSION });
26.         Method open = lobClass.getMethod("open", new Class[] { int.class });
27.         open.invoke(lob, new Object[] { MODE_READWRITE });
28.         return lob;
29.     }
31.     /**
32.      *
33.      * Description:将Clob对象转换为String对象,Blob处理方式与此相同
34.      *
35.      * @param clob
36.      * @return
37.      * @throws Exception
38.      * @mail [e-mail]
39.      * @blog blog.csdn.ne t/sunyujia/
40.      * @since：Oct 1, 2008 7:19:57 PM
41.      */
42.     public static String oracleClob2Str(Clob clob) throws Exception {
43.         return (clob != null ? clob.getSubString(1, (int) clob.length()) : null);
44.     }
46.     /**
47.      *
48.      * Description:将string对象转换为Clob对象,Blob处理方式与此相同
49.      *
50.      * @param str
51.      * @param lob
52.      * @return
53.      * @throws Exception
54.      * @mail [e-mail]
55.      * @blog blog.csdn.ne t/sunyujia/
56.      * @since：Oct 1, 2008 7:20:31 PM
57.      */
58.     public static Clob oracleStr2Clob(String str, Clob lob) throws Exception {
59.         Method methodToInvoke = lob.getClass().getMethod(
60.                 "getCharacterOutputStream", (Class[]) null);
61.         Writer writer = (Writer) methodToInvoke.invoke(lob, (Object[]) null);
62.         writer.write(str);
63.         writer.close();
64.         return lob;
65.     }
67.     /**
68.      *
69.      * Description: 全部源码查考自
70.      * org.springframework.jdbc.support.lob.OracleLobHandler
71.      *
72.      * @param args
73.      * @throws Exception
74.      * @mail [e-mail]
75.      * @blog blog.csdn.ne t/sunyujia/
76.      * @since：Oct 1, 2008 7:26:16 PM
77.      */
78.     public static void main(String[] args) throws Exception {
79.         //创建数据源略
80.         Connection conn = SqlUtil.getConnection();
81.         Clob clob = (Clob) createOracleLob(conn, "oracle.sql.CLOB");// BLOB的话传oracle.sql.BLOB
82.         // create table testTb (TheClob Clob);
83.         PreparedStatement pstmt = conn
84.                 .prepareStatement("insert into testTb (TheClob) values (?)");
85.         pstmt.setClob(1, oracleStr2Clob("test", clob));
86.         pstmt.execute();
87.         SqlUtil.closeStmt(pstmt);
88.         Statement stmt = conn.createStatement();
89.         ResultSet rs = stmt.executeQuery("select * from testTb");
90.         while (rs.next()) {
91.             String str = oracleClob2Str(rs.getClob(1));
92.             System.out.println(str);
93.         }
94.         SqlUtil.closeRs(rs);
95.         SqlUtil.closeStmt(stmt);
96.         SqlUtil.closeConn(conn);
97.     }