在Oracle中存取BLOB對(duì)象實(shí)現(xiàn)文件的上傳和下載

最近做一個(gè) J2EE 項(xiàng)目，需要在 JSP 頁(yè)面實(shí)現(xiàn)對(duì)文件的上傳和下載。很早以前就知道 JDBC 支持大對(duì)象（ LOB ）的存取，以為很容易，做起來(lái)才發(fā)現(xiàn)問(wèn)題多多，讀了一大堆文章，反而沒(méi)有什么頭緒了。正如一位網(wǎng)友文章所講：“…網(wǎng)絡(luò)上的教程 99% 都是行不通的，連 SUN 自己的文檔都一直錯(cuò)誤……”，實(shí)際情況大致如此了。

?

?

?

存取 BLOB 出現(xiàn)這么多問(wèn)題，我認(rèn)為大半是由數(shù)據(jù)庫(kù)開(kāi)發(fā)商、應(yīng)用服務(wù)器商在 JDBC 驅(qū)動(dòng)上的不兼容性帶來(lái)的。而實(shí)際應(yīng)用中，每個(gè)人的開(kāi)發(fā)運(yùn)行環(huán)境不同，使得某個(gè)網(wǎng)友的 solution 沒(méi)有辦法在別人的應(yīng)用中重現(xiàn)，以至于罵聲一片。至于為什么會(huì)不兼容、有哪些問(wèn)題，我沒(méi)有時(shí)間去弄清，這里只說(shuō)說(shuō)我們?cè)鯓咏鉀Q了問(wèn)題的。

?

?

?

基于上述原因，先列出我們的開(kāi)發(fā)環(huán)境，免得有人配不出來(lái)，招人唾罵。

數(shù)據(jù)庫(kù) Oracle 9i

應(yīng)用服務(wù)器 BEA Weblogic 8.11

開(kāi)發(fā)工具 JBuilder X

?

?

?

在 JSP 實(shí)現(xiàn)文件 Upload/Download 可以分成這樣幾塊 ：文件提交到形成 InputSteam ； InputSteam 以 BLOB 格式入庫(kù)；數(shù)據(jù)從庫(kù)中讀出為 InputSteam ； InputStream 輸出到頁(yè)面形成下載文件。先說(shuō) BLOB 吧。

?

?

?

1．? BLOB 入庫(kù)

（1）?????? 直接獲得數(shù)據(jù)庫(kù)連接的情況

這是 Oracle 提供的標(biāo)準(zhǔn)方式，先插入一個(gè)空 BLOB 對(duì)象，然后 Update 這個(gè)空對(duì)象。代碼如下：

// 得到數(shù)據(jù)庫(kù)連接（驅(qū)動(dòng)包是 weblogic 的，沒(méi)有下載任何新版本）

Class.forName("oracle.jdbc.driver.OracleDriver");

Connection con = DriverManager.getConnection(

????????? "jdbc:oracle:thin:@localhost:1521:testdb", "test", "test");

// 處理事務(wù)

con.setAutoCommit(false);

Statement st = con.createStatement();

// 插入一個(gè)空對(duì)象

st.executeUpdate("insert into BLOBIMG? values(103,empty_blob())");

// 用 for update 方式鎖定數(shù)據(jù)行

ResultSet rs = st.executeQuery(

????????? "select contents from? BLOBIMG? where? id=103 for update");

if (rs.next()) {

?? // 得到 java.sql.Blob 對(duì)象，然后 Cast 為 oracle.sql.BLOB

oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(1).;

?? // 到數(shù)據(jù)庫(kù)的輸出流

OutputStream outStream = blob.getBinaryOutputStream();

?? // 這里用一個(gè)文件模擬輸入流

File file = new File("d:\\proxy.txt");

? InputStream fin = new FileInputStream(file);

// 將輸入流寫(xiě)到輸出流

byte[] b = new byte[blob.getBufferSize()];

??????? int len = 0;

??????? while ( (len = fin.read(b)) != -1) {

????????? outStream.write(b, 0, len);

????????? //blob.putBytes(1,b);

??????? }

?

?

?

?? // 依次關(guān)閉（注意順序）

fin.close();

?? outStream.flush();

?? outStream.close();

?? con.commit();

?? con.close();

?

?

?

（2）?????? 通過(guò) JNDI 獲得數(shù)據(jù)庫(kù)連接

在 Weblogic 中配置到 Oracle 的 JDBC Connection Pool 和 DataSource ，綁定到 Context 中，假定綁定名為 ”orads” 。

為了得到數(shù)據(jù)庫(kù)連接，做一個(gè)連接工廠(chǎng)，主要代碼如下：

Context context = new InitialContext();

ds = (DataSource) context.lookup("orads");

return ds.getConnection();

以下是 BLOB 寫(xiě)入數(shù)據(jù)庫(kù)的代碼：

?

?

?

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 ，會(huì)報(bào) 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 出庫(kù)

從數(shù)據(jù)庫(kù)中讀出 BLOB 數(shù)據(jù)沒(méi)有上述由于連接池的不同帶來(lái)的差異，只需要 J2SE 的標(biāo)準(zhǔn)類(lèi) java.sql.Blob 就可以取得輸出流（注意區(qū)別 java.sql.Blob 和 oracle.sql.BLOB ）。代碼如下：

Connection con = ConnectionFactory.getConnection();

con.setAutoCommit(false);

Statement st = con.createStatement();

// 這里的 SQL 語(yǔ)句不再需要 ”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 數(shù)據(jù)寫(xiě)入文件

??? byte[] b = new byte[1024];

??? int len = 0;

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

????????? fout.write(b, 0, len);

??????? }

? // 依次關(guān)閉

? fout.close();

? ins.close();

? con.commit();

? con.close();

?

?

?

3．? 從 JSP 頁(yè)面提交文件到數(shù)據(jù)庫(kù)

?

?

?

（1）?????? 提交頁(yè)面的代碼如下：

<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 沒(méi)有提供文件上傳的處理能力，只有使用第三方的開(kāi)發(fā)包。網(wǎng)絡(luò)上開(kāi)源的包有很多，我們這里選擇 Apache Jakarta 的 FileUpload ，在 http://jakarta.apache.org/commons/fileupload/index.html 可以得到下載包和完整的 API 文檔。法奧為 adajspException

處理頁(yè)面（ handle.jsp ）的代碼如下

<%

boolean isMultipart = FileUpload.isMultipartContent(request);

??? if (isMultipart) {

????? // 建立一個(gè)新的 Upload 對(duì)象

????? DiskFileUpload upload = new DiskFileUpload();

?

?

?

??? // 設(shè)置上載文件的參數(shù)

??? //upload.setSizeThreshold(yourMaxMemorySize);

??? //upload.setSizeMax(yourMaxRequestSize);

??? String rootPath = getServletConfig().getServletContext().getRealPath("/") ;

??? upload.setRepositoryPath(rootPath+"\\uploads");

?

?

?

???? // 分析 request 中的傳來(lái)的文件流，返回 Item 的集合，

???? // 輪詢(xún) Items ，如果不是表單域，就是一個(gè)文件對(duì)象。

????? List items = upload.parseRequest(request);

????? Iterator iter = items.iterator();

????? while (iter.hasNext()) {

??????? FileItem item = (FileItem) iter.next();

??????? // 如果是文件對(duì)象

if (!item.isFormField()) {

?

?

?

????????? // 如果是文本文件，可以直接顯示

????????? //out.println(item.getString());

?

?

?

????????? // 將上載的文件寫(xiě)到服務(wù)器的 \WEB-INF\webstart\ 下，文件名為 test.txt

????????? //File uploadedFile = new File(rootPath+"\\uploads\\test.txt");

????????? //item.write(uploadedFile);

?

?

?

????? ??// 下面的代碼是將文件入庫(kù)（略）：

??????? // 注意輸入流的獲取

…

InputStream uploadedStream = item.getInputStream();

…

??????? }

??????? // 否則是普通表單

else{

????????? out.println("FieldName: " + item.getFieldName()+"<br>");

????????? out.println("Value: "+item.getString()+"<br>");??????? }

????? }

??? }

%>

?

?

?

4．? 從數(shù)據(jù)庫(kù)讀取 BLOB 然后保存到客戶(hù)端磁盤(pán)上

這段代碼有點(diǎn)詭異，執(zhí)行后將會(huì)彈出文件保存對(duì)話(huà)窗口，將 BLOB 數(shù)據(jù)讀出保存到本地文件。全文列出如下：

<%@ 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();

????? }

%>

注意，在 <% … … %> 之外，絕對(duì)不能有任何字符，空格或回車(chē)都不行 ，不然會(huì)導(dǎo)致 outputStream 出錯(cuò)，對(duì)非 ASCII 輸出文件來(lái)說(shuō)就是格式錯(cuò)誤不可讀。