hibernate persist update 方法没有正常工作(不保存数据，不更新数据)
工程结构
问题描述
在工程中通过spring aop的方式配置事务，使用hibernate做持久化。在代码实现中使用hibernate persit()方法插入数据到数据库，使用hibernate update()方法更新数据。问题是执行这两个方法没有报错，但是也没有插入数据或者更新数据。
原因
hibernate persist()以及update()方法只有事务执行flush()或者commit()方法，才将数据写入数据库。详细内容可以阅读博客：http://www.cnblogs.com/xiaoheike/p/5374613.html。使用spring aop配置的事务，在方法运行结束之后会运行commit()方法。程序实例可以看PersonDAOImpl.java（实现方法）小结，重点原因在于spring aop事务与session自己创建的事务是两个不同的事务，虽然最后spring aop 配置的事情 commit，但是session对象的事务并没有调用commit。以下是实例程序。
事务配置(applicationContext.xml)
<?xml version="1.0" encoding="UTF-8"?>
org.hibernate.dialect.MySQLDialect
update
true
true
classpath:/hibernate.cfg.xml
PersonDAOImpl.java（实现方法）
package com.journaldev.dao;
import java.util.List;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import com.journaldev.model.Person;
public class PersonDAOImpl implements PersonDAO {
private SessionFactory sessionFactory1;
private SessionFactory sessionFactory2;
public void setSessionFactory1(SessionFactory sessionFactory1) {
this.sessionFactory1 = sessionFactory1;
}
public void setSessionFactory2(SessionFactory sessionFactory2) {
this.sessionFactory2 = sessionFactory2;
}
public void save1(Person person) {
Session session1 = this.sessionFactory1.openSession();
session1.persist(person);
session1.close();
}
public void save2(Person person) {
Session session1 = this.sessionFactory1.openSession();
Session session2 = sessionFactory2.openSession();
Transaction tx = session2.beginTransaction();
session1.persist(person);
tx.commit();
session2.close();
session1.close();
}
public void save3(Person person) {
Session session1 = this.sessionFactory1.openSession();
Transaction tx = session1.beginTransaction();
session1.persist(person);
tx.commit();
session1.close();
}
@SuppressWarnings("unchecked")
public List list() {
Session session = this.sessionFactory1.openSession();
List personList = session.createQuery("from Person").list();
session.close();
return personList;
}
public Person findOne(Integer id) {
Session session = this.sessionFactory1.openSession();
Person p = (Person) session.get(Person.class, id);
session.close();
return p;
}
public void delete(Person person) {
Session session = this.sessionFactory1.openSession();
session.delete(person);
session.close();
}
public void update1(Person person) {
Session session = this.sessionFactory1.openSession();
session.update(person);
session.close();
}
public void update2(Person person) {
Session session1 = this.sessionFactory1.openSession();
Session session2 = this.sessionFactory1.openSession();
Transaction tx = session2.beginTransaction();
session1.update(person);
tx.commit();
session2.close();
session1.close();
}
public void update3(Person person) {
Session session1 = this.sessionFactory1.openSession();
Transaction tx = session1.beginTransaction();
session1.update(person);
tx.commit();
session1.close();
}
}
测试类
package com.journaldev.main;
import java.util.List;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.journaldev.dao.PersonDAO;
import com.journaldev.model.Person;
public class SpringHibernateMain {
public static void main(String[] args) {
test1();
test2();
test3();
}
public static void test1() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
PersonDAO personDAO = context.getBean(PersonDAO.class);
System.out.println("=================save1()==================");
// 增加一条数据
Person person = new Person();
person.setName("Pankaj");
person.setCountry("India");
personDAO.save1(person);
System.out.println("================listAll()===================");
// 检索所有数据
List list = personDAO.list();
for (Person p : list) {
System.out.println("所有记录：" + p);
}
System.out.println("================update1()===================");
// 更新一条Person记录
person.setCountry("zhongguo");
personDAO.update1(person);
System.out.println("更新一条记录India-->zhongguo：" + personDAO.findOne(person.getId()));
System.out.println("================delete()===================");
// 删除一条Person记录
personDAO.delete(person);
context.close();
}
public static void test2() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
PersonDAO personDAO = context.getBean(PersonDAO.class);
System.out.println("=================save3()==================");
// 增加一条数据
Person person = new Person();
person.setName("Pankaj");
person.setCountry("India");
personDAO.save1(person);
System.out.println("================listAll()===================");
// 检索所有数据
List list = personDAO.list();
for (Person p : list) {
System.out.println("所有记录：" + p);
}
System.out.println("================update2()===================");
// 更新一条Person记录
person.setCountry("zhongguo");
personDAO.update1(person);
System.out.println("更新一条记录India-->zhongguo：" + personDAO.findOne(person.getId()));
System.out.println("================delete()===================");
// 删除一条Person记录
personDAO.delete(person);
context.close();
}
public static void test3() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
PersonDAO personDAO = context.getBean(PersonDAO.class);
System.out.println("=================save3()==================");
// 增加一条数据
Person person = new Person();
person.setName("Pankaj");
person.setCountry("India");
personDAO.save3(person);
System.out.println("================listAll()===================");
// 检索所有数据
List list = personDAO.list();
for (Person p : list) {
System.out.println("所有记录：" + p);
}
System.out.println("================update3()===================");
// 更新一条Person记录
person.setCountry("zhongguo");
personDAO.update3(person);
System.out.println("更新一条记录India-->zhongguo：" + personDAO.findOne(person.getId()));
System.out.println("================delete()===================");
// 删除一条Person记录
personDAO.delete(person);
context.close();
}
}
运行结果
=================save1()==================
================update1()===================
Hibernate: select person0_.id as id1_0_0_, person0_.country as country2_0_0_, person0_.name as name3_0_0_ from PERSON person0_ where person0_.id=?
更新一条记录India-->zhongguo：null
=================save2()==================
================update2()===================
Hibernate: select person0_.id as id1_0_0_, person0_.country as country2_0_0_, person0_.name as name3_0_0_ from PERSON person0_ where person0_.id=?
更新一条记录India-->zhongguo：null
=================save3()==================
Hibernate: insert into PERSON (country, name) values (?, ?)
================update3()===================
Hibernate: update PERSON set country=?, name=? where id=?
Hibernate: select person0_.id as id1_0_0_, person0_.country as country2_0_0_, person0_.name as name3_0_0_ from PERSON person0_ where person0_.id=?
更新一条记录India-->zhongguo：id=8, name=Pankaj, country=zhongguo
原因分析
一共有三个测试例子，第一个例子test1()方法，调用save1()方法，使用spring aop配置的事务，从输出结果可以看出，数据没有插入数据库。update1()方法与save1()方法是相同情况。
第二个例子test2()方法，调用save2()方法，persist()方法被包围在spring aop配置的事务和session2的事务中(事务有提交)，从输出结果可以看出，数据没有插入数据库。update2()方法与save2()方法是相同情况。
第三个例子test3()方法，persist()方法被包围在spring aop配置的事务和session1的事务中(事务有提交)，从输出结果可以看出，数据成功插入数据库。update3()方法与save3()方法是相同情况。
通过实例程序可以看出，persist()，以及update()方法需要在调用它们的session中的事务中执行，最后该session的事务需要commit。
源代码可以从github获取：https://github.com/xiaoheike/SpringHibernateWithTransactionExample，这份源代码是spring + hibernate + spring aop 配置事务的demo工程。在完成demo过程中发现该问题，一直无法理解，一周之后恍然大悟，遂写这篇博客。
教程结束，感谢阅读。
欢迎转载，但请注明本文链接，谢谢。
2016/4/15 18:38:01