spring声明式事务以及配置

 

使用spring提供的事务处理机制的好处是程序员可以不用关心事务的切面了，只要配置就好了，可以少写代码。

 

spring声明式事务处理

   spring

   声明：针对的是程序员，程序员告诉spring容器，哪些方法需要事务，哪些方法不需要事务

   事务处理   spring容器来做事务处理

目的：让spring管理事务，开发者不再关注事务

 

 

spring声明式事务处理的步骤：

   1、搭建环境

   2、把dao层和service层的接口和类写完

   3、在spring的配置文件中，先导入dataSource

   4、测试

   5、导入dao和service层的bean

   6、测试

   7、进行AOP的配置

       1、引入事务管理器

       2、进行aop的配置

   8、测试service层的类看是否是代理对象

 

 

例子

Person.java

package cn.itcast.spring.jdbc.transaction;

public class Person {
    private Long pid;
    private String pname;
    private String psex;
    public Long getPid() {
        return pid;
    }
    public void setPid(Long pid) {
        this.pid = pid;
    }
    public String getPname() {
        return pname;
    }
    public void setPname(String pname) {
        this.pname = pname;
    }
    public String getPsex() {
        return psex;
    }
    public void setPsex(String psex) {
        this.psex = psex;
    }
    
}

MyPersonDao.java

package cn.itcast.spring.jdbc.transaction;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
public class MyPersonDao extends JdbcDaoSupport{    
    public void savePerson()
    {
        this.getJdbcTemplate().execute("insert into person(pname,psex) values('bbbbbb','aaaa')");
        int i=1/0;
    }
}

PersonService.java

package cn.itcast.spring.jdbc.transaction;

import cn.itcast.spring.jdbc.PersonDao;

public class PersonService {
    private MyPersonDao dao=new MyPersonDao();
    
    public MyPersonDao getDao() {
        return dao;
    }

    public void setDao(MyPersonDao dao) {
        this.dao = dao;
    }

    public void savePerson()
    {
        dao.savePerson();

    }
}

MyException.java

package cn.itcast.spring.jdbc.transaction;

public class MyException {
    public void defineException(Throwable ex){
        System.out.println(ex.getMessage());
    }
    
}

jdbc.properties

jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc\:mysql\://localhost\:3306/hibernate_basic
jdbc.username=root
jdbc.password=friends

重点 applicationContext-spring_jdbc_transaction.xml

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 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/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
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <value>classpath:jdbc.properties</value>
        </property>
    </bean>


    <bean id="dataSource" destroy-method="close"
        class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="${jdbc.driverClassName}" />
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
    </bean>

    <bean id="personDao" class="cn.itcast.spring.jdbc.transaction.MyPersonDao">
        <property name="dataSource">
            <ref bean="dataSource" />
        </property>
    </bean>
    <bean id="serviceDao" class="cn.itcast.spring.jdbc.transaction.PersonService">
        <property name="dao">
            <ref bean="personDao"/>
        </property>
    </bean>
    
    <bean id="myException" class="cn.itcast.spring.jdbc.transaction.MyException"></bean>
<!--     spring提供的事务管理器， -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource">
            <ref bean="dataSource"/>
        </property>
    </bean>
    <!--
        通知 1、告诉spring容器，采用什么样的方法处理事务 2、告诉spring容器，目标方法应该采用什么样的事务处理策略
    -->
    <tx:advice id="tx" transaction-manager="transactionManager">
        <tx:attributes>
            <!--
                save开头的函数名 name规定方法 isolation 默认值为DEFAULT propagation 传播机制 REQUIRED
            -->
            <tx:method name="save*" read-only="false" />
        </tx:attributes>
    </tx:advice>
<!--     本来事务由程序员自己写并且当切面放入，但是这里spring提供了事务处理的通知方法，所以不用程序员写切面了 -->
    <aop:config >
        <aop:pointcut expression="execution(* cn.itcast.spring.jdbc.transaction.PersonService.*(..))" id="perform"/>
        <aop:advisor advice-ref="tx" pointcut-ref="perform" />
<!--         指定了切面和通知 -->
        <aop:aspect  ref="myException">
            <aop:after-throwing method="defineException" pointcut-ref="perform" throwing="ex"/>
        </aop:aspect>
    </aop:config>
</beans>

测试

package cn.itcast.spring.jdbc.transaction;

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

import cn.itcast.spring.jdbc.PersonDao;
import cn.itcast.spring.jdbc.PersonDao2;
import cn.itcast.spring.jdbc.PersonDao3;

public class test {
    @Test
    public void testPersonDao1()
    {
        ApplicationContext context=new ClassPathXmlApplicationContext("applicationContext-spring_jdbc_transaction.xml");
        PersonService dao=(PersonService) context.getBean("serviceDao");
        dao.savePerson();
    }
    
}