hibernate session生命周期示例



hibernate session生命周期示例。今天做了一个hibernate关于session的生命周期的测试,用的eclipse的junit工具类。

在昨天入门配置的基础上,创建了一个Sourse folder  名为test,主要放置测试类。

 

首先解释一下持久化对象:

瞬时对象(Transient Objects):使用new 操作符初始化的对象不是立刻就持久的。它们的状态是瞬时的,也就是说它们没有任何跟数据库表相关联的行为,只要应用不再引用这些对象(不再被任何其它对象所引用),它们的状态将会丢失,并由垃圾回收机制回收。 持久化对象(Persist Objects):持久实例是任何具有数据库标识的实例。它有持久化管理器Session统一管理,持久实例是在事务中进行操作的——它们的状态在事务结束时同数据库进行同步。当事务提交时,通过执行SQL的INSERT、UPDATE和DELETE语句把内存中的状态同步到数据库中。 离线对象(Detached Objects):Session关闭之后,持久化对象就变为离线对象。离线表示这个对象不能再与数据库保持同步,它们不再受Hibernate管理。

 

 

生命周期:

 

 

配置好后,新建一个HibernateUtils.java类:

Java代码 复制代码 收藏代码
  1. package com.mp.hibernate;
  2. import org.hibernate.Session;
  3. import org.hibernate.SessionFactory;
  4. import org.hibernate.cfg.Configuration;
  5. public class HibernateUtils {
  6.     public static SessionFactory factory;
  7.     static {
  8.         try {
  9.             Configuration cfg = new Configuration().configure();
  10.             factory = cfg.buildSessionFactory();
  11.         } catch(Exception e) {
  12.             e.printStackTrace();
  13.         }
  14.     }
  15.     public static SessionFactory getSessionFactory() {
  16.         return factory;
  17.     }
  18.     public static Session getSession() {
  19.         return factory.openSession();
  20.     }
  21.     public static void closeSession(Session session) {
  22.         if(session != null) {
  23.             if(session.isOpen()) {
  24.                 session.close();
  25.             }
  26.         }
  27.     }
  28. }
package com.mp.hibernate;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class HibernateUtils {
	public static SessionFactory factory;

	static {
		try {
			Configuration cfg = new Configuration().configure();
			factory = cfg.buildSessionFactory();
		} catch(Exception e) {
			e.printStackTrace();
		}
	} 

	public static SessionFactory getSessionFactory() {
		return factory;
	}

	public static Session getSession() {
		return factory.openSession();
	}

	public static void closeSession(Session session) {
		if(session != null) {
			if(session.isOpen()) {
				session.close();
			}
		}
	}
}

 

 

这个类就是把对session的基本操作封装起来。

在数据库中新建了hibernate_session数据库,并且修改hibernate.cfg.xml文件中的配置。

 

在test中建了一个测试类SessionTest.java

 

首先对session的三个状态进行测试:

 

Java代码 复制代码 收藏代码
  1. package com.mp.hibernate;
  2. import java.util.Date;
  3. import org.hibernate.Session;
  4. import org.hibernate.Transaction;
  5. import junit.framework.TestCase;
  6. public class SessionTest extends TestCase {
  7.     public void testHello() {
  8.         System.out.println(“———–SessionTest.hello()————”);
  9.         //throw new RuntimeException();
  10.     }
  11.     public void testSave1() {
  12.         Session session = null;
  13.         Transaction ts =  null;
  14.         User user = null;
  15.         try {
  16.             session = HibernateUtils.getSession();
  17.             ts = session.beginTransaction();
  18.             //Transient状态
  19.             user = new User();
  20.             user.setName(“哈哈”);
  21.             user.setPassword(“234″);
  22.             user.setCreateTime(new Date());
  23.             user.setExpireTime(new Date());
  24.             //persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
  25.             session.save(user);
  26.             user.setName(“李鹏”);
  27. //          session.update(user);
  28.             ts.commit();
  29.         } catch(Exception e) {
  30.             e.printStackTrace();
  31.             ts.rollback();
  32.         } finally {
  33.             HibernateUtils.closeSession(session);
  34.         }
  35.         //detached状态
  36.         user.setName(“张三”);
  37.         try {
  38.             session = HibernateUtils.getSession();
  39.             session.beginTransaction();
  40.             //persistent状态
  41.             session.update(user);
  42.             session.getTransaction().commit();
  43.         } catch (Exception e) {
  44.             // TODO: handle exception
  45.             e.printStackTrace();
  46.             session.getTransaction().rollback();
  47.         } finally {
  48.             HibernateUtils.closeSession(session);
  49.         }
  50.     }
  51. }
package com.mp.hibernate;

import java.util.Date;

import org.hibernate.Session;
import org.hibernate.Transaction;

import junit.framework.TestCase;

public class SessionTest extends TestCase {
	public void testHello() {
		System.out.println("-----------SessionTest.hello()------------");
		//throw new RuntimeException();
	}

	public void testSave1() {
		Session session = null;
		Transaction ts =  null;
		User user = null;
		try {
			session = HibernateUtils.getSession();
			ts = session.beginTransaction();

			//Transient状态
			user = new User();
			user.setName("哈哈");
			user.setPassword("234");
			user.setCreateTime(new Date());
			user.setExpireTime(new Date());

			//persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
			session.save(user);

			user.setName("李鹏");

//			session.update(user);
			ts.commit();

		} catch(Exception e) {
			e.printStackTrace();
			ts.rollback();
		} finally {
			HibernateUtils.closeSession(session);
		}

		//detached状态
		user.setName("张三");
		try {
			session = HibernateUtils.getSession();
			session.beginTransaction();

			//persistent状态
			session.update(user);
			session.getTransaction().commit();
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
			session.getTransaction().rollback();
		} finally {
			HibernateUtils.closeSession(session);

		}
	}

}


进入debug模式调试,查看user 的变化过程

在执行了save方法后,id被创建,也就意味着user对象被创建,但是hibernate并没有执行插入语句

之后修改user的属性也是可以的

因为在提交事务后可以看到hibernate执行了两个语句,一个insert另外一个就是update;此时也能看到数据库中已经插入记录:

update主要是由于使用了user对象的属性。

sava()操作使得它进入persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步

 

之后的commit()执行时,进行了”脏数据检查”操作。

 

紧接着又关闭了session,在进入了detached状态(对象不存在于session中)。

 

执行到update 又转入到persistent状态。

之后提交事务,也能完成数据库的更新。

查看数据库:

 

之后又添加了几个测试方法,主要测试get() 和 load() 方法的不同:

Java代码 复制代码 收藏代码
  1. public void testReadByGetMethod() {
  2.     Session session = null;
  3.     User user = null;
  4.     try {
  5.         session = HibernateUtils.getSession();
  6.         session.beginTransaction();
  7.         //马上发出查询sql,加载user对象
  8.         user = (User)session.get(User.class, “8a8af09123500da10123500ddb240001″);
  9.         System.out.println(“username” + user.getName());
  10.         //persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
  11.         user.setName(“龙哥”);
  12.         session.getTransaction().commit();
  13.     } catch (Exception e) {
  14.         e.printStackTrace();
  15.         session.getTransaction().rollback();
  16.     } finally {
  17.         HibernateUtils.closeSession(session);
  18.     }
  19. }
  20. public void testReadByGetMethod2() {
  21.     Session session = null;
  22.     User user = null;
  23.     try {
  24.         session = HibernateUtils.getSession();
  25.         session.beginTransaction();
  26.         //马上发出查询sql,加载user对象
  27.         user = (User)session.get(User.class, “845465756dfgdfdfgdfg001″);
  28.         //persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
  29.         user.setName(“龙哥”);
  30.         session.getTransaction().commit();
  31.     } catch (Exception e) {
  32.         e.printStackTrace();
  33.         session.getTransaction().rollback();
  34.     } finally {
  35.         HibernateUtils.closeSession(session);
  36.     }
  37. }
  38. public void testReadByLoadMethod() {
  39.     Session session = null;
  40.     User user = null;
  41.     try {
  42.         session = HibernateUtils.getSession();
  43.         session.beginTransaction();
  44.         //不会发出查询sql,因为load方法实现了lazy(懒加载或延迟加载)
  45.         //延迟加载:只有真正使用这个对象的时候才加载(发出sql语句)
  46.         //hibernate延迟加载实现原理是代理方式
  47.         user = (User)session.load(User.class, “8a8af09123500da10123500ddb240001″);
  48.         System.out.println(“username = ” + user.getName());
  49.         //persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
  50.         user.setName(“龙哥”);
  51.         session.getTransaction().commit();
  52.     } catch (Exception e) {
  53.         e.printStackTrace();
  54.         session.getTransaction().rollback();
  55.     } finally {
  56.         HibernateUtils.closeSession(session);
  57.     }
  58. }
  59. public void testReadByLoadMethod1() {
  60.     Session session = null;
  61.     User user = null;
  62.     try {
  63.         session = HibernateUtils.getSession();
  64.         session.beginTransaction();
  65.         //采用load加载数据,如果数据库中没有相应的数据
  66.         //则抛出异常ObjectNotFoundException
  67.         user = (User)session.load(User.class, “454565555555551″);
  68.         //查不到对象,则抛异常
  69.         System.out.println(“username = ” + user.getName());
  70.         session.getTransaction().commit();
  71.     } catch (Exception e) {
  72.         e.printStackTrace();
  73.         session.getTransaction().rollback();
  74.     } finally {
  75.         HibernateUtils.closeSession(session);
  76.     }
  77. }
	public void testReadByGetMethod() {
		Session session = null;
		User user = null;
		try {
			session = HibernateUtils.getSession();
			session.beginTransaction();

			//马上发出查询sql,加载user对象
			user = (User)session.get(User.class, "8a8af09123500da10123500ddb240001");
			System.out.println("username" + user.getName());

			//persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
			user.setName("龙哥");

			session.getTransaction().commit();
		} catch (Exception e) {
			e.printStackTrace();
			session.getTransaction().rollback();
		} finally {
			HibernateUtils.closeSession(session);
		}
	}

	public void testReadByGetMethod2() {
		Session session = null;
		User user = null;
		try {
			session = HibernateUtils.getSession();
			session.beginTransaction();

			//马上发出查询sql,加载user对象
			user = (User)session.get(User.class, "845465756dfgdfdfgdfg001");

			//persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
			user.setName("龙哥");

			session.getTransaction().commit();
		} catch (Exception e) {
			e.printStackTrace();
			session.getTransaction().rollback();
		} finally {
			HibernateUtils.closeSession(session);
		}
	}

	public void testReadByLoadMethod() {
		Session session = null;
		User user = null;
		try {
			session = HibernateUtils.getSession();
			session.beginTransaction();

			//不会发出查询sql,因为load方法实现了lazy(懒加载或延迟加载)
			//延迟加载:只有真正使用这个对象的时候才加载(发出sql语句)
			//hibernate延迟加载实现原理是代理方式
			user = (User)session.load(User.class, "8a8af09123500da10123500ddb240001");
			System.out.println("username = " + user.getName());

			//persistent状态,当属性发生改变的时候,hibernate会自动和数据库同步
			user.setName("龙哥");

			session.getTransaction().commit();
		} catch (Exception e) {
			e.printStackTrace();
			session.getTransaction().rollback();
		} finally {
			HibernateUtils.closeSession(session);
		}
	}

	public void testReadByLoadMethod1() {
		Session session = null;
		User user = null;
		try {
			session = HibernateUtils.getSession();
			session.beginTransaction();

			//采用load加载数据,如果数据库中没有相应的数据
			//则抛出异常ObjectNotFoundException
			user = (User)session.load(User.class, "454565555555551");

			//查不到对象,则抛异常
			System.out.println("username = " + user.getName());

			session.getTransaction().commit();
		} catch (Exception e) {
			e.printStackTrace();
			session.getTransaction().rollback();
		} finally {
			HibernateUtils.closeSession(session);
		}
	}

 

 

添加工程文件到附件中。

  • 大小: 3 KB
  • 大小: 16.8 KB
  • 大小: 2.9 KB