内置对象Clob对从数据库表中取的字符大对象CLOB类型的列值进行读取操作

 1 package readclobDemo.bao;
 2 
 3 import java.io.IOException;
 4 import java.io.Reader;
 5 import java.sql.Clob;
 6 import java.sql.Connection;
 7 import java.sql.PreparedStatement;
 8 import java.sql.ResultSet;
 9 import java.sql.SQLException;
10 
11 import jdbcutil.bao.JdbcUtil;
12 
13 public class ReadClobDemo {
14 
15     /**
16      CLOB用于存储大量的字符数据，程序的主要功能为从数据库中通过jdbc获取CLOB字段，将其转化为IO进行读取，
17       所以首先通过查询语句得到CLOB字段，再将CLOB从结果集中获得并将其转化为oracle.sql.CLOB类型进行写入操作
18      * @throws IOException 
19      */
20     
21     
22     
23     /* CREATE TABLE "HR"."CLOB_1" 
24        (    "ID" NUMBER(*,0), 
25             "CLOB_TEXT" CLOB
26        ) SEGMENT CREATION IMMEDIATE *///在oracle创建表CLOB_1;
27     
28     public static void readclob(int id) throws IOException{
29         
30         
31         Connection conn=null;
32         PreparedStatement patst=null;
33         ResultSet rs=null;
34         String sql="select * from CLOB_1 where id=?";
35         try {
36             conn=JdbcUtil.getConnection();   //通过获得数据连接池JdbcUtil中分配的数据库连接接口进行数据库的连接
37             patst=conn.prepareStatement(sql);
38             patst.setInt(1, id);
39             rs=patst.executeQuery();    //返回结果集；
40             
41             if(rs.next()){
42                 
43                 Clob clob=rs.getClob("CLOB_TEXT");  //Clob对象在它被创建的事务处理期间有效
44                 Reader rd=clob.getCharacterStream();
45                 
46                 char[] chars = new char[1024];   //定义一个字符数组
47 
48                    int length=0;
49 
50                    System.out.print("CLOB_TEXT:");
51                  //通过Io流读取返回int字节值转化为char类型直到没有字节，返回-1
52                    while((length=rd.read(chars)) != -1) {  
53 
54                     if(length==1024){
55 
56                     System.out.print(chars);
57 
58                     }else{
59 
60                     System.out.print(new String(chars,0,length));//不够长度1024的字符数组只显示有值的字符串
61 
62                    }
63                 
64              }
65                 
66                 
67           }
68             
69         } catch (SQLException e1) {
70             e1.printStackTrace();
71         } finally{
72             JdbcUtil.free(rs, patst, conn);//调用JdbcUtil定义的free方法关闭各接口；
73         }
74         
75         
76     }
77     public static void main(String[] args) throws IOException {
78         
79                readclob(1);
80                 
81     }
82 
83 }