首页 > 代码库 > Hibernate操作Blob数据

Hibernate操作Blob数据

 


首先看数据库。数据库中新建一个BlobTable表,表中有两个字段,一个id(主键)一个picture字段是Blob类型字段。然后使用Hibernate向该数据库中写入和读取数据

在POJO类中picture属性用的是Blob类型数据。

以下看操作源代码

package dao;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.math.BigDecimal;
import java.sql.Blob;

import org.hibernate.LobHelper;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;

import Factory.HibernateSessionFactory;
import entity.Blobtable;

public class BlobDao {
	
	private Session session = null;
	private Transaction tran = null;
	
	
	public BlobDao(){
		this.session = HibernateSessionFactory.getSession();
	}
	
	public void saveBlob(Blobtable bigdate,String path) throws IOException{
		
		/*InputStream in = this.getClass().getResourceAsStream(path);
		byte[] bytes = new byte[in.available()];
		in.read(bytes);
		in.close();*/
		File file = new File(path);
		FileInputStream fis = new FileInputStream(file);
		byte[] bytes = new byte[fis.available()];
		fis.read(bytes);
		LobHelper lh = session.getLobHelper();
		bigdate.setPicture(lh.createBlob(bytes));
		
		tran = session.beginTransaction();
		try{
			session.save(bigdate);
			tran.commit();
			System.out.println("插入成功!

"); }catch(Exception e){ System.out.println("插入失败!"); tran.rollback(); }finally{ HibernateSessionFactory.closeSession(); fis.close(); } } public void getBlob(BigDecimal id,String targetpath) throws Exception{ String hql = "From Blobtable where id = ?"; Query query = session.createQuery(hql); query.setBigDecimal(0, id); Blobtable bt = (Blobtable) query.uniqueResult(); Blob image = bt.getPicture(); InputStream in = image.getBinaryStream(); OutputStream os = new FileOutputStream(targetpath); int n = -1; while((n=in.read())!=-1){ os.write(n); } in.close(); os.close(); } }

package Test;

import java.io.IOException;
import java.math.BigDecimal;

import dao.BlobDao;
import entity.Blobtable;

public class Test {
	public static void main(String[] args) {

		BlobDao bb = new BlobDao();
		Blobtable bt = new Blobtable();
		bt.setId(new BigDecimal(5));
		try {
			String path = "f:\\a.jpg";
			bb.saveBlob(bt, path);
		} catch (IOException e) {
			e.printStackTrace();
		}
		BlobDao bd = new BlobDao();
		try {
			bd.getBlob(new BigDecimal(1), "e:\\a.jpg");
			System.out.println("写出成功!");
		} catch (Exception e) {
			e.printStackTrace();
		}		
	}
}



 

Hibernate操作Blob数据