在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）提交页面的代码如下：
　　
　　<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-INF\webstart\下，文件名为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数据读出保存到本地