Oracle數據庫BLOB字段的存取

　　最近幾回碰到這個問題，需求是將一個文件或者文件流存儲到Oracle數據庫裏，Oracle8提供了Blob和Clob用來存儲二進制大對象數據，但是它和Java.sql.裏面的Blob不兼容，常常致使Blob字段沒法鎖定或者操做失敗，總之我總結了一些經驗你們共享。oracle培訓

　　首先創建測試數據表

　　drop table filelist;

　　commit;

　　CREATE TABLE SYSTEM.FILELIST (

　　"FILENAME" VARCHAR2(50) NOT NULL,

　　"FILESIZE" NUMBER(20) NULL,

　　"FILEBODY" BLOB NULL,

　　PRIMARY KEY("FILENAME"), UNIQUE("FILENAME")) ;

　　commit;

　　測試過程，首先將硬盤文件讀入數據庫，而後再讀出到硬盤的另外一個新文件裏，原碼以下：

　　import java.io.*;

　　import java.util.*;

　　import java.sql.*;

　　import oracle.sql.*;

　　import oracle.jdbc.driver.*;

　　import java.text.*;

　　public class test

　　{

　　public static void main(String args[]) throws java.io.IOException,java.sql.SQLException

　　{

　　dbBean db1=new dbBean();

　　/**

　　*這裏是個人數據聯接Bean

　　*你們能夠用本身的鏈接Bean

　　*/

　　byte a[]=null;//**將測試文件test.doc讀入此字節數組

　　java.io.FileInputStream fin=null;

　　java.io.FileOutputStream fout=null;

　　oracle.jdbc.OracleResultSet ors=null;//**這裏rs必定要用Oracle提供的

　　oracle.jdbc.driver.OraclePreparedStatement opst=null;//**PreparedStatement用

　　//Oracle提供的

　　try

　　{

　　java.io.File f1=new java.io.File("c:/temp/test.doc");

　　java.io.File f2=new java.io.File("c:/temp/testout.doc");//**從BLOB讀出的信息寫

　　//入該文件，和源文件對比測試用

　　fin=new java.io.FileInputStream(f1);

　　fout=new java.io.FileOutputStream(f2);

　　int flength=(int)f1.length();//**讀入文件的字節長度

　　System.out.println("file length::"+flength);

　　a=new byte[flength];

　　int i=0;int itotal=0;

　　/**將文件讀入字節數組

　　for (;itotal

　　{

　　i=fin.read(a,itotal,flength-itotal);

　　}

　　fin.close();

　　System.out.println("read itotal::"+itotal);

　　/**注意Oracle的 BLOB必定要用EMPTY_BLOB()初始化

　　String mysql="insert into filelist (FileName,FileSize,FileBody) values (?,?,EMPTY_BLOB())";

　　opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);

　　opst.setString(1,"wordtemplate");

　　opst.setInt (2,flength);

　　opst.executeUpdate();

　　opst.clearParameters();

　　/**插入其它數據後，定位BLOB字段

　　mysql="select filebody from filelist where filename=?";

　　opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);

　　opst.setString(1,"wordtemplate");

　　ors=(oracle.jdbc.OracleResultSet)opst.executeQuery();

　　if (ors.next())

　　{

　　oracle.sql.BLOB blob=ors.getBLOB(1);/**獲得BLOB字段

　　int j=blob.putBytes(1,a);/**將字節數組寫入BLOB字段

　　System.out.println("j:"+j);

　　db1.conn.commit();

　　ors.close();

　　}

　　System.out.println("insert into ok");

　　byte b[]=null;/**保存從BLOB讀出的字節

　　opst.clearParameters();

　　mysql="select filebody from filelist where filename=?";

　　opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);

　　opst.setString(1,"wordtemplate");

　　ors=(oracle.jdbc.OracleResultSet)opst.executeQuery();

　　if (ors.next())

　　{

　　oracle.sql.BLOB blob2=ors.getBLOB(1);

　　System.out.println("blob2 length:"+blob2.length());

　　b=blob2.getBytes(1,flength);/**從BLOB取出字節流數據

　　System.out.println("b length::"+b.length);

　　db1.conn.commit();

　　}

　　ors.close();

　　/**將從BLOB讀出的字節寫入文件

　　fout.write(b,0,b.length);

　　fout.close();

　　System.out.println("write itotal::"+b.length);

　　}

　　catch(Exception e)

　　{

　　System.out.println("errror :"+e.toString() );

　　e.printStackTrace();

　　}

　　finally

　　{ /**關閉全部數據聯接

　　stmt.close();

　　db1.closeConn();

　　}

　　}

　　}

　　編譯運行在TomCat下調試經過。

　　須要注意的是Blob存取的過程，通常先存入和BLOB相關的控制數據，如文件的名字，而後查詢定位BLOB字段，利用OracleBlob提供的方法：

　　public int putBytes(long pos,byte bytes[])

　　public byte[] getBytes(long pos,byte bytes[])

　　或者利用

　　public OutputStream getBinaryOutputStream() throws SQLException

　　public InputStream getBinaryStream() throws SQLException

　　由於利用輸入輸出流總歸仍是利用到字節數組緩衝流，因此就不舉例子了。