随笔-8  评论-2  文章-24  trackbacks-0

最近做一个 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 数据读出保存到本地文件。全文列出如下:

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

      }

%>

注意,在 <% … … %> 之外,绝对不能有任何字符,空格或回车都不行 ,不然会导致 outputStream 出错,对非 ASCII 输出文件来说就是格式错误不可读。

 

5.  最后一个问题就是把以 BLOB 形式存放的图像文件直接显示到 JSP 页面上

解决办法是:首先将图像文件从数据库中读出形成 InputStream ,然后用 Servlet 写到页面输出流上。最后,将这个 servlet 包含到 JSP 页面适当的图像位置上。

 

Servlet 代码如下:

public void doGet(HttpServletRequest request, HttpServletResponse response) throws

      ServletException, IOException {

    int id = Integer.parseInt(request.getParameter("id"));

 

    try {

      Connection con = ConnectionFactory.getConnection();

      con.setAutoCommit(false);

      String sql = "select contents from  BLOBIMG  where  id= ? ";

      PreparedStatement psmt = con.prepareStatement(sql);

      psmt.setInt(1, id);

      ResultSet rs = psmt.executeQuery();

      if (rs.next()) {

        Blob bb = rs.getBlob(1);

        InputStream ins = bb.getBinaryStream();

 

         response.setContentType("image/gif");

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

      }

    }

    catch (Exception ex) {}

  }

 

JSP 代码如下:

<img src="showimgae?id=110">

注意在 web.xml 中配置好 Servlet Mapping

 

这样, BLOB JSP 中的基本应用就完整了。

 

本文参考了大量网友文章,特此表示感谢。

1.        通过 JDBC 操纵 Oracle 数据库 LOB 字段的几种情况分析 http://dev.csdn.net/develop/article/26/26786.shtm

2.        关于将文件用 java.sql.Blob 类型的 blob 操作写入 oracle 数据库中的 blob http://community.csdn.net/Expert/FAQ/FAQ_Index.asp?id=197116

3.        weblogic7 可以操作 Oracle9i 的大字段 ,Weblogic8 为什么不可以 ? http://dev2dev.bea.com.cn/bbs/thread.jspa?forumID=123&threadID=5390&messageID=23598

4.        How to show file download dialog box in IE 6.0 http://www.experts-exchange.com/Web/Web_Languages/JSP/Q_20842012.html

5.        SQL SERVER 2000 中的 JPEG 图片在 Jsp 上显示乱码问题 http://search.csdn.net/Expert/topic/2462/2462925.xml?temp=3.071231E-02



环境:
Database: Oracle 9i
App Server: BEA Weblogic 8.14
表结构:
CREATE TABLE TESTBLOB (ID Int, NAME Varchar2(20), BLOBATTR Blob)
CREATE TABLE TESTBLOB (ID Int, NAME Varchar2(20), CLOBATTR Clob)
 
JAVA可以通过JDBC,也可以通过JNDI访问并操作数据库,这两种方式的具体操作存在着一些差异,由于通过App Server的数据库连接池JNDI获得的数据库连接提供的java.sql.Blob和java.sql.Clob实现类与JDBC方式提供的不同,因此在入库操作的时候需要分别对待;出库操作没有这种差异,因此不用单独对待。

一、BLOB操作
1、入库
(1)JDBC方式
    //通过JDBC获得数据库连接
    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();
    //插入一个空对象empty_blob()
    st.executeUpdate("insert into TESTBLOB (ID, NAME, BLOBATTR) values (1, "thename", empty_blob())");
    //锁定数据行进行更新,注意“for update”语句
    ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1 for update");
    if (rs.next())
    {
        //得到java.sql.Blob对象后强制转换为oracle.sql.BLOB
        oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob("BLOBATTR");
        OutputStream outStream = blob.getBinaryOutputStream();
        //data是传入的byte数组,定义:byte[] data
        outStream.write(data, 0, data.length);
    }
    outStream.flush();
    outStream.close();
    con.commit();
    con.close();
(2)JNDI方式
    //通过JNDI获得数据库连接
    Context context = new InitialContext();
    ds = (DataSource) context.lookup("ORA_JNDI");
    Connection con = ds.getConnection();
    con.setAutoCommit(false);
    Statement st = con.createStatement();
    //插入一个空对象empty_blob()
    st.executeUpdate("insert into TESTBLOB (ID, NAME, BLOBATTR) values (1, "thename", empty_blob())");
    //锁定数据行进行更新,注意“for update”语句
    ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1 for update");
    if (rs.next())
    {
        //得到java.sql.Blob对象后强制转换为weblogic.jdbc.vendor.oracle.OracleThinBlob(不同的App Server对应的可能会不同)
        weblogic.jdbc.vendor.oracle.OracleThinBlob blob = (weblogic.jdbc.vendor.oracle.OracleThinBlob) rs.getBlob("BLOBATTR");
        OutputStream outStream = blob.getBinaryOutputStream();
        //data是传入的byte数组,定义:byte[] data
        outStream.write(data, 0, data.length);
    }
    outStream.flush();
    outStream.close();
    con.commit();
    con.close();
2、出库
    //获得数据库连接
    Connection con = ConnectionFactory.getConnection();
    con.setAutoCommit(false);
    Statement st = con.createStatement();
    //不需要“for update”
    ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1");
    if (rs.next())
    {
        java.sql.Blob blob = rs.getBlob("BLOBATTR");
        InputStream inStream = blob.getBinaryStream();
        //data是读出并需要返回的数据,类型是byte[]
        data = new byte[input.available()];
        inStream.read(data);
        inStream.close();
    }
    inStream.close();
    con.commit();
    con.close();
 
二、CLOB操作
1、入库
(1)JDBC方式
    //通过JDBC获得数据库连接
    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();
    //插入一个空对象empty_clob()
    st.executeUpdate("insert into TESTCLOB (ID, NAME, CLOBATTR) values (1, "thename", empty_clob())");
    //锁定数据行进行更新,注意“for update”语句
    ResultSet rs = st.executeQuery("select CLOBATTR from TESTCLOB where ID=1 for update");
    if (rs.next())
    {
        //得到java.sql.Clob对象后强制转换为oracle.sql.CLOB
        oracle.sql.CLOB clob = (oracle.sql.CLOB) rs.getClob("CLOBATTR");
        Writer outStream = clob.getCharacterOutputStream();
        //data是传入的字符串,定义:String data
        char[] c = data.toCharArray();
        outStream.write(c, 0, c.length);
    }
    outStream.flush();
    outStream.close();
    con.commit();
    con.close();
(2)JNDI方式
    //通过JNDI获得数据库连接
    Context context = new InitialContext();
    ds = (DataSource) context.lookup("ORA_JNDI");
    Connection con = ds.getConnection();
    con.setAutoCommit(false);
    Statement st = con.createStatement();
    //插入一个空对象empty_clob()
    st.executeUpdate("insert into TESTCLOB (ID, NAME, CLOBATTR) values (1, "thename", empty_clob())");
    //锁定数据行进行更新,注意“for update”语句
    ResultSet rs = st.executeQuery("select CLOBATTR from TESTCLOB where ID=1 for update");
    if (rs.next())
    {
        //得到java.sql.Clob对象后强制转换为weblogic.jdbc.vendor.oracle.OracleThinClob(不同的App Server对应的可能会不同)
        weblogic.jdbc.vendor.oracle.OracleThinClob clob = (weblogic.jdbc.vendor.oracle.OracleThinClob) rs.getClob("CLOBATTR");
        Writer outStream = clob.getCharacterOutputStream();
        //data是传入的字符串,定义:String data
        char[] c = data.toCharArray();
        outStream.write(c, 0, c.length);
    }
    outStream.flush();
    outStream.close();
    con.commit();
    con.close();
2、出库
    //获得数据库连接
    Connection con = ConnectionFactory.getConnection();
    con.setAutoCommit(false);
    Statement st = con.createStatement();
    //不需要“for update”
    ResultSet rs = st.executeQuery("select CLOBATTR from TESTCLOB where ID=1");
    if (rs.next())
    {
        java.sql.Clob clob = rs.getClob("CLOBATTR");
        Reader inStream = clob.getCharacterStream();
        char[] c = new char[(int) clob.length()];
        inStream.read(c);
        //data是读出并需要返回的数据,类型是String
        data = new String(c);
        inStream.close();
    }
    inStream.close();
    con.commit();
    con.close();
 
需要注意的地方:
1、java.sql.Blob、oracle.sql.BLOB、weblogic.jdbc.vendor.oracle.OracleThinBlob几种类型的区别
2、java.sql.Clob、oracle.sql.CLOB、weblogic.jdbc.vendor.oracle.OracleThinClob几种类型的区别
posted on 2006-12-19 13:39 MyBox 阅读(1908) 评论(0)  编辑  收藏

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


网站导航: