如何使用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;

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

/**
* @author aaa
* @email
* @version
*/
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;itotal=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字段，利用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
因为利用输入输出流总归还是利用到字节数组缓冲流，所以就不举例子了。

这个例子有点小问题，按照作者的写法会报“ORA-22920: 未锁定含有 LOB 值的行”的错误，究其原因是因为没有锁定要更新的行记录。将 mysql="select filebody from filelist where filename=?"中的SQL语句加上 for update即可。如：mysql="select filebody from filelist where filename=? for update"。
注意：
在执行查询操作前，必须将connecction的自动提交模式置为false(默认为true).如db1.conn.setAutoCommit(false);
否则会报“ORA-01002: fetch out of sequence”的错误。