spring进行声明式事务管理(annotation)

在使用注解的时候，首先得在配置文件bean.xml中添加命名空间：

xmlns:tx="http://www.springframework.org/schema/tx"

 

然后在xsi:schemaLocation中添加：

http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-2.5.xsd

 

再次引入事务管理者：

<tx:annotation-driven transaction-manager="txManager"/>

 

bean.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
           http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context-2.5.xsd
           http://www.springframework.org/schema/tx
           http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
	
	<context:component-scan base-package="com.test"></context:component-scan>
	
	<bean id="myDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
	    <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
	    <property name="url" value="jdbc:oracle:thin:@localhost:1521:oralsb"/>
	    <property name="username" value="scott"/>
	    <property name="password" value="tiger"/>
	</bean>
	
	<!-- annotation版 -->
	<bean id="mySessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
	    <property name="dataSource" ref="myDataSource"/>
		<property name="annotatedClasses">
			<list>
	        	<value>com.test.model.User</value>
	        	<value>com.test.model.Log</value>
			</list>
	    </property>
	    <property name="hibernateProperties">
	    	<props>
		        <prop key="hibernate.dialect">org.hibernate.dialect.Oracle9iDialect</prop>
		        <prop key="hibernate.show_sql">true</prop>
		        <prop key="hibernate.format_sql">true</prop>
<!--		        <prop key="hibernate.hbm2ddl.auto">create</prop>-->
		    </props>
	    </property>
	</bean>
	  
	<!-- 定义事务管理者 --> 
	<tx:annotation-driven transaction-manager="txManager"/>
	  
	<bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="mySessionFactory" />
	</bean>
	
</beans>

 

实体类

User.java

package com.test.model;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name="t_user")
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;
	}

}

 

Log.java

package com.test.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 message;

	@Id
	@GeneratedValue
	public int getId() {
		return id;
	}

	public void setId(int id) {
		this.id = id;
	}

	public String getMessage() {
		return message;
	}

	public void setMessage(String message) {
		this.message = message;
	}

}

 

接口

UserDAO.java

package com.test.dao;

import com.test.model.User;

public interface UserDAO {
	public void save(User user);
}

 

LogDAO.java

package com.test.dao;

import com.test.model.Log;

public interface LogDAO {
	public void save(Log log);
}

 

实现接口类

UserDAOImpl.java

package com.test.dao.impl;

import javax.annotation.Resource;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.stereotype.Component;

import com.test.dao.UserDAO;
import com.test.model.User;

@Component("userDAOImpl")
public class UserDAOImpl implements UserDAO {

	private SessionFactory sessionFactory;

	public SessionFactory getSessionFactory() {
		return sessionFactory;
	}
	
	@Resource
	public void setSessionFactory(SessionFactory sessionFactory) {
		this.sessionFactory = sessionFactory;
	}

	public void save(User user) {
		Session session = sessionFactory.getCurrentSession();
		session.save(user);
	}
}

 

LogDAOImpl.java

package com.test.dao.impl;

import javax.annotation.Resource;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.stereotype.Component;

import com.test.dao.LogDAO;
import com.test.model.Log;

@Component("logDAOImpl")
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 session = sessionFactory.getCurrentSession();
		session.save(log);
		// spring默认RuntimeException的情况下事务会回滚
		// throw new RuntimeException("exception!");
	}
}

 

服务类

UserService.java

package com.test.service;

import javax.annotation.Resource;

import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.test.dao.LogDAO;
import com.test.dao.UserDAO;
import com.test.model.Log;
import com.test.model.User;

@Component("userService")
public class UserService {
	private UserDAO userDAO;
	private LogDAO logDAO;

	/**
	 * 事务的传播特性：
	 * 1.propagation默认值就是REQUIRED，表示在当前的环境中，别的地方调用这个方法，如果已经有了transaction，就用原来这个
	 * ，如果没有，就创建一个transaction(常用)。
	 * 2.propagation值为MANDATORY，表示在当前的环境中，别的地方调用这个方法必须有transaction，否则就报错。
	 * 3.propagation值为NESTED
	 * ，相当于在原来的transaction中内嵌了一个transaction，别的地方调用这个方法，原来的transaction暂停，创建一个保存点
	 * ，方法新起一个transaction，执行完了，原来的transaction继续，内嵌的transaction如果回滚了，
	 * 就会回滚到原来transaction的保存点(用的很少)
	 * 4.propagation值为NEVER，表示在当前的环境中，别的地方调用这个方法不能有transaction，否则就报错。
	 * 5.propagation值为NOT_SUPPORTED
	 * ，表示在当前的环境中，别的地方调用这个方法不能有transaction，否则先挂起原来的transaction
	 */
	@Transactional(propagation = Propagation.REQUIRED)
	public void add(User user) {
		userDAO.save(user);
		Log log = new Log();
		log.setMessage("user save success!");
		logDAO.save(log);
	}

	public UserDAO getUserDAO() {
		return userDAO;
	}

	// 这里会找注解Component的值为：userDAOImpl的那个类
	@Resource(name = "userDAOImpl")
	public void setUserDAO(UserDAO userDAO) {
		this.userDAO = userDAO;
	}

	public LogDAO getLogDAO() {
		return logDAO;
	}

	@Resource(name = "logDAOImpl")
	public void setLogDAO(LogDAO logDAO) {
		this.logDAO = logDAO;
	}

}

 

Junit测试类

UserServiceTest.java

package com.test.service;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.test.model.User;

public class UserServiceTest {

	@Test
	public void testAdd() throws Exception {
		ApplicationContext applicationContext = new ClassPathXmlApplicationContext("beans.xml");
		UserService service = (UserService) applicationContext.getBean("userService");
		User u = new User();
		u.setName("张三");
		service.add(u);
	}

}