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

最近做一个 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) 提交页面的代码如下:

1<form action="handle.jsp" enctype="multipart/form-data" method="post">
2<input name="id" type="hidden" value="103"/>
3<input name="fileToUpload" type="file"/>
4<input type="submit" value="Upload"/>
5</form>

(2) 由于 JSP 没有提供文件上传的处理能力,只有使用第三方的开发包。网络上开源的包有很多,我们这里选择 Apache Jakarta 的 FileUpload ,在 http://jakarta.apache.org/commons/fileupload/index.html 可以得到下载包和完整的 API 文档。 法奥为 adajspException

处理页面( handle.jsp )的代码如下

 1 
 2
 3boolean isMultipart = FileUpload.isMultipartContent(request); 
 4
 5if (isMultipart) { 
 6
 7//  建立一个新的  Upload  对象 
 8
 9DiskFileUpload upload = new DiskFileUpload(); 
10
11//  设置上载文件的参数 
12
13//upload.setSizeThreshold(yourMaxMemorySize); 
14
15//upload.setSizeMax(yourMaxRequestSize); 
16
17String rootPath = getServletConfig().getServletContext().getRealPath("/") ; 
18
19upload.setRepositoryPath(rootPath+"\\\uploads"); 
20
21//  分析  request  中的传来的文件流,返回  Item  的集合, 
22
23//  轮询  Items  ,如果不是表单域,就是一个文件对象。 
24
25List items = upload.parseRequest(request); 
26
27Iterator iter = items.iterator(); 
28
29while (iter.hasNext()) { 
30
31FileItem item = (FileItem) iter.next(); 
32
33//  如果是文件对象 
34
35if (!item.isFormField()) { 
36
37//  如果是文本文件,可以直接显示 
38
39//out.println(item.getString()); 
40
41//  将上载的文件写到服务器的  \WEB-INF\webstart\  下,文件名为  test.txt 
42
43//File uploadedFile = new File(rootPath+"\\\uploads\\\test.txt"); 
44
45//item.write(uploadedFile); 
46
47//  下面的代码是将文件入库(略): 
48
49//  注意输入流的获取 
50
5152
53InputStream uploadedStream = item.getInputStream(); 
54
5556
57} 
58
59//  否则是普通表单 
60
61else{ 
62
63out.println("FieldName: " + item.getFieldName()+"

<br/>

1"); 
2
3out.println("Value: "+item.getString()+"

<br/>

1");  } 
2
3} 
4
5} 

4. 从数据库读取 BLOB 然后保存到客户端磁盘上

这段代码有点诡异,执行后将会弹出文件保存对话窗口,将 BLOB 数据读出保存到本地文件。全文列出如下:

1@ page contentType="text/html; charset=GBK" import="java.io.*" import="java.sql.*" import="test.global.ConnectionFactory"

Connection con = ConnectionFactory.getConnection();

con.setAutoCommit(false);

Statement st = con.createStatement();

ResultSet rs = st.executeQuery(

"select contents from BLOBIMG where id=103 ");

if (rs.next()) {

Blob blob = rs.getBlob(1);

InputStream ins = blob.getBinaryStream();

response.setContentType("application/unknown");

response.addHeader("Content-Disposition", "attachment; filename="+"output.txt");

OutputStream outStream = response.getOutputStream();

byte[] bytes = new byte[1024];

int len = 0;

while ((len=ins.read(bytes))!=-1) {

outStream.write(bytes,0,len);

}

ins.close();

outStream.close();

outStream = null;

con.commit();

con.close();

}

1
2注意,在  ```
3 … … 
4``` 之外,绝对不能有任何字符,空格或回车都不行  ,不然会导致  outputStream  出错,对非  ASCII  输出文件来说就是格式错误不可读。
Published At
Categories with 数据库类
Tagged with
comments powered by Disqus