使用JDBC對BLOB和CLOB進行處理
阿新 • • 發佈:2018-12-25
從網上看到這篇文章,轉過來做為學習用
設有表:
create table blobimg (id int primary key, contents blob);
一、BLOB入庫的專用訪問:
1) 最常見於Oracle的JDBC示例中
一般是先通過select ... for update鎖定blob列,然後寫入blob值,然後提交。要用到特定的Oracle BLOB類。
- Class.forName("oracle.jdbc.driver.OracleDriver");
-
Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:testdb"
- //處理事務
- con.setAutoCommit(false);
- Statement st = con.createStatement();
- //插入一個空物件
- st.executeUpdate("insert into BLOBIMG values(1,empty_blob())");
- //用for update方式鎖定資料行
- ResultSet rs = st.executeQuery(
-
"select contents from BLOBIMG where id=1 for update"
- if (rs.next()) {
- //使用oracle.sql.BLOB類,沒辦法了,變成專用的了
- oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(1).;
- //到資料庫的輸出流
- OutputStream outStream = blob.getBinaryOutputStream();
- //這裡用一個檔案模擬輸入流
- File file = new File("d:\\proxy.txt");
-
InputStream fin = new FileInputStream(file);
- //將輸入流寫到輸出流
- byte[] b = new byte[blob.getBufferSize()];
- int len = 0;
- while ( (len = fin.read(b)) != -1) {
- outStream.write(b, 0, len);
- }
- //依次關閉
- fin.close();
- outStream.flush();
- outStream.close();
- }
- con.commit();
- con.close();
2) 再厲害一點的,是通過呼叫DBMS_LOB包中的一些函式來處理,效率好像也不錯.
不過,要使用到儲存過程,用到專用類OracleCallableStatement。
- import java.sql.*;
- import java.io.*;
- import oracle.jdbc.driver.*;
- import oracle.sql.*;
- class TestBlobWriteByDBMS_LOB {
- public static void main (String args []) throws SQLException ,
- FileNotFoundException, IOException
- {
- DriverManager.registerDriver (new oracle.jdbc.driver.OracleDriver());
- Connection conn =
- DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:ora92","scott","tiger");
- conn.setAutoCommit(false);
- Statement stmt = conn.createStatement();
- stmt.execute( "delete from demo" );
- System.out.println( "deleted from demo" );
- stmt.execute( "insert into demo (id,theBlob) values (s_enr.nextval,empty_blob())" );
- conn.commit();
- System.out.println( "committed" );
- ResultSet rset = stmt.executeQuery ("SELECT theBlob FROM demo where id = s_enr.currval FOR UPDATE");
- System.out.println( "Executed Query" );
- if(rset.next())
- {
- System.out.println( "Fetched row " );
- BLOB l_mapBLOB = ((OracleResultSet)rset).getBLOB(1);
- File binaryFile = new File("e:\\free\\jo.jpg");
- FileInputStream instream=new FileInputStream(binaryFile);
- int chunk = 32000;
- System.out.println( "Chunk = "+ chunk );
- byte[] l_buffer = new byte[chunk];
- int l_nread = 0;
- OracleCallableStatement cstmt =
- (OracleCallableStatement)conn.prepareCall( "begin dbms_lob.writeappend( :1, :2, :3 ); end;" );
- cstmt.registerOutParameter( 1, OracleTypes.BLOB );
- while ((l_nread= instream.read(l_buffer)) != -1)
- {
- cstmt.setBLOB( 1, l_mapBLOB );
- cstmt.setInt( 2, l_nread );
- cstmt.setBytes( 3, l_buffer );
- cstmt.executeUpdate();
- l_mapBLOB = cstmt.getBLOB(1);
- }
- instream.close();
- conn.commit();
- rset.close();
- stmt.close();
- conn.close();
- }
- }
- }
二、BLOB值讀取的通用處理:
這個jdbc標準介面可以直接呼叫,因此比較簡單,如下所示:
- Connection con = ConnectionFactory.getConnection();
- con.setAutoCommit(false);
- Statement st = con.createStatement();
- ResultSet rs = st.executeQuery("select contents from BLOBIMG where id=1");
- if (rs.next()) {
- java.sql.Blob blob = rs.getBlob(1);
- InputStream ins = blob.getBinaryStream();
- //輸出到檔案
- File file = new File("d:\\output.txt");
- OutputStream fout = new FileOutputStream(file);
- //下面將BLOB資料寫入檔案
- byte[] b = new byte[1024];
- int len = 0;
- while ( (len = ins.read(b)) != -1) {
- fout.write(b, 0, len);
- }
- //依次關閉
- fout.close();
- ins.close();
- }
- con.commit();
- con.close();
三、BLOB值寫入的通用處理:
這時要藉助於PreparedStatement的動態繫結功能,借用其setObject()方法插入位元組流到BLOB欄位。
- public void insertFile(File f) throws Exception{
- FileInputStream fis=new FileInputStream(f,Connection conn);
- byte[] buffer=new byte[1024];
- data=null;
- int sept=0;int len=0;
- while((sept=fis.read(buffer))!=-1){
- if(data==null){
- len=sept;
- data=buffer;
- }else{
- byte[] temp;
- int tempLength;
- tempLength=len+sept;
- temp=new byte[tempLength];
- System.arraycopy(data,0,temp,0,len);
- System.arraycopy(buffer,0,temp,len,sept);
- data=temp;
- len=tempLength;
- }
- if(len!=data.length()){
- byte temp=new byte[len];
- System.arraycopy(data,0,temp,0,len);
- data=temp;
- }
- }
- String sql="insert into fileData (filename,blobData) value(?,?)";
- PreparedStatement ps=conn.prepareStatement(sql);
- ps.setString(1,f.getName());
- ps.setObject(2,data);
- ps.executeUpdate();
- }
四. CLOB讀取的通用處理
Java程式碼- public static String getClobString(ResultSet rs, int col) {
- try {
- Clob c=resultSet.getClob(2);
- Reader reader=c.getCharacterStream():
- if (reader == null) {
- return null;
- }
- StringBuffer sb = new StringBuffer();
- char[] charbuf = new char[4096];
- for (int i = reader.read(charbuf); i > 0; i = reader.read(charbuf)) {
- sb.append(charbuf, 0, i);
- }
- return sb.toString();
- } catch (Exception e) {
- return "";
- }
- }