Oracle讀取Blob數據-通過hibernate

通過hibernate向Oracle存儲字節類型的數據(如byte[]等),在定義實體對象的時候不能用"private byte[] content", 這樣定義我試過,在存儲數據的時候(session.save(user))是沒有問題的,但是在讀取Blob字段(Oracle中存儲byte[]使用的是"BLOB"類型)時就會出現問題,讀出來的東西就成了亂碼.

使用hibernate讀取Blob字段時,實體對象(對應的byte[]類型字段)應該這樣定義:

import java.io.Serializable;
import java.sql.Blob;

public class User implements Serializable {
    // Fields
    private long id;
    private String name;
    private String email;
    private String addr;
    // 定義Blob的pthto
    private Blob photo;

    // getter and setters
    ......
}

對應的hibernate文件配置:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<Hibernate-mapping>
    <class name="com.xxx.xxx.User" table="user">
        <id name="id" type="java.lang.Long">
            <column name="id" />
            <generator class="increment" />
        </id>
        <property name="name" type="java.lang.String">
            <column name="name" length="45" not-null="true" />
        </property>
        <property name="email" type="java.lang.String">
            <column name="email" length="45" />
        </property>
        <property name="addr" type="java.lang.String">
            <column name="addr" length="45" />
        </property>
        <!-- 映射blob類型 -->
        <property name="photo" type="java.sql.Blob">
            <column name="photo" />
        </property>
    </class>
</Hibernate-mapping>

讀取Blob數據方法:

// 寫方法
public void testCreate(){
    User user = new User();
    user.setName("linweiyang");
    user.setAddr("beijing");
    user.setEmail("[e-mail]");
    Blob photo = null;
    try {
        //將圖片讀進輸入流
        FileInputStream fis = new FileInputStream("c:\\a.jpg");
        //轉成Blob類型
        photo = Hibernate.createBlob(fis);
    } catch (FileNotFoundException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }
    user.setPhoto(photo);
    Session session = factory.openSession();
    Transaction tr = session.beginTransaction();
    session.save(user);
    tr.commit();
    session.close();
}

// 讀方法
public void testRerieve(){
    Session session = factory.openSession();
    User user = (User)session.load(User.class, new Long(3));
    try {
        //從數據庫中要讀取出來
        InputStream is = user.getPhoto().getBinaryStream();
        //在把寫到一個圖片格式的文件里
        FileOutputStream fos = new FileOutputStream("c:\\linweihan.jpg");
        byte[] buffer = new byte[1024];
        int len = 0;
        //從數據庫中讀取到指定的字節數組中
        while((len = is.read(buffer) )!= -1){
            //從指定的數組中讀取，然后輸出來,所以這里buffer好象是連接inputStream和outputStream的一個東西
            fos.write(buffer,0,len);
        }
    } catch (FileNotFoundException e) {
        e.printStackTrace();
    } catch (SQLException e) {
        e.printStackTrace();
    } catch (IOException  e) {
        e.printStackTrace();
    }
    session.close();
}

關於輸入輸出流

讀入流自然要有讀入的源頭,輸出也要輸出到某個地方,輸出一般是先要輸讀入,這里連接輸入和輸出的是一個在內存中的字節數組buffer.這樣從數據庫中讀到這個數組里,輸出流在從這個數組中輸出到特定的文件格式里