Hibernate 中Blob字段的使用

create table textblob (tid number(38,0),lob blob)

然后建立对应的Java对象

public class testblob {
         private long id;
         private byte[] lob;
         //set和get方法略...
    }

 最后是Hibernate配置和映射文件。

<hibernate-configuration>
        <session-factory>
        <property name="connection.driver_class">
            oracle.jdbc.driver.OracleDriver
            </property>
            <property name="connection.url">
            jdbc:oracle:thin:@xxx.xxx.xxx.xxx:1521:orcl
            </property>
            <property name="connection.useUnicode">true</property>
            <property name="connection.characterEncoding">UTF-8</property>
            <property name="connection.username">xxxxxx</property>
            <property name="connection.password">xxxxxx</property>
            <property name="hibernate.connection.provider_class">
            org.hibernate.connection.C3P0ConnectionProvider
            </property>
            <property name="hibernate.c3p0.max_size">20</property>
            <property name="hibernate.c3p0.min_size">5</property>
            <property name="hibernate.c3p0.timeout">120</property>
            <property name="hibernate.c3p0.max_statements">100</property>
            <property name="hibernate.c3p0.idle_test_period">120</property>
            <property name="hibernate.c3p0.acquire_increment">2</property>
            <property name="hibernate.connection.SetBigStringTryClob">
            true
            </property>
            <property name="hibernate.jdbc.use_streams_for_binary">
            true
            </property>
            <property name="dialect">
            org.hibernate.dialect.Oracle9Dialect
            </property>
            <property name="hibernate.show_sql">true</property>
            <property name="hibernate.transaction.factory_class">
            org.hibernate.transaction.JDBCTransactionFactory
            </property>

      <mapping resource="org/Miao/testblob.hbm.xml" />
         </session-factory>
     </hibernate-configuration>

注意配置文件中“hibernate.jdbc.use_streams_for_binary”这个部分。这是Oracle必须添加的属性。其它配置没有什么特别的。SQL Server不需要这个属性。同时配置文件配置了一个C3P0数据库连接池。

映射文件如下：

<hibernate-mapping package="org.Miao">
        <class name="testblob" table="tblob">
            <id name="id" column="tid">
               <generator class="native"></generator>
            </id>
        <property name="lob" column="tlob" type="binary">

    </property>
     </class>
</hibernate-mapping>

然后就可以测试一下了。写一个运行的测试类Run.class。

public class run {
      public static void main(String[] args) {
         Configuration configuration = new Configuration();
         configuration.configure();
         SessionFactory sessionFactory = configuration.buildSessionFactory();
         Session session = sessionFactory.openSession();
         File f = new File("d:/f.exe");
         byte[] tmp = new byte[(int) f.length()];
         try {
               FileInputStream fi = new FileInputStream(f);
               fi.read(tmp);
          } catch (FileNotFoundException e1) {
          e1.printStackTrace();
          } catch (IOException e) {
          e.printStackTrace();
          }
          testblob test = new testblob();
          test.setId(5);
          test.setLob(tmp);
          Transaction t = session.beginTransaction();
          try {
              session.saveOrUpdate(test);
              t.commit();
          } catch (HibernateException e) {
             e.printStackTrace();
             t.rollback();
          } finally {
             session.close();
          }
    }

}

现在进入数据库的话，可以看到数据库记录中已经增加了一条，文件已经被保存到数据库里了。但是，这么做有一个很大的问题，那就是内存。在Eclipse+WTP的环境下，加入的文件稍微大一点，就会造成OutofMemony异常。因为用这种方法存入数据库，需要把文件全部读入内存才可以。文件一大，就会造成内存溢出，即使把JVM使用的内存调大，保存大文件也是非常慢的。我的调试环境，存一个10M的文件，单用户Tomcat（内存调整到256-512M）跑，Oracle10g又是远程，需要好几分钟。多用户条件下，性能可想而知。而且，一旦多用户同时保存或同时读取大文件，立马会造成内存占用暴增，最后溢出。所以，使用这种方式处理Blob，一定要注意，不要保存大文件，我觉得最好不要超过1M。

<property name="lob" column="tlob" type="java.sql.Blob">  

然后要在hibernate配置文件中加入一句话:

<property name="hibernate.jdbc.batch_size">0</property>  

因为Oracle JBDC不允许流操作以批量方式执行.

然后

测试类里面可以写:

testblob test = new testblob();   
test.setId(5);   
test.setLob(Hibernate.createBlob(new byte[1]));  
Transaction t = session.beginTransaction();   
session.save(test);   
//调用flush方法,强制Hibernate立即执行 sql 语句
session.flush();
//通过refresh方法,强制Hibernate执行select for update
session.refresh(test,LockMode.UPGRADE);
//向Blob写入实际内容
oracle.sql.BLOB blob=(oracle.sql.BLOB)test.getLob();
OutPutStream out =blob.getBinaryOutputStream();
FileInputStream imgis=new FileInputStream("xx.jpg");
byte[] buf = new byte[10240];//10k缓存
int len=0;
while((len=imgis.read(buf))>0){
out.write(buf,0,len);
}
imgis.close();
out.close();
session.save(test);
t.comit();

<property name="lob" column="tlob" type="java.sql.Blob">  

<property name="hibernate.jdbc.batch_size">0</property>  

testblob test = new testblob();   
test.setId(5);   
test.setLob(Hibernate.createBlob(new byte[1]));  
Transaction t = session.beginTransaction();   
session.save(test);   
//调用flush方法,强制Hibernate立即执行 sql 语句
session.flush();
//通过refresh方法,强制Hibernate执行select for update
session.refresh(test,LockMode.UPGRADE);
//向Blob写入实际内容
oracle.sql.BLOB blob=(oracle.sql.BLOB)test.getLob();
OutPutStream out =blob.getBinaryOutputStream();
FileInputStream imgis=new FileInputStream("xx.jpg");
byte[] buf = new byte[10240];//10k缓存
int len=0;
while((len=imgis.read(buf))>0){
out.write(buf,0,len);
}
imgis.close();
out.close();
session.save(test);
t.comit();

很可惜。这么写是错误的。

Hibernate.createBlob(new byte[1]))生成的BLOB根本无法转化成Oracle的BLOB。它们虽然都继承自BLOB，但是不能强行转换。这种写法只适用于Hibernate2，3以后是不能用的。如果不想用我的方法，那么只能自己写Hibernate类型或使用Spring提供的类型。但是这样一来增加了难度或和Spring紧耦合了。

还有，你的写法造成了代码和数据库的紧耦合。也就是说如果更换数据库，那么必须修改代码。同时在Hibernate配置中关闭了批处理，造成系统整个性能下降。可以说是得不偿失。

深入浅出Hibernate我记得应该是一本比较早期的Hibernate参考书，上面的很多东西已经不适用于最新的Hibernate版本了。