知识点八：spring的事物

spring2.5的事物管理，分为两种方式，一是基于注解方式的，而是基于配置文件方式的

一。基于注解方式

import java.util.List;

import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.mingbai.bean.StudentBean;
import com.mingbai.service.StudentService;

//将此业务类交由spring的事务管理，这时此方法的某个方法在执行前就开启事务，结束后提交事务
@Transactional                  
public class StudentServiceImpl implements StudentService {
	private JdbcTemplate jdbcTemplate;

	public void setDataSource(DataSource dataSource) {
		this.jdbcTemplate = new JdbcTemplate(dataSource);
	}

/*	public void delete(Integer sid) {
		jdbcTemplate.update("delete from student where id=?", 
				new Object[]{sid}, new int[]{java.sql.Types.INTEGER});
		throw new RuntimeException("我是异常");
	}*/
/*	@Transactional(rollbackFor=Exception.class)
	public void delete(Integer sid) throws Exception {
		jdbcTemplate.update("delete from student where id=?", 
				new Object[]{sid}, new int[]{java.sql.Types.INTEGER});
		throw new Exception("我是异常");
	}*/
	@Transactional(noRollbackFor=RuntimeException.class)
	public void delete(Integer sid) throws Exception {
		jdbcTemplate.update("delete from student where id=?", 
				new Object[]{sid}, new int[]{java.sql.Types.INTEGER});
		throw new RuntimeException("我是运行期异常");//运行期例外（unchecked exception）事务默认回滚
	}
	
	@Transactional(propagation=Propagation.NOT_SUPPORTED)
	public List<StudentBean> getAllStudent() {
		return jdbcTemplate.query("select * from student", new StudentRowMapper());
	}
	
	public StudentBean getStudent(Integer sid) {
		StudentBean sb = (StudentBean)jdbcTemplate.queryForObject("select * from student where id=?", new Object[]{sid}, new int[]{java.sql.Types.INTEGER}, new StudentRowMapper());
		return sb;
	}

	public void save(StudentBean student) {
		jdbcTemplate.update("insert into student(name,password) values(?,?)", 
				new Object[]{student.getName(),student.getPassword()}, new int[]{java.sql.Types.VARCHAR,java.sql.Types.VARCHAR});
	}

	public void update(StudentBean student) {
		jdbcTemplate.update("update student set name=? where id=?", 
				new Object[]{student.getName(),5}, new int[]{java.sql.Types.VARCHAR,java.sql.Types.INTEGER});
	}

}

数据库链接信息放在类路径的文件jdbc.properties中

driverClassName=org.gjt.mm.mysql.Driver
url=jdbc\:mysql\://localhost\:3306/test
username=root
password=
initialSize=1
maxActive=500
maxIdle=2
minIdle=1



此时的配置文件需要注明采用注解方式



<?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:aop="http://www.springframework.org/schema/aop"
       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/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">          
     
     
     <context:property-placeholder location="classpath:jdbc.properties"/><!-- 属性文件，占位符 -->
	 <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
	    <property name="driverClassName" value="${driverClassName}"/>
	    <property name="url" value="${url}"/>
	    <property name="username" value="${username}"/>
	    <property name="password" value="${password}"/>
	     <!-- 连接池启动时的初始值 -->
		 <property name="initialSize" value="${initialSize}"/>
		 <!-- 连接池的最大值 -->
		 <property name="maxActive" value="${maxActive}"/>
		 <!-- 最大空闲值.当经过一个高峰时间后，连接池可以慢慢将已经用不到的连接慢慢释放一部分，一直减少到maxIdle为止 -->
		 <property name="maxIdle" value="${maxIdle}"/>
		 <!--  最小空闲值.当空闲的连接数少于阀值时，连接池就会预申请去一些连接，以免洪峰来时来不及申请 -->
		 <property name="minIdle" value="${minIdle}"/>
	 </bean>
     
     
     <!-- 
     <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
	    <property name="driverClassName" value="org.gjt.mm.mysql.Driver"/>
	    <property name="url" value="jdbc:mysql://localhost:3306/test"/>
	    <property name="username" value="root"/>
	    <property name="password" value=""/>
		 <property name="initialSize" value="1"/>
		 <property name="maxActive" value="500"/>
		 <property name="maxIdle" value="1"/>
		 <property name="minIdle" value="1"/>
	 </bean>
	  -->
	<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  	   <property name="dataSource" ref="dataSource"/>
    </bean>
    <!-- 采用注解事务方式-->
    <tx:annotation-driven transaction-manager="txManager"/>
       <bean id="studentService" class="com.mingbai.service.impl.StudentServiceImpl">
       <property name="dataSource"  ref="dataSource"></property>
    </bean>
</beans>

一。基于xml配置方式

import java.util.List;

import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;

import com.mingbai.bean.StudentBean;
import com.mingbai.service.StudentService;

                  
public class StudentServiceImpl2 implements StudentService {
	private JdbcTemplate jdbcTemplate;

	public void setDataSource(DataSource dataSource) {
		this.jdbcTemplate = new JdbcTemplate(dataSource);
	}


	public void delete(Integer sid) throws Exception {
		jdbcTemplate.update("delete from student where id=?", 
				new Object[]{sid}, new int[]{java.sql.Types.INTEGER});
		throw new RuntimeException("我是运行期异常");//运行期例外（unchecked exception）事务默认回滚
	}
	
	public List<StudentBean> getAllStudent() {
		return jdbcTemplate.query("select * from student", new StudentRowMapper());
	}
	
	public StudentBean getStudent(Integer sid) {
		StudentBean sb = (StudentBean)jdbcTemplate.queryForObject("select * from student where id=?", new Object[]{sid}, new int[]{java.sql.Types.INTEGER}, new StudentRowMapper());
		return sb;
	}

	public void save(StudentBean student) {
		jdbcTemplate.update("insert into student(name,password) values(?,?)", 
				new Object[]{student.getName(),student.getPassword()}, new int[]{java.sql.Types.VARCHAR,java.sql.Types.VARCHAR});
	}

	public void update(StudentBean student) {
		jdbcTemplate.update("update student set name=? where id=?", 
				new Object[]{student.getName(),5}, new int[]{java.sql.Types.VARCHAR,java.sql.Types.INTEGER});
	}

}

配置文件

<?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:aop="http://www.springframework.org/schema/aop"
       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/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">          
     
     
  
     
     <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
	    <property name="driverClassName" value="org.gjt.mm.mysql.Driver"/>
	    <property name="url" value="jdbc:mysql://localhost:3306/test"/>
	    <property name="username" value="root"/>
	    <property name="password" value=""/>
		 <property name="initialSize" value="1"/>
		 <property name="maxActive" value="500"/>
		 <property name="maxIdle" value="1"/>
		 <property name="minIdle" value="1"/>
	 </bean>
	<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  	   <property name="dataSource" ref="dataSource"/>
    </bean>

    <!-- 采用基于xml方式 -->
    <tx:advice id="txadvice" transaction-manager="txManager">
        <tx:attributes>
        	<tx:method name="get*" read-only="true" propagation="NOT_SUPPORTED"/>
        	<tx:method name="*" />
        </tx:attributes>
    </tx:advice>
    <aop:config>
    	<aop:pointcut id="transactionPointcut" expression="execution(* com.mingbai.service..*.*(..))"/>
    	<aop:advisor advice-ref="txadvice" pointcut-ref="transactionPointcut"/>
    </aop:config>
         
     
    <bean id="studentService" class="com.mingbai.service.impl.StudentServiceImpl">
       <property name="dataSource"  ref="dataSource"></property>
    </bean>
</beans>