Oracle數據庫中BLOB字段的存取問題

以下的文章主要是對Oracle數據庫中BLOB字段的存取問題的介紹，我在經常會碰到Oracle數據庫中BLOB字段的存取這一問題，需求是將一個文件或者文件流存儲到Oracle數據庫裡，Oracle8提供了Blob和Clob用來存儲二進制大對象數據。

可是它和Java.sql.裡面的Blob不兼容，經常導致Blob字段無法鎖定或者操作失敗，總之我總結了一些經驗大家共享。

首先建立測試數據表

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;  

測試過程，首先將硬盤文件讀入Oracle數據庫，然後再讀出到硬盤的另一個新文件裡，原碼如下：

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<flength;iitotal=i+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字段，利用Oracle數據庫Blob提供的方法：

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

或者利用

public OutputStream getBinaryOutputStream() throws SQLException  
public InputStream getBinaryStream() throws SQLException  

因為利用輸入輸出流總歸還是利用到字節數組緩沖流，所以就不舉例子了。