1. 程式人生 > >使用JDBC對BLOB和CLOB進行處理

使用JDBC對BLOB和CLOB進行處理

從網上看到這篇文章,轉過來做為學習用

設有表:
create table blobimg (id int primary key, contents blob);
一、BLOB入庫的專用訪問:
    1) 最常見於Oracle的JDBC示例中
    一般是先通過select  ... for update鎖定blob列,然後寫入blob值,然後提交。要用到特定的Oracle BLOB類。

Java程式碼  收藏程式碼
  1. Class.forName("oracle.jdbc.driver.OracleDriver");  
  2.     Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:testdb"
    "test""test");  
  3.     //處理事務  
  4.     con.setAutoCommit(false);  
  5.     Statement st = con.createStatement();  
  6.     //插入一個空物件  
  7.     st.executeUpdate("insert into BLOBIMG  values(1,empty_blob())");  
  8.     //用for update方式鎖定資料行  
  9.     ResultSet rs = st.executeQuery(  
  10.               "select contents from  BLOBIMG  where  id=1  for update"
    );  
  11.     if (rs.next()) {  
  12.     //使用oracle.sql.BLOB類,沒辦法了,變成專用的了  
  13.     oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(1).;  
  14.     //到資料庫的輸出流  
  15.     OutputStream outStream = blob.getBinaryOutputStream();  
  16.     //這裡用一個檔案模擬輸入流  
  17.     File file = new File("d:\\proxy.txt");  
  18.     InputStream fin = new FileInputStream(file);  
  19.     //將輸入流寫到輸出流  
  20.     byte[] b = new byte[blob.getBufferSize()];  
  21.     int len = 0;  
  22.     while ( (len = fin.read(b)) != -1) {  
  23.               outStream.write(b, 0, len);  
  24.     }  
  25.     //依次關閉  
  26.     fin.close();  
  27.     outStream.flush();  
  28.     outStream.close();  
  29.     }  
  30.     con.commit();  
  31.     con.close();  

 2) 再厲害一點的,是通過呼叫DBMS_LOB包中的一些函式來處理,效率好像也不錯.
 不過,要使用到儲存過程,用到專用類OracleCallableStatement。

Java程式碼  收藏程式碼
  1. import java.sql.*;  
  2.     import java.io.*;  
  3.     import oracle.jdbc.driver.*;  
  4.     import oracle.sql.*;  
  5.     class TestBlobWriteByDBMS_LOB {  
  6.         public static void main (String args []) throws SQLException ,   
  7.         FileNotFoundException, IOException  
  8.         {  
  9.             DriverManager.registerDriver (new oracle.jdbc.driver.OracleDriver());  
  10.             Connection conn =   
  11.                 DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:ora92","scott","tiger");  
  12.             conn.setAutoCommit(false);  
  13.             Statement stmt = conn.createStatement();  
  14.             stmt.execute( "delete from demo" );  
  15.             System.out.println( "deleted from demo" );  
  16.             stmt.execute( "insert into demo (id,theBlob) values (s_enr.nextval,empty_blob())" );  
  17.             conn.commit();  
  18.             System.out.println( "committed" );  
  19.             ResultSet rset = stmt.executeQuery ("SELECT theBlob FROM  demo where id = s_enr.currval  FOR UPDATE");  
  20.             System.out.println( "Executed Query" );  
  21.             if(rset.next())  
  22.             {  
  23.                 System.out.println( "Fetched row " );  
  24.                 BLOB l_mapBLOB = ((OracleResultSet)rset).getBLOB(1);  
  25.                 File binaryFile = new File("e:\\free\\jo.jpg");  
  26.                 FileInputStream instream=new  FileInputStream(binaryFile);  
  27.                 int chunk = 32000;  
  28.                 System.out.println( "Chunk = "+ chunk );  
  29.                 byte[] l_buffer = new byte[chunk];  
  30.                 int l_nread = 0;  
  31.                 OracleCallableStatement cstmt =  
  32.                     (OracleCallableStatement)conn.prepareCall( "begin dbms_lob.writeappend( :1, :2, :3 ); end;" );  
  33.                 cstmt.registerOutParameter( 1, OracleTypes.BLOB );  
  34.                 while ((l_nread= instream.read(l_buffer)) != -1)   
  35.                 {  
  36.                     cstmt.setBLOB(  1, l_mapBLOB );  
  37.                     cstmt.setInt(   2, l_nread );  
  38.                     cstmt.setBytes( 3, l_buffer );  
  39.                     cstmt.executeUpdate();  
  40.                     l_mapBLOB = cstmt.getBLOB(1);  
  41.                 }  
  42.                 instream.close();  
  43.                 conn.commit();  
  44.                 rset.close();  
  45.                 stmt.close();  
  46.                 conn.close();  
  47.             }  
  48.         }  
  49.     }  

二、BLOB值讀取的通用處理:
這個jdbc標準介面可以直接呼叫,因此比較簡單,如下所示:

Java程式碼  收藏程式碼
  1. Connection con = ConnectionFactory.getConnection();  
  2.    con.setAutoCommit(false);  
  3.    Statement st = con.createStatement();  
  4.    ResultSet rs = st.executeQuery("select contents from  BLOBIMG  where  id=1");  
  5.    if (rs.next()) {  
  6.        java.sql.Blob blob = rs.getBlob(1);  
  7.        InputStream ins = blob.getBinaryStream();  
  8.        //輸出到檔案  
  9.        File file = new File("d:\\output.txt");  
  10.        OutputStream fout = new FileOutputStream(file);  
  11.        //下面將BLOB資料寫入檔案  
  12.        byte[] b = new byte[1024];  
  13.        int len = 0;  
  14.        while ( (len = ins.read(b)) != -1) {  
  15.          fout.write(b, 0, len);  
  16.        }  
  17.        //依次關閉  
  18.        fout.close();  
  19.        ins.close();  
  20.    }      
  21.    con.commit();  
  22.    con.close();  

三、BLOB值寫入的通用處理:
 這時要藉助於PreparedStatement的動態繫結功能,借用其setObject()方法插入位元組流到BLOB欄位。

Java程式碼  收藏程式碼
  1. public void insertFile(File f) throws Exception{   
  2.         FileInputStream fis=new FileInputStream(f,Connection conn);   
  3.         byte[] buffer=new byte[1024];   
  4.         data=null;   
  5.         int sept=0;int len=0;   
  6.         while((sept=fis.read(buffer))!=-1){   
  7.             if(data==null){   
  8.             len=sept;   
  9.             data=buffer;   
  10.             }else{   
  11.                 byte[] temp;   
  12.                 int tempLength;   
  13.                 tempLength=len+sept;   
  14.                 temp=new byte[tempLength];   
  15.                 System.arraycopy(data,0,temp,0,len);   
  16.                 System.arraycopy(buffer,0,temp,len,sept);   
  17.                 data=temp;   
  18.                 len=tempLength;   
  19.             }   
  20.             if(len!=data.length()){   
  21.             byte temp=new byte[len];   
  22.             System.arraycopy(data,0,temp,0,len);   
  23.             data=temp;   
  24.             }   
  25.         }   
  26.         String sql="insert into fileData (filename,blobData) value(?,?)";   
  27.         PreparedStatement ps=conn.prepareStatement(sql);   
  28.         ps.setString(1,f.getName());   
  29.         ps.setObject(2,data);   
  30.         ps.executeUpdate();  
  31.     }  

四. CLOB讀取的通用處理

Java程式碼  收藏程式碼
  1. public static String getClobString(ResultSet rs, int col) {   
  2.        try {   
  3.            Clob c=resultSet.getClob(2);   
  4.            Reader reader=c.getCharacterStream():   
  5.            if (reader == null) {   
  6.                return null;   
  7.            }   
  8.            StringBuffer sb = new StringBuffer();   
  9.            char[] charbuf = new char[4096];   
  10.            for (int i = reader.read(charbuf); i > 0; i = reader.read(charbuf)) {   
  11.                sb.append(charbuf, 0, i);   
  12.            }   
  13.            return sb.toString();   
  14.        } catch (Exception e) {   
  15.            return "";   
  16.        }   
  17.    }