Oracle数据库中BLOB字段的存取问题

以下的文章主要是对Oracle数据库中BLOB字段的存取问题的介绍，我在经常会碰到Oracle数据库中BLOB字段的存取这一问题，需求是将一个文件或者文件流存储到Oracle数据库里，Oracle8提供了Blob和Clob用来存储二进制大对象数据。

勃利网站建设公司成都创新互联公司,勃利网站设计制作，有大型网站制作公司丰富经验。已为勃利上1000家提供企业网站建设服务。企业网站搭建\外贸网站建设要多少钱，请找那个售后服务好的勃利做网站的公司定做！

可是它和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;

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

 
 
 
  
  
  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字段，利用Oracle数据库Blob提供的方法：

 
 
 
  
  
  public int putBytes(long pos,byte bytes[])  
  
  
  public byte[] getBytes(long pos,byte bytes[])

或者利用

 
 
 
  
  
  public OutputStream getBinaryOutputStream() throws SQLException  
  
  
  public InputStream getBinaryStream() throws SQLException

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

当前题目：Oracle数据库中BLOB字段的存取问题
分享网址：http://www.hantingmc.com/qtweb/news23/544423.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容