Spring框架总结（十二）

问题引入:
      程序的“事务控制”， 可以用aop实现！ 即只需要写一次，运行时候动态植入到业务方法上。

     一个业务的成功： 调用的service是执行成功的，意味着service中调用的所有的dao是执行成功的。  事务应该在Service层统一控制。

1、名词解释
      细粒度的事务控制： 可以对指定的方法、指定的方法的某几行添加事务控制.(比较灵活，但开发起来比较繁琐： 每次都要开启、提交、回滚.)
      粗粒度的事务控制： 只能给整个方法应用事务，不可以对方法的某几行应用事务。(因为aop拦截的是方法。)

编程式事务控制

      程序员手动控制事务，就叫做编程式事务控制。

声明式事务控制

         Spring提供了对事务的管理, 这个就叫声明式事务管理。

         Spring提供了对事务控制的实现。用户如果想用Spring的声明式事务管理，只需要在配置文件中配置即可； 不想使用时直接移除配置。这个实现了对事务控制的最大程度的解耦。         Spring声明式事务管理，核心实现就是基于Aop。

编程式事务控制与声明式事务控制实现
2、编程式事务控制

        Jdbc代码：

                   Conn.setAutoCommite(false);  // 设置手动控制事务

         Hibernate代码：

                   Session.beginTransaction();    // 开启一个事务

声明式事务控制实现

        

Spring声明式事务管理器类：

          Jdbc技术：DataSourceTransactionManager

          Hibernate技术：HibernateTransactionManager

3、声明式事务管理

     

步骤：

1） 引入spring-aop相关的4个jar文件       

       spring-aopaopalliance.jar     

      aspectjrt.jar

      aspectjweaver.jar

      spring-aop-3.2.5.RELEASE.jar

2） 引入aop名称空间  【XML配置方式需要引入】
3） 引入tx名称空间    【事务方式必须引入】

事例编辑

1、bean.xml(注意:

 http://www.springframework.org/schema/aop
 http://www.springframework.org/schema/aop/spring-aop.xsd
 http://www.springframework.org/schema/tx
 http://www.springframework.org/schema/tx/spring-tx.xsd"
加载了这几个schme和相关的命名

)

<?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:p="http://www.springframework.org/schema/p"
    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.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/tx
         http://www.springframework.org/schema/tx/spring-tx.xsd">
    <!-- 数据对像.c3p0连接池 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql:///springmvcdb"></property>
        <property name="user" value="root"></property>
        <property name="password" value="123456"></property>
        <property name="initialPoolSize" value="3"></property>
        <property name="maxPoolSize" value="10"></property>
        <property name="maxStatements" value="100"></property>
        <property name="acquireIncrement" value="2"></property>
    </bean>

    <!-- jDBCTemplate工具类实例 -->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!-- dao实现 -->
    <bean id="deptDao" class="com.liuyang.xml.action.Dept_Dao">
        <property name="jdbcTemplate" ref="jdbcTemplate"></property>
    </bean>

    <!-- service实现 -->
    <bean id="deptService" class="com.liuyang.xml.action.Dept_Service">
        <property name="dept_Dao" ref="deptDao"></property>
    </bean>

    <!-- #############5. Spring声明式事务管理配置############### -->
    <!-- 5.1 配置事务管理器类 -->
    <bean id="txManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!-- 5.2 配置事务增强(如果管理事务?) -->
    <tx:advice id="txAdvice" transaction-manager="txManager">
        <tx:attributes>
            <tx:method name="*" read-only="false" />
        </tx:attributes>
    </tx:advice>

    <!-- 5.3 Aop配置： 拦截哪些方法(切入点表表达式) + 应用上面的事务增强配置 -->
    <aop:config>
        <aop:pointcut
            expression="execution(* com.liuyang.xml.action.Dept_Service.ServiceSave(..))"
            id="pt" />
        <aop:advisor advice-ref="txAdvice" pointcut-ref="pt" />
    </aop:config>

</beans>    

2、创建user

    public class Dept_user {
    private int deptId;
    private String deptName;

    public int getDeptId() {
        return deptId;
    }

    public void setDeptId(int deptId) {
        this.deptId = deptId;
    }

    public String getDeptName() {
        return deptName;
    }

    public void setDeptName(String deptName) {
        this.deptName = deptName;
    }
}

3、创建dao

    public class Dept_Dao {

    private JdbcTemplate jdbcTemplate;

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public void save(Dept_user dept_action) {
        String sql = "insert into t_dept(deptName) values(?);";
        jdbcTemplate.update(sql, dept_action.getDeptName());
    }

}

4、创建service

    public class Dept_Service {
    private Dept_Dao dept_Dao;

    public void setDept_Dao(Dept_Dao dept_Dao) {
        this.dept_Dao = dept_Dao;
    }

    public void ServiceSave(Dept_user dept_action) {
        dept_Dao.save(dept_action);
    }

}

5、创建测试的数据在数据库

    SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for `t_dept`
-- ----------------------------
DROP TABLE IF EXISTS `t_dept`;
CREATE TABLE `t_dept` (
  `deptId` varchar(10) NOT NULL DEFAULT '',
  `deptName` varchar(50) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of t_dept
-- ----------------------------
INSERT INTO `t_dept` VALUES ('22', 'test');
INSERT INTO `t_dept` VALUES ('10', '市场部');
INSERT INTO `t_dept` VALUES ('12', '财务部');
INSERT INTO `t_dept` VALUES ('9', '应用开发部');
INSERT INTO `t_dept` VALUES ('', 'test');
INSERT INTO `t_dept` VALUES ('', 'test');

6、测试

@SuppressWarnings("resource")
public class App {

    @Test
    public void testApp() throws Exception {
        ApplicationContext ac = new ClassPathXmlApplicationContext(
                "com/liuyang/xml/action/beanTemplate.xml");

        Dept_user dept = new Dept_user();
        dept.setDeptId(15);
        dept.setDeptName("王小二");

        Dept_Service deptService = (Dept_Service) ac.getBean("deptService");
        deptService.ServiceSave(dept);

    }
}

 加上事物以后,遇到错误异常,事物会不将数据插入到表格中,比如

     public void ServiceSave(Dept_user dept_action) {
         dept_Dao.save(dept_action);
        int i = 1/0;
        dept_Dao.save(dept_action);
   }

方法中加入如上设置,事物就不会回滚.