Oracle数据库中BLOB字段的存取问题

以下的文章主要是对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

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

【编辑推荐】

LTO归档解决方案容量、性能和功能介绍