oracle.sql.BLOB
这两个blob仅仅是大小写不同,但是差异很大,java.sql.Blob是一个接口,而oracle.sql.BLOB是一个实现java.sql.Blob的类,并且还有很多扩展的属性和方法,注意不要搞混了。
2、JDBC2.0和JDBC3.0的问题
classes12.zip实现了JDBC2.0(JDK1.3),而JDBC2.0对于Blob的操作只有读,没有写,所以classes12.zip只好自己扩展了一套对Blob进行写的API,我的例子就是用了这套API。
ojdbc14.jar实现了JDBC3.0(JDK1.4),JDBC3.0已经包括了对Blob写的操作,而ojdbc14.jar也实现了该API。
总之注意这些问题。
你用的是什么容器?是不是weblogic?如果是weblogic,并且通过datasourse获取connection,取出来的就不是oracle.sql.BLOB,而是weblogic封装过的OracleThinBlob,所以cast的时候肯定会出错,但是如果在程序里面cast成OracleThinBlob,就会造成对weblogic的依赖,所以我在dao的impl中用反射解耦。并且这个只是在使用oracle的thin驱动的时候才会出现的问题
写CLOB的代码片段:
Java代码
File blobFile = new File("image.jpg");
int file_length = (int)blobFile.length();
FileInputStream blobInStream = new FileInputStream(blobFile);
PreparedStatement insert_prepared = null;
insert_prepared = m_conn.prepareStatement(query);
insert_prepared.setString(1, id);
insert_prepared.setBinaryStream(2, blobInStream, file_length);
insert_prepared.setString(3, tel);
insert_prepared.executeUpdate();
m_conn.commit();
String SqlStr = "update TextInfo set Content=empty_clob()
where TextInfoKey=" + Integer.toString(textinfokey);
myConn.setAutoCommit(false);
java.sql.PreparedStatement pstmt =
myConn.prepareStatement(SqlStr);
pstmt.executeUpdate();
SqlStr = "select Content from TextInfo where TextInfoKey=" +
Integer.toString(textinfokey) + " for update";
java.sql.Statement st = myConn.createStatement();
java.sql.ResultSet rs = st.executeQuery(SqlStr);
java.sql.Clob clob ;
if (rs.next()) {
clob = rs.getClob("Content");
weblogic.jdbc.rmi.SerialOracleClob cast1
=(weblogic.jdbc.rmi.SerialOracleClob)clob;
weblogic.jdbc.rmi.internal.OracleTClobImpl cast2
=(weblogic.jdbc.rmi.internal.OracleTClobImpl)cast1.getTheRealClob();
CLOB myClob = (oracle.sql.CLOB)cast2.getTheRealClob();
java.io.Writer out=myClob.getCharacterOutputStream
();
out.write(content);
out.flush();
out.close();
-------------------------------------------------------------------------------------------------
存取BLOB出现这么多问题,我认为大半是由数据库开发商、应用服务器商在JDBC驱动上的不兼容性带来的。而实际应用中,每个人的开发运行环境不同,使得某个网友的solution没有办法在别人的应用中重现,以至于骂声一片。至于为什么会不兼容、有哪些问题,我没有时间去弄清,这里只说说我们怎样解决了问题的。
基于上述原因,先列出我们的开发环境,免得有人配不出来,招人唾骂。
数据库 Oracle 9i
应用服务器 BEA Weblogic 8.11
开发工具 JBuilder X
在JSP实现文件Upload/Download可以分成这样几块
:文件提交到形成InputSteam;InputSteam以BLOB格式入库;数据从库中读出为InputSteam;InputStream输出到页面形成下载文件。先说BLOB吧。
1.
BLOB入库
直接获得数据库连接的情况
这是Oracle提供的标准方式,先插入一个空BLOB对象,然后Update这个空对象。代码如下:
Java代码
//得到数据库连接(驱动包是weblogic的,没有下载任何新版本)
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection con = DriverManager.getConnection(
weblogic.jdbc.vendor.oracle.OracleThinBlob blob =
(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)。代码如下:
Java代码
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页面提交文件到数据库
提交页面的代码如下:
Html代码
由于JSP没有提供文件上传的处理能力,只有使用第三方的开发包。网络上开源的包有很多,我们这里选择Apache
Jakarta的FileUpload,在
可以得到下载包和完整的API文档。法奥为adajspException
处理页面(handle.jsp)的代码如下
Html代码
boolean isMultipart = FileUpload.isMultipartContent(request);
if (isMultipart) {
建立一个新的Upload对象
DiskFileUpload upload = new DiskFileUpload();
String mysql="insert into filelist
(FileName,FileSize,FileBody) values (?,?,EMPTY_BLOB())";
opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);
opst.setString(1,"wordtemplate");
opst.setInt (2,flength);
opst.executeUpdate();
opst.clearParameters();
/**插入其它数据后,定位BLOB字段
mysql="select filebody from filelist where
filename=?";
opst=(oracle.jdbc.driver.OraclePreparedStatement)db1.conn.prepareStatement(mysql);
opst.setString(1,"wordtemplate");
ors=(oracle.jdbc.OracleResultSet)opst.executeQuery();
(ors.next())
oracle.sql.BLOB blob=ors.getBLOB(1);/**得到BLOB字段
需要注意的是Blob存取的过程,一般先存入和BLOB相关的控制数据,如文件的名字,然后查询定位BLOB字段,利用OracleBlob提供的方法:
public int putBytes(long
pos,byte bytes[])
public byte[]
getBytes(long pos,byte bytes[])
public OutputStream
getBinaryOutputStream() throws SQLException
public InputStream
getBinaryStream() throws SQLException
因为利用输入输出流总归还是利用到字节数组缓冲流,所以就不举例子了。
<!-- 正文结束 -->
广播电视节目制作经营许可证(京) 字第1234号 中国互联网协会会员