转载于http://www.iocblog.net/java/j2ee/j2ee-oracle-blob.html
最近做一个j2ee项目，需要在jsp页面实现对文件的上传和下载。很早以前就知道jdbc支持大对象（lob）的存取，以为很容易，做起来才发现问题多
多，读了一大堆文章，反而没有什么头绪了。正如一位网友文章所讲：“…网络上的教程99%都是行不通的，连sun自己的文档都一直错误……”，实际情况大
致如此了。
存取blob出现这么多问题，我认为大半是由数据库开发商、应用服务器商在jdbc驱动上的不兼容性带来的。而实际应用中，每个人的开发运行环境不
同，使得某个网友的solution没有办法在别人的应用中重现，以至于骂声一片。至于为什么会不兼容、有哪些问题，我没有时间去弄清，这里只说说我们怎
样解决了问题的。
基于上述原因，先列出我们的开发环境，免得有人配不出来，招人唾骂。
数据库 oracle 9i
应用服务器 bea weblogic 8.11
开发工具 jbuilder x
在jsp实现文件upload/download可以分成这样几块 ：文件提交到形成inputsteam；inputsteam以blob格式入库；数据从库中读出为inputsteam；inputstream输出到页面形成下载文件。先说blob吧。
1.blob入库
（1）直接获得数据库连接的情况
这是oracle提供的标准方式，先插入一个空blob对象，然后update这个空对象。代码如下：
//得到数据库连接（驱动包是weblogic的，没有下载任何新版本）
class.forname("oracle.jdbc.driver.oracledriver");
connection con = drivermanager.getconnection(
"jdbc:oracle:thin:@localhost:1521:testdb", "test", "test");
//处理事务
con.setautocommit(false);
statement st = con.createstatement();
//插入一个空对象
st.executeupdate("insert into blobimg values(103,empty_blob())");
//用for update方式锁定数据行
resultset rs = st.executequery(
"select contents from blobimg where id=103 for update");
if (rs.next()) {
//得到java.sql.blob对象，然后cast为oracle.sql.blob
oracle.sql.blob blob = (oracle.sql.blob) rs.getblob(1).;
//到数据库的输出流
outputstream outstream = blob.getbinaryoutputstream();
//这里用一个文件模拟输入流
file file = new file("d:"proxy.txt");
inputstream fin = new fileinputstream(file);
//将输入流写到输出流
byte[] b = new byte[blob.getbuffersize()];
int len = 0;
while ( (len = fin.read(b)) != -1) {
outstream.write(b, 0, len);
//blob.putbytes(1,b);
}
//依次关闭（注意顺序）
fin.close();
outstream.flush();
outstream.close();
con.commit();
con.close();
（2）通过jndi获得数据库连接
在weblogic中配置到oracle的jdbc connection pool和datasource，绑定到context中，假定绑定名为”orads”。
为了得到数据库连接，做一个连接工厂，主要代码如下：
context context = new initialcontext();
ds = (datasource) context.lookup("orads");
return ds.getconnection();
以下是blob写入数据库的代码：
connection con = connectionfactory.getconnection();
con.setautocommit(false);
statement st = con.createstatement();
st.executeupdate("insert into blobimg values(103,empty_blob())");
resultset rs = st.executequery(
"select contents from blobimg where id=103 for update");
if (rs.next()) {
//上面代码不变
//这里不能用oracle.sql.blob，会报classcast 异常
weblogic.jdbc.vendor.oracle.oraclethinblobblob = (weblogic.jdbc.vendor.oracle.oraclethinblob) rs.getblob(1);
//以后代码也不变
outputstream outstream = blob.getbinaryoutputstream();
file file = new file("d:"proxy.txt");
inputstream fin = new fileinputstream(file);
byte[] b = new byte[blob.getbuffersize()];
int len = 0;
while ( (len = fin.read(b)) != -1) {
outstream.write(b, 0, len);
}
fin.close();
outstream.flush();
outstream.close();
con.commit();
con.close();
2．blob出库
从数据库中读出blob数据没有上述由于连接池的不同带来的差异，只需要j2se的标准类java.sql.blob就可以取得输出流（注意区别java.sql.blob和oracle.sql.blob）。代码如下：
connection con = connectionfactory.getconnection();
con.setautocommit(false);
statement st = con.createstatement();
//这里的sql语句不再需要”for update”
resultset rs = st.executequery(
"select contents from blobimg where id=103 ");
if (rs.next()) {
java.sql.blob blob = rs.getblob(1);
inputstream ins = blob.getbinarystream();
//用文件模拟输出流
file file = new file("d:"output.txt");
outputstream fout = new fileoutputstream(file);
//下面将blob数据写入文件
byte[] b = new byte[1024];
int len = 0;
while ( (len = ins.read(b)) != -1) {
fout.write(b, 0, len);
}
//依次关闭
fout.close();
ins.close();
con.commit();
con.close();
3.从jsp页面提交文件到数据库
（1）提交页面的代码如下：
<form action="handle.jsp" enctype="multipart/form-data" method="post" >
<input type="hidden" name="id" value="103"/>
<input type="file" name="filetoupload">
<input type="submit" value="upload">
</form>
（2）由于jsp没有提供文件上传的处理能力，只有使用第三方的开发包。网络上开源的包有很多，我们这里选择apache
jakarta的fileupload，在http:
//jakarta.apache.org/commons/fileupload/index.html
可以得到下载包和完整的api文档。法奥为adajspexception
处理页面（handle.jsp）的代码如下
<%
boolean ismultipart = fileupload.ismultipartcontent(request);
if (ismultipart) {
// 建立一个新的upload对象
diskfileupload upload = new diskfileupload();
// 设置上载文件的参数
//upload.setsizethreshold(yourmaxmemorysize);
//upload.setsizemax(yourmaxrequestsize);
string rootpath = getservletconfig().getservletcontext().getrealpath("/") ;
upload.setrepositorypath(rootpath+""uploads");
// 分析request中的传来的文件流，返回item的集合，
// 轮询items，如果不是表单域，就是一个文件对象。
list items = upload.parserequest(request);
iterator iter = items.iterator();
while (iter.hasnext()) {
fileitem item = (fileitem) iter.next();
//如果是文件对象
if (!item.isformfield()) {
//如果是文本文件，可以直接显示
//out.println(item.getstring());
//将上载的文件写到服务器的web-infwebstart下，文件名为test.txt
//file uploadedfile = new file(rootpath+""uploads"test.txt");
//item.write(uploadedfile);
//下面的代码是将文件入库（略）：
//注意输入流的获取
…
inputstream uploadedstream = item.getinputstream();
…
}
//否则是普通表单
else{
out.println("fieldname: " + item.getfieldname()+"<br>");
out.println("value: "+item.getstring()+"<br>"); }
}
}
%>
4．从数据库读取blob然后保存到客户端磁盘上
这段代码有点诡异，执行后将会弹出文件保存对话窗口，将blob数据读出保存到本地