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类:
- 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();
- }
- }
- }
- }
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的三个状态进行测试:
- 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);
- }
- }
- }
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() 方法的不同:
- 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);
- }
- }
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);
}
}
添加工程文件到附件中。
