1.HibernateTransactionManager功能介绍

  ① 使用hibernate实现dml语句时,注意sessionFactory.opensession(),打开新的session它是没有事物的

  ② 如果为其配置了事务处理,要使用sessionFactory.getCurrentSession();如果不使用这个,那么将开启新的session,事务处理失效

  ③ 给一个类或者一个方法配置了@Transactional那么它的一系列子方法在使用getCurrentSession()都会使用同一个session,完成一整个事务处理的过程,如果不配置@Transactional,线程中没有session,使用getCurrentSession()爆出异常(ps:这种异常来源于hibernate的配置,hibernate.session.class=thread:没有session就开启一个,要有就使用当前的,我们这里面不涉及)

  ④ 无论是哪一种事务处理类,dataSourceManager还是HibernateTransactionManager,它们需要的数据源是不一样的,但是都是一样的使用方法

  ⑤ 如果用hibernate的访问数据,就用HibernateTransactionManager, 如果用jdbc,就用dataSourceManager

2.HibernateTemplate 事务处理

  ① 虽然hibernateTemplate所使用的方法是.save()、.update()但是在spring.xml的中同样要为其配置事务处理,原理是它需要的数据源是一个sessionFactory,而HibernateTransactionManager需要的数据源同样是sessionFactory,所以在Template的内部它所使用的同样是getCurrentSession().

3.源程序

  ① Model

package com.bjsxt.model;import javax.persistence.Entity;import javax.persistence.GeneratedValue;import javax.persistence.Id;import javax.persistence.Table;@Entity@Table(name="t_log")public class Log {	private int id;	private String msg;		@Id	@GeneratedValue	public int getId() {		return id;	}	public void setId(int id) {		this.id = id;	}	public String getMsg() {		return msg;	}	public void setMsg(String msg) {		this.msg = msg;	}		}

package com.bjsxt.model;import javax.persistence.Entity;import javax.persistence.GeneratedValue;import javax.persistence.Id;import javax.persistence.Table;@Entity@Table(name="user_U")public class User {	private int id;	private String name;		@Id	@GeneratedValue	public int getId() {		return id;	}	public void setId(int id) {		this.id = id;	}	public String getName() {		return name;	}	public void setName(String name) {		this.name = name;	}	}

  ② Dao 接口

package com.bjsxt.dao;import com.bjsxt.model.Log;public interface LogDAO {	public void save(Log log);}

package com.bjsxt.dao;import com.bjsxt.model.User;public interface UserDAO {	public void save(User user);}

  ③ Dao 实现

package com.bjsxt.dao.impl;import javax.annotation.Resource;import org.hibernate.Session;import org.hibernate.SessionFactory;import org.springframework.stereotype.Component;import org.springframework.transaction.annotation.Transactional;import com.bjsxt.dao.LogDAO;import com.bjsxt.model.Log;@Component("logDAO") public class LogDAOImpl implements LogDAO {	private SessionFactory sessionFactory;	public SessionFactory getSessionFactory() {		return sessionFactory;	}		@Resource	public void setSessionFactory(SessionFactory sessionFactory) {		this.sessionFactory = sessionFactory;	}	public void save(Log log) {				Session s = sessionFactory.getCurrentSession();		s.save(log);		//throw new RuntimeException("error!");	}}

package com.bjsxt.dao.impl;import javax.annotation.Resource;import org.hibernate.Session;import org.hibernate.SessionFactory;import org.junit.Test;import org.springframework.stereotype.Component;import org.springframework.transaction.annotation.Transactional;import com.bjsxt.dao.UserDAO;import com.bjsxt.model.User;@Component("u") public class UserDAOImpl implements UserDAO {	private SessionFactory sessionFactory;	public SessionFactory getSessionFactory() {		return sessionFactory;	}		@Resource	public void setSessionFactory(SessionFactory sessionFactory) {		this.sessionFactory = sessionFactory;	}	@Test    @Transactional(readOnly=true)	public void save(User user) {					Session s = sessionFactory.getCurrentSession();						s.save(user);					//throw new RuntimeException("exeption!");	}}

  ④ service(在这一层中加入@Transactional,有关联对象的dml时候,只要有一方出现异常,即事务回滚)

package com.bjsxt.service;import javax.annotation.Resource;import org.springframework.stereotype.Component;import org.springframework.transaction.annotation.Propagation;import org.springframework.transaction.annotation.Transactional;import com.bjsxt.dao.LogDAO;import com.bjsxt.dao.UserDAO;import com.bjsxt.model.Log;import com.bjsxt.model.User;@Component("userService")public class UserService {		private UserDAO userDAO;	private LogDAO logDAO;		public void init() {		System.out.println("init");	}		public User getUser(int id) {		return null;	}		@Transactional(readOnly=true)	public void add(User user) {					userDAO.save(user);			Log log = new Log();			log.setMsg("a user saved!");			logDAO.save(log);//			int a = 0;//			int b = 1/a;			}	public UserDAO getUserDAO() {		return userDAO;	}		@Resource(name="u")	public void setUserDAO( UserDAO userDAO) {		this.userDAO = userDAO;	}			public LogDAO getLogDAO() {		return logDAO;	}		@Resource	public void setLogDAO(LogDAO logDAO) {		this.logDAO = logDAO;	}	public void destroy() {		System.out.println("destroy");	}}

  ⑤ Test

package com.bjsxt.service;import org.junit.Test;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.bjsxt.model.User;//Dependency Injection//Inverse of Controlpublic class UserServiceTest {	@Test 	public void testAdd() throws Exception {		ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml");		UserService service = (UserService)ctx.getBean("userService");		System.out.println(service.getClass());		User user = new User();		user.setId(2);		user.setName("Jack");		service.add(user);		ctx.destroy();			}public static void main(String[] args) {	ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml");	try {		new UserServiceTest().testAdd();	} catch (Exception e) {		// TODO Auto-generated catch block		e.printStackTrace();	}}}

  ⑥ HibernateTemplate 事务处理及测试程序

package com.bjsxt.hibernate.template;import javax.annotation.Resource;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.stereotype.Component;import org.springframework.transaction.annotation.Transactional;import com.bjsxt.dao.LogDAO;import com.bjsxt.dao.UserDAO;import com.bjsxt.model.User;@Component("h_template")public class HibernateTemplate {	private UserDAO userDAO;	private LogDAO logDAO;    private org.springframework.orm.hibernate3.HibernateTemplate hibernateTemplate;	public UserDAO getUserDAO() {		return userDAO;	}	public org.springframework.orm.hibernate3.HibernateTemplate getHibernateTemplate() {		return hibernateTemplate;	}	@Resource(type=org.springframework.orm.hibernate3.HibernateTemplate.class)	public void setHibernateTemplate(			org.springframework.orm.hibernate3.HibernateTemplate hibernateTemplate) {		this.hibernateTemplate = hibernateTemplate;	}	@Resource(name = "u")	public void setUserDAO(UserDAO userDAO) {		this.userDAO = userDAO;	}	public LogDAO getLogDAO() {		return logDAO;	}	@Resource	public void setLogDAO(LogDAO logDAO) {		this.logDAO = logDAO;	}	public void saveUser() {		User user = new User();		user.setName("Jack2");		this.hibernateTemplate.save(user);		int a = 0;		int b = 1/a;	}	public static void main(String[] args) {		ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml");	    HibernateTemplate template = (HibernateTemplate)ctx.getBean("h_template");	    template.saveUser();	}}

  ⑦ spring 配置

    
    	
     	
     	
     		
      			
       
        classpath:jdbc.properties
       		
      	
     	
     		
      		
      		
      		
      	
     	
     		
      		
      			
       				
        
         com.bjsxt.model.User
        				
        
         com.bjsxt.model.Log
        			
       		
      		
      			
       			
        
         update
        				
        
         				org.hibernate.dialect.Oracle9Dialect				
        				
        
         true
        			
       		
      	
     	
     		
      	
     		
     	
     		
      			
       		
      	
     	
     		
      		
      	
     	
     
      
     
    

  ⑧ jdbc.properties

jdbc.driverClassName=oracle.jdbc.OracleDriverjdbc.url=jdbc:oracle:thin:@127.0.0.1:1521:orcljdbc.username=newjdbc.password=sa

4. 项目列表

hibernate4 新特性