最近做一个
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 阅读(1916)
评论(0) 编辑 收藏