test.java

实现Hibernate操作blob的开发

package main;

import java.io.File;
import java.io.FileInputStream;
import java.io.OutputStream;
import oracle.sql.*; 



import org.hibernate.Hibernate;
import org.hibernate.LockMode;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;
import org.hibernate.lob.SerializableBlob;

import test.hibernate.Iricinfo;


public class Test {  
	  public static void main(String [] args) { 
		      
		    byte[] buffer = new byte[1]; 
		    buffer[0] = 1; 
		    
		    SessionFactory sf = new Configuration().configure().buildSessionFactory();
		  Session session = sf.openSession();
		  Transaction tx = session.beginTransaction();
		    try { 
		      
		      Iricinfo c = new Iricinfo(); 
		      c.setBUSDATE("2007-07-08"); 
		      c.setRICNO("1");
		      c.setFILENAME("asdf.zip");
		      c.setFILEINFO(Hibernate.createBlob(buffer)); 
		      
		      session.save(c); 
//		      tx.commit(); 
		      session.flush(); 
		      
		      session.refresh(c, LockMode.UPGRADE);   
		      
		      SerializableBlob blob1 = (SerializableBlob)c.getFILEINFO();

		      BLOB wrappedBlob = (BLOB) blob1.getWrappedBlob();    
		      
		      String fileName = "asdf.zip"; 
		      File f = new File("e:/"+fileName); 
		      
//		      OutputStream out = blob.getBinaryOutputStream();    
		      
		      FileInputStream fin = new FileInputStream(f);    
		      int count = -1, total = 0; 
		      byte[] data = new byte[(int)fin.available()]; 
		      fin.read(data); 
		      
		      wrappedBlob.setBytes(1, data);
		      c.setFILEINFO(wrappedBlob);
//		      out.write(data);      
		      fin.close(); 
//		      out.close(); 
		      session.flush(); 
		      tx.commit(); 
		    
		    } catch (Exception e) { 
		    	 System.out.println("wrong");
		      System.out.println(e.getMessage()); 
		    } finally { 
		      if (session != null) 
		        try { 
		        	session.close(); 
		        } catch (Exception e) {} 
		    }    
		    
		  } 
		}