hibernate3操作oracle的Blob字段

igjhrkehrf

　　【老乔】hibernate作为一个优秀的OR－Mapping构架，对数据库的基本操作进行了比较好的封装，针对Blob类型字段的操作也不例外。但网上大部分能找到的hibernate操作Blob的例程都是基于hibernate2版本的，同时在实际操作中我发现针对不同的数据库，可以有不同的操作方法。下面将hibernate3操作oracle的Blob字段进行一个介绍。
         用JDBC操作Blob最基本的思路是：先插入一条包含空Blob的记录，然后立即将该条记录用行锁定的方式打开，得到改Blob字段的引用，从中得到一个输出流，将byte[]数据写入后提交。hibernate操作的基本思路也是一致的。下例中用到表img，里面一个主键id，一个Blob字段img。它对应的映射文件如下：
  
      <class name="Img" table="IMG">
          <id name="id" column="ID" type="long">
              <generator class="increment"/>
          </id>
          <property name="img" column="IMG" type="java.sql.Blob" />        1
      </class>

         在1处可以不指定字段的类型，让hibernate自动处理。对应的持久化类中，img属性也声明为java.sql.Blob类型。插入的代码如下：
  
    Session s = Hsf.currentSession();
    Transaction t = s.beginTransaction();
    Img img = new Img();
  //调用Hibernate的静态方法，创建一个长度为1的byte数组，生成一个空Blob
    img.setImg(Hibernate.createBlob(new byte[1]));
    s.save(img);  //保存到数据库中
    s.flush();
    s.refresh(img,LockMode.UPGRADE);  //锁定为更新模式
    //System.out.println(img.getImg().getClass());
  //返回的是SerializableBlob类型的对象，这是个实现了Blob接口的对象，但不能直接造型为BLOB
    SerializableBlob sb = (SerializableBlob)img.getImg();
  //需要调用它的getWrappedBlob造型出来
    BLOB blob = (BLOB)sb.getWrappedBlob();
  //将某个文件读入后，写到Blob字段的输出流中
    OutputStream os = blob.getBinaryOutputStream();
    FileInputStream fis = new FileInputStream("a.jpg");
    byte[] buff = new byte[fis.available()];
    fis.read(buff);
    fis.close();
    os.write(buff);
    os.close();
    s.flush();
    t.commit();
    Hsf.closeSession();
  
       在操作中要注意的是，要进行写的操作，必须将类型强制造型为oracle.sql.BLOB，而用img.getImg()方法返回的对象的类型是org.hibernate.lob.SerializableBlob类型，该类型与oracle.sql.BLOB类型没有直接关系，所以不能直接强制造型。需要先造型为SerializableBlob，然后调用它的getWrappedBlob方法得到BLOB类型的对象。

       对应的读Blob的方法要简单一些，从Blob中直接得到输入流进行操作。代码如下：
  
     Session s = Hsf.currentSession();
    Img img = (Img)(s.createQuery("from Img order by id desc").iterate().next());
    InputStream is = img.getImg().getBinaryStream();
    OutputStream os = new FileOutputStream("b.jpg");
    //通过is.available()得不到总长度
    byte[] buff = new byte[1024];
    int i = 0;
    while((i=is.read(buff))!=-1){
     os.write(buff,0,i);
    }
    is.close();
    os.close();
    Hsf.closeSession();