以下的文章主要是对Oracle数据库中BLOB字段的存取问题的介绍，我在经常会碰到Oracle数据库中BLOB字段的存取这一问题，需求是将一个文件或者文件流存储到Oracle数据库里，Oracle8提供了Blob和Clob用来存储二进制大对象数据。

可是它和Java.sql.里面的Blob不兼容，经常导致Blob字段无法锁定或者操作失败，总之我总结了一些经验大家共享。

首先建立测试数据表

droptablefilelist; 
commit; 
CREATETABLESYSTEM.FILELIST( 
"FILENAME"VARCHAR2(50)NOTNULL, 
"FILESIZE"NUMBER(20)NULL, 
"FILEBODY"BLOBNULL, 
PRIMARYKEY("FILENAME"),UNIQUE("FILENAME")); 
commit; 

测试过程，首先将硬盘文件读入Oracle数据库，然后再读出到硬盘的另一个新文件里，原码如下：

importjava.io.*; 
importjava.util.*; 
importjava.sql.*; 
importoracle.sql.*; 
importoracle.jdbc.driver.*; 
importjava.text.*; 
publicclasstest 
{ 
publicstaticvoidmain(Stringargs[])throwsjava.io.IOException,java.sql.SQLException 
{ 
dbBeandb1=newdbBean(); 
/** 

*这里是我的数据联接Bean

*大家可以用自己的连接Bean

*/ 
bytea[]=null; 

**将测试文件test.doc读入此字节数组

java.io.FileInputStreamfin=null; 
java.io.FileOutputStreamfout=null; 
oracle.jdbc.OracleResultSetors=null； 

**这里rs一定要用Oracle数据库提供的

oracle.jdbc.driver.OraclePreparedStatementopst=null;

**PreparedStatement用

Oracle提供的

try 
{ 
java.io.Filef1=newjava.io.File("c:/temp/test.doc"); 
java.io.Filef2=newjava.io.File("c:/temp/testout.doc"); 

**从BLOB读出的信息写

//入该文件，和源文件对比测试用

fin=newjava.io.FileInputStream(f1); 
fout=newjava.io.FileOutputStream(f2); 

int flength=(int)f1.length();//**读入文件的字节长度

System.out.println("filelength::"+flength); 
a=newbyte[flength]; 
inti=0;intitotal=0; 

/**将文件读入字节数组

for(;itotal<flength;iitotal=i+itotal) 
{ 
i=fin.read(a,itotal,flength-itotal); 
} 
fin.close(); 
System.out.println("readitotal::"+itotal); 

/**注意Oracle数据库的 BLOB一定要用EMPTY_BLOB()初始化

Stringmysql="insertintofilelist(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="selectfilebodyfromfilelistwherefilename=?"; 
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("insertintook"); 

byte b[]=null;/**保存从BLOB读出的字节

opst.clearParameters(); 
mysql="selectfilebodyfromfilelistwherefilename=?"; 
opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql); 
opst.setString(1,"wordtemplate"); 
ors=(oracle.jdbc.OracleResultSet)opst.executeQuery(); 
if(ors.next()) 
{ 
oracle.sql.BLOBblob2=ors.getBLOB(1); 
System.out.println("blob2length:"+blob2.length()); 

b=blob2.getBytes(1,flength);/**从BLOB取出字节流数据

System.out.println("blength::"+b.length); 
db1.conn.commit(); 
} 
ors.close(); 

/**将从BLOB读出的字节写入文件

fout.write(b,0,b.length); 
fout.close(); 
System.out.println("writeitotal::"+b.length); 
} 
catch(Exceptione) 
{ 
System.out.println("errror:"+e.toString()); 
e.printStackTrace(); 
} 
finally 

{ /**关闭所有数据联接

stmt.close(); 
db1.closeConn(); 
} 
} 
} 

编译运行在TomCat下调试通过。

需要注意的是Blob存取的过程，一般先存入和BLOB相关的控制数据，如文件的名字，然后查询定位BLOB字段，利用Oracle数据库Blob提供的方法：

publicintputBytes(longpos,bytebytes[]) 
publicbyte[]getBytes(longpos,bytebytes[]) 

或者利用

publicOutputStreamgetBinaryOutputStream()throwsSQLException 
publicInputStreamgetBinaryStream()throwsSQLException 

因为利用输入输出流总归还是利用到字节数组缓冲流，所以就不举例子了。