Oracle数据库中BLOB字段的存取-控件新闻-慧都网

Oracle数据库中BLOB字段的存取

原创|其它|编辑：郝浩|2010-02-05 16:05:14.000|阅读 797 次

概述：最近几次碰到这个问题，需求是将一个文件或者文件流存储到Oracle数据库里，Oracle8提供了Blob和Clob用来存储二进制大对象数据，可是它和Java.sql.里面的Blob不兼容，经常导致Blob字段无法锁定或者操作失败，总之我总结了一些经验大家共享。

# 界面/图表报表/文档/IDE等千款热门软控件火热销售中 >>

　　最近几次碰到这个问题，需求是将一个文件或者文件流存储到Oracle数据库里，Oracle8提供了Blob和Clob用来存储二进制大对象数据，可是它和Java.sql.里面的Blob不兼容，经常导致Blob字段无法锁定或者操作失败，总之我总结了一些经验大家共享。

　　首先建立测试数据表

　　drop table filelist;
　　commit;
　　CREATE TABLE SYSTEM.FILELIST (
　　"FILENAME" VARCHAR2(50) NOT NULL,
　　"FILESIZE" NUMBER(20) NULL,
　　"FILEBODY" BLOB NULL,
　　PRIMARY KEY("FILENAME"), UNIQUE("FILENAME")) ;
　　commit;

　　测试过程，首先将硬盘文件读入数据库，然后再读出到硬盘的另一个新文件里，原码如下：

　　import java.io.*;
　　import java.util.*;
　　import java.sql.*;
　　import oracle.sql.*;
　　import oracle.jdbc.driver.*;
　　import java.text.*;
　　public class test
　　{
　　public static void main(String args[]) throws java.io.IOException,java.sql.SQLException
　　{
　　dbBean db1=new dbBean();
　　/**

　　*这里是我的数据联接Bean
　　*大家可以用自己的连接Bean
　　*/
　　byte a[]=null;//**将测试文件test.doc读入此字节数组
　　java.io.FileInputStream fin=null;
　　java.io.FileOutputStream fout=null;
　　oracle.jdbc.OracleResultSet ors=null;//**这里rs一定要用Oracle提供的
　　oracle.jdbc.driver.OraclePreparedStatement opst=null;//**PreparedStatement用
　　//Oracle提供的
　　try
　　{
　　java.io.File f1=new java.io.File("c:/temp/test.doc");
　　java.io.File f2=new java.io.File("c:/temp/testout.doc");//**从BLOB读出的信息写
　　//入该文件，和源文件对比测试用
　　fin=new java.io.FileInputStream(f1);
　　fout=new java.io.FileOutputStream(f2);
　　int flength=(int)f1.length();//**读入文件的字节长度

　　System.out.println("file length::"+flength);
　　a=new byte[flength];
　　int i=0;int itotal=0;
　　/**将文件读入字节数组
　　for (;itotal
　　{
　　i=fin.read(a,itotal,flength-itotal);
　　}
　　fin.close();
　　System.out.println("read itotal::"+itotal);
　　/**注意Oracle的 BLOB一定要用EMPTY_BLOB()初始化
　　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();
　　if (ors.next())
　　{
　　oracle.sql.BLOB blob=ors.getBLOB(1);/**得到BLOB字段
　　int j=blob.putBytes(1,a);/**将字节数组写入BLOB字段
　　System.out.println("j:"+j);
　　db1.conn.commit();
　　ors.close();
　　}
　　System.out.println("insert into ok");
　　byte b[]=null;/**保存从BLOB读出的字节
　　opst.clearParameters();
　　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();
　　if (ors.next())
　　{
　　oracle.sql.BLOB blob2=ors.getBLOB(1);
　　System.out.println("blob2 length:"+blob2.length());
　　b=blob2.getBytes(1,flength);/**从BLOB取出字节流数据
　　System.out.println("b length::"+b.length);
　　db1.conn.commit();
　　}
　　ors.close();
　　/**将从BLOB读出的字节写入文件

　　fout.write(b,0,b.length);
　　fout.close();
　　System.out.println("write itotal::"+b.length);
　　}
　　catch(Exception e)
　　{
　　System.out.println("errror :"+e.toString() );
　　e.printStackTrace();
　　}
　　finally
　　{ /**关闭所有数据联接
　　stmt.close();
　　db1.closeConn();
　　}
　　}
　　}

　　编译运行在TomCat下调试通过。

　　需要注意的是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

　　因为利用输入输出流总归还是利用到字节数组缓冲流，所以就不举例子了。

标签：

本站文章除注明转载外，均为本站原创或翻译。欢迎任何形式的转载，但请务必注明出处、不得修改原文相关链接，如果存在内容上的异议请邮件反馈至chenjj@evget.com

文章转载自：网络转载

上一篇：讲解Oracle对用户的访问控制下一篇：VB.NET结构化异常处理分析