服务热线:13616026886

技术文档 欢迎使用技术文档,我们为你提供从新手到专业开发者的所有资源,你也可以通过它日益精进

位置:首页 > 技术文档 > JAVA > 新手入门 > 基础入门 > 查看文档

jdbc和hibernate来写入blob型数据


  oracle的blob字段比较特殊,他比long字段的性能要好很多,可以用来保存例如图片之类的二进制数据。
  
  写入blob字段和写入其它类型字段的方式非常不同,因为blob自身有一个cursor,你必须使用cursor对blob进行操作,因而你在写入blob之前,必须获得cursor才能进行写入,那么如何获得blob的cursor呢?
  
  这需要你先插入一个empty的blob,这将创建一个blob的cursor,然后你再把这个empty的blob的cursor用select查询出来,这样通过两步操作,你就获得了blob的cursor,可以真正的写入blob数据了。
  
  看下面的jdbc的demo,把oraclejdbc.jar这个二进制文件写入数据库表javatest的content字段(这是一个blob型字段)
  
  java代码:
  
  import java.sql.*;
  import java.io.*;
  import oracle.sql.*;
  public class writeblob {
  
  public static void main(string[] args) {
  
  try {
  drivermanager.registerdriver(new oracle.jdbc.driver.oracledriver());
  connection conn = drivermanager.getconnection("jdbc:oracle:thin:@localhost:1521:orcl","fankai","fankai");
  conn.setautocommit(false);
  
  blob blob = null;
  
  preparedstatement pstmt = conn.preparestatement("insert into javatest(name,content) values(?,empty_blob())");
  pstmt.setstring(1,"fankai");
  pstmt.executeupdate();
  pstmt.close();
  
  pstmt = conn.preparestatement("select content from javatest where name= ? for update");
  pstmt.setstring(1,"fankai");
  resultset rset = pstmt.executequery();
  if (rset.next()) blob = (blob) rset.getblob(1);
  
  string filename = "oraclejdbc.jar";
  file f = new file(filename);
  fileinputstream fin = new fileinputstream(f);
  system.out.println("file size = " + fin.available());
  
  pstmt = conn.preparestatement("update javatest set content=? where name=?");
  
  outputstream out = blob.getbinaryoutputstream();
  
  int count = -1, total = 0;
  byte[] data = new byte[(int)fin.available()];
  fin.read(data);
  out.write(data);
  /*
  byte[] data = new byte[blob.getbuffersize()]; 另一种实现方法,节省内存
  while ((count = fin.read(data)) != -1) {
  total += count;
  out.write(data, 0, count);
  }
  */
  
  fin.close();
  out.close();
  
  pstmt.setblob(1,blob);
  pstmt.setstring(2,"fankai");
  
  pstmt.executeupdate();
  pstmt.close();
  
  conn.commit();
  conn.close();
  } catch (sqlexception e) {
  system.err.println(e.getmessage());
  e.printstacktrace();
  } catch (ioexception e) {
  system.err.println(e.getmessage());
  }
  }
  
  }
  
  仔细看上例,分三步:
  
  1、插入空blob
  into javatest(name,content) values(?,empty_blob());
  
  2、获得blob的cursor
  select content from javatest where name= ? for update;
  
  注意!!!必须加for update,这将锁定该行,直至该行被修改完毕,保证不产生并发冲突。
  
  3、update javatest set content=? where name=
  
  用cursor往数据库写数据
  
  这里面还有一点要提醒大家:
  
  jdk1.3带的jdbc2.0规范是不完善的,只有读blob的接口,而没有写blob的接口,jdk1.4带的jdbc3.0加入了写blob的接口。你可以使用jdbc3.0的接口,也可以直接使用oracle的jdbc的api,我在上例中使用了oracle的jdbc的api。
  
  另外要注意的是:
  
  java.sql.blob
  oracle.sql.blob
  
  注意看blob的大小写,是不一样的。写程序的时候不要搞混了。
  
  下面看看用hibernate怎么写,原理是一样的,也要分三步,但是代码简单很多
  
  这是cat对象定义
  
  java代码:
  
  package com.fankai;
  
  import java.sql.blob;
  
  public class cat {
  private string id;
  private string name;
  private char sex;
  private float weight;
  private blob image;
  public cat() { }
  
  public string getid() { return id; }
  public void setid(string id) { this.id = id; }
  
  public string getname() { return name; }
  public void setname(string name) { this.name = name; }
  
  public char getsex() { return sex; }
  public void setsex(char sex) { this.sex = sex; }
  
  public float getweight() { return weight; }
  public void setweight(float weight) { this.weight = weight; }
  
  public blob getimage() { return image; }
  public void setimage(blob image) { this.image = image;}
  }
  
  这是cat.hbm.xml
  
  java代码:
  
  <?xml version="1.0"?>
  <!doctype hibernate-mapping system "http://hibernate.sourceforge.net/hibernate-mapping-2.0.dtd">
  
  <hibernate-mapping>
  <class name="com.fankai.cat" table="cat">
  <!--jcs-cache usage="read-only"/-->
  <id name="id" unsaved-value="null">
  <generator class="uuid.hex"/>
  </id>
  <property name="name" length="16" not-null="true"/>
  <property name="sex" length="1" not-null="true"/>
  <property name="weight" />
  <property name="image" />
  </class>
  </hibernate-mapping>
  
  下面是完整的用hibernate写入blob的例子,相比jdbc,已经简单轻松多了,也不用写那些oracle特殊的sql了:
  
  java代码:
  
  package com.fankai;
  
  import java.sql.blob;
  import net.sf.hibernate.*;
  import oracle.sql.*;
  import java.io.*;
  
  public class testcathibernate {
  public static void testblob() {
  session s = null;
  byte[] buffer = new byte[1];
  buffer[0] = 1;
  try {
  sessionfactory sf = hibernatesessionfactory.getsessionfactory();
  s = sf.opensession();
  transaction tx = s.begintransaction();
  cat c = new cat();
  c.setname("robbin");
  c.setimage(hibernate.createblob(buffer));
  s.save(c);
  s.flush();
  s.refresh(c, lockmode.upgrade);
  blob blob = (blob) c.getimage();
  outputstream out = blob.getbinaryoutputstream();
  string filename = "oraclejdbc.jar";
  file f = new file(filename);
  fileinputstream fin = new fileinputstream(f);
  int count = -1, total = 0;
  byte[] data = new byte[(int)fin.available()];
  fin.read(data);
  out.write(data);
  fin.close();
  out.close();
  s.flush();
  tx.commit();
  
  } catch (exception e) {
  system.out.println(e.getmessage());
  } finally {
  if (s != null)
  try {
  s.close();
  } catch (exception e) {}
  }
  
  }
  }

扫描关注微信公众号