最近做一个 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
51…
52
53InputStream uploadedStream = item.getInputStream();
54
55…
56
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 输出文件来说就是格式错误不可读。