hibernate对大数据资源的处理操作 - 数据库编程

ct(Object entity) { System.out.println("开始执行BaseServiceImpl中的方法==============updateObject"); baseDao.updateObject(entity); } @Override public Object getObject(Class clazz, Serializable id) { System.out.println("开始执行BaseServiceImpl中的方法==============getObject"); return baseDao.getObject(clazz, id); } @Override public Object loadObject(Class clazz, Serializable id) { System.out.println("开始执行BaseServiceImpl中的方法==============loadObject"); return baseDao.loadObject(clazz, id); } @Override public List getObjectAll(Class clazz) { System.out.println("开始执行BaseServiceImpl中的方法==============getObjectAll"); return baseDao.getObjectAll(clazz); } } 处理图片的service的实现

package tk.blank_hibernate.service.impl;

import tk.blank_hibernate.service.ImageService;

public class ImageServiceImpl extends BaseServiceImpl implements ImageService {

}

单独产生session的接口

package tk.blank_hibernate.util;

import org.hibernate.Session;

public interface IHibernateConnection {
public Session getSessionObject();
}

单独产生session的实现类

package tk.blank_hibernate.util;

import org.hibernate.Session;

public class BaseHibernateDaoImpl implements IHibernateConnection {

@Override
public Session getSessionObject() {
return HiberUtil.openSession();
}

}

产生session的实质方法

package tk.blank_hibernate.util;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.boot.registry.StandardServiceRegistryBuilder;
import org.hibernate.cfg.Configuration;
import org.hibernate.service.ServiceRegistry;

public class HiberUtil {
	static Configuration cfg;
	static ServiceRegistry serviceRegistry;
	static SessionFactory sessionFactory;
	
	static{
		cfg=new Configuration().configure();
		serviceRegistry=new StandardServiceRegistryBuilder().applySettings(cfg.getProperties()).build();
		sessionFactory =cfg.buildSessionFactory(serviceRegistry);
	}
	
	
	public static Session openSession(){
		//返回当前的session的连接对象
		return sessionFactory.getCurrentSession();
	}
}

配置hibernate与数据库连接的入口文件hibernate.cfg.xml

< xml version="1.0" encoding="UTF-8" >



	
		com.mysql.jdbc.Driver
	
	
		jdbc:mysql://localhost:3306/hiber_jd
	
	root
	admin
	
	
		org.hibernate.dialect.MySQLDialect
	
	
	thread

	
	true
	
	false
	
	update

测试代码

package tk.blank_hibernate.junit;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Blob;
import java.sql.SQLException;

import org.hibernate.Hibernate;
import org.junit.Test;

import tk.blank_hibernate.bean.Image;
import tk.blank_hibernate.service.ImageService;
import tk.blank_hibernate.service.impl.ImageServiceImpl;
import tk.blank_hibernate.util.HiberUtil;

public class ImageTest {

	// 创建ImageService处理对象
	ImageService imageService = new ImageServiceImpl();

	@Test
	public void save() {
		// 创建img对象
		Image image = new Image();
		// 读取文件
		File file = new File("F:\\webprogect\\hibernate_jd\\src\\ni.jpg");

hibernate对大数据资源的处理操作(四)