1、向數據庫中存入java對象
//建立一個字節數組的輸出流
ByteArrayOutputStream byteOut=new ByteArrayOutputStream();
//使用對象輸出流將字節數組流包裝起來
ObjectOutputStream outObj=new ObjectOutputStream(byteOut);
//使用對象輸出流的writeObject方法將query對象寫入到字節數組輸出流中,query對象作為tss的一個屬性存在
outObj.writeObject(query) ;
//使用toByteArray()方法獲得一個字節數組
final byte[] objbytes=byteOut.toByteArray();
Session session = this.getSession();
//寫入Blob字段和寫入其它類型字段的方式非常不同,因為Blob自身有一個cursor,你必須使用cursor對blob進行操作,因而你在寫入Blob之前,必須獲得cursor才能進行寫入所以必須先要創建一個空的BLOB對象
tss.setQuery(Hibernate.createBlob(new byte[1]));//創建空的Blob對象
Serializable s=session.save(tss);
session.flush();//通過此方法強制執行插入操作
//通過refresh方法,強制Hibernate執行select for update
session.refresh(tss, LockMode.UPGRADE);
//向Blob中寫入實際的內容
SerializableBlob sb = (SerializableBlob)tss.getQuery();
java.sql.Blob wrapBlob = sb.getWrappedBlob();
Oracle.sql.BLOB blob=(oracle.sql.BLOB)wrapBlob;
OutputStream out = blob.getBinaryOutputStream();
BufferedOutputStream bos = new BufferedOutputStream(out);
bos.write(objbytes, 0, objbytes.length);
bos.flush();
bos.close();
out.close();
byteOut.close();
outObj.close();
2、從數據庫中取出query對象
SerializableBlob sb = (SerializableBlob)tss.getQuery();
java.sql.Blob wrapBlob = sb.getWrappedBlob();
BLOB inblob = (BLOB)wrapBlob;
InputStream is = inblob.getBinaryStream();
BufferedInputStream bis = new BufferedInputStream(is);
byte[] byte11 = new byte[inblob.getBufferSize()];
if(-1!=bis.read(byte11, 0, byte11.length));
ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(byte11));
Query bq = (BooleanQuery)ois.readObject();
ois.close();
bis.close();
is.close();