在Oracle中存取BLOB对象实现文件的上传和下载

转载于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数据读出保存到本地

posted on 2008-09-04 21:26 鲁胜迪 阅读(1551) 评论(0)  编辑  收藏 所属分类: 一点点


只有注册用户登录后才能发表评论。


网站导航:
 
<2008年9月>
31123456
78910111213
14151617181920
21222324252627
2829301234
567891011

导航

统计

常用链接

留言簿(4)

随笔分类

随笔档案

文章分类

新闻分类

搜索

最新评论

阅读排行榜

评论排行榜