zoukankan      html  css  js  c++  java
  • SSH系列教材 (五)- 使用XML方式配置事务管理

    步骤1:删除Product表所有数据
    步骤2:先运行,看到效果,再测试
    步骤3:事务概念
    步骤4:故意制造异常,观察无事务管理的结果
    步骤5:配置事务管理
    步骤6:观察有事务管理的结果
    步骤7:Spring事务类型详解
    步骤8:MYSQL 表的类型必须是INNODB才支持事务

    步骤 1 : 删除Product表所有数据

    为了观察事务现象,需要对数据做一些准备,首先把product_ 表里的数据都删除

    delete from product_

    步骤 2 : 先运行,看到效果,再测试

    访问地址:

    http://127.0.0.1:8080/ssh/listProduct


    会看到如图所示的异常(这是故意造成的)。 
    接着执行sql语句

    select * from product_


    会发现表里没有数据,即表明相关操作在事务里,当发生异常后,数据并没有被提交

    先运行,看到效果,再测试

    步骤 3 : 事务概念

    事务概念,表现在4个方面:
    原子性(Atomicity),一致性(Consistency),隔离性(Isolation),持续性/永久性(Durability)
    大家接触的最直接的是原子性,即要么都成功,要么都失败。

    本知识点,在整合步骤的基础上进行,当数据库中没有产品的时候,会新创建5个产品。那么所谓的原子性就是,要么5个产品都创建成功,要么一个也别创建。

    List<Product> products= productDAO.list();

    if(products.isEmpty()){

        for (int i = 0; i < 5; i++) {

            Product p = new Product();

            p.setName("product " + i);

            productDAO.add(p);

            products.add(p);

        }

    }

    步骤 4 : 故意制造异常,观察无事务管理的结果

    在默认情况下是没有进行事务管理的,所以故意把代码修改,制造错误:
    当i==2的时候,抛出一个运行时异常,这样,就只创建了2条,而不是本来计划5条数据。
    修改后,清空product_表,重启tomcat,运行
    1. 第一次运行会抛出异常
    2. 第二次运行,因为已经有数据了,所以不会抛异常,但是只会看到2条数据。

    这就是没有事务管理的后果,只有部分数据增加

    故意制造异常,观察无事务管理的结果

    package com.how2java.service.impl;

    import java.util.List;

    import org.springframework.orm.hibernate3.HibernateTemplate;

    import com.how2java.dao.ProductDAO;

    import com.how2java.pojo.Product;

    import com.how2java.service.ProductService;

    public class ProductServiceImpl implements ProductService {

        ProductDAO productDAO;

        public List<Product> list() {

            List<Product> products= productDAO.list();

            if(products.isEmpty()){

                for (int i = 0; i < 5; i++) {

                    if(i==2)

                        throw new RuntimeException();

                    Product p = new Product();

                    p.setName("product " + i);

                    productDAO.add(p);

                    products.add(p);

                     

                }

            }

            return products;

        }

        public ProductDAO getProductDAO() {

            return productDAO;

        }

        public void setProductDAO(ProductDAO productDAO) {

            this.productDAO = productDAO;

        }

    }

    步骤 5 : 配置事务管理

    SSH的配置事务管理是非侵入式的,所谓的非侵入式,就是指不需要修改一行java代码,只需要进行applicationContext.xml的配置,即可达到事务管理的效果。
    1. 增加一个专门进行事务管理的bean

    <tx:advice id="txadvice" transaction-manager="transactionManager">  

        <tx:attributes>  

            <tx:method name="add*" propagation="REQUIRED" rollback-for="Exception" />  

            <tx:method name="del*" propagation="REQUIRED" rollback-for="Exception"/>

        <tx:method name="edit*" propagation="REQUIRED" rollback-for="Exception" />

            <tx:method name="update*" propagation="REQUIRED" rollback-for="Exception"/>  

            <tx:method name="list*" propagation="REQUIRED" rollback-for="Exception"/>  

        </tx:attributes>  

    </tx:advice> 


    这里面的add*,del*等等,表示对于这些名词开头的方法,进行事务管理。
    2. 配置切面

    <aop:config>  

        <aop:pointcut id="serviceMethod" expression="execution(* com.how2java.service.*.*(..))"/>  

        <aop:advisor pointcut-ref="serviceMethod" advice-ref="txadvice"/>  

    </aop:config>   


    这里使用了AOP切面编程的配置手段,让前面配置的事务管理bean,去和业务方法编织在一起。
    哪些业务方法呢?

    execution(* com.how2java.service.*.*(..))


    * 返回任意类型
    com.how2java.service.* 包名以com.how2java.service 开头的类的任意方法
    (..) 任意的参数类型
    这样就达到了对ProductServiceImpl的list()方法,进行事务管理的效果

    <?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:aop="http://www.springframework.org/schema/aop"

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

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

        xsi:schemaLocation="

       http://www.springframework.org/schema/beans 

       http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

       http://www.springframework.org/schema/aop 

       http://www.springframework.org/schema/aop/spring-aop-3.0.xsd

       http://www.springframework.org/schema/tx 

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

       http://www.springframework.org/schema/context      

       http://www.springframework.org/schema/context/spring-context-3.0.xsd">

      

        <bean name="productActionBean" class="com.how2java.action.ProductAction">

            <property name="productService" ref="productServiceImpl" />

        </bean>

         

        <bean name="productServiceImpl" class="com.how2java.service.impl.ProductServiceImpl">

            <property name="productDAO" ref="productDAOImpl" />

        </bean>

        <bean name="productDAOImpl" class="com.how2java.dao.impl.ProductDAOImpl">

            <property name="sessionFactory" ref="sf" />

        </bean>

        <bean name="sf"

            class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">

            <property name="dataSource" ref="ds" />

            <property name="mappingResources">

                <list>

                    <value>com/how2java/pojo/Product.hbm.xml</value>

                </list>

            </property>

      

            <property name="schemaUpdate">  

                <value>true</value>  

            </property>  

                     

            <property name="hibernateProperties">

                <value>

                    hibernate.dialect=org.hibernate.dialect.MySQLDialect

                    hibernate.show_sql=true

                    hbm2ddl.auto=update

                </value>

            </property>

        </bean>    

             

        <bean name="ds"

            class="org.springframework.jdbc.datasource.DriverManagerDataSource">

            <property name="driverClassName" value="com.mysql.jdbc.Driver" />

            <property name="url" value="jdbc:mysql://localhost:3306/how2java?characterEncoding=UTF-8"/>

            <property name="username" value="root" />

            <property name="password" value="admin" />

        </bean>

         

        <!-- 配置事务管理器(声明式的事务) --> 

        <bean id="transactionManager"class="org.springframework.orm.hibernate3.HibernateTransactionManager">  

            <property name="sessionFactory" ref="sf"></property>  

        </bean>  

        <tx:advice id="txadvice" transaction-manager="transactionManager">  

            <tx:attributes>  

                <tx:method name="add*" propagation="REQUIRED" rollback-for="Exception" />  

                <tx:method name="del*" propagation="REQUIRED" rollback-for="Exception"/>

                <tx:method name="edit*" propagation="REQUIRED" rollback-for="Exception" />

                <tx:method name="update*" propagation="REQUIRED" rollback-for="Exception"/>  

                <tx:method name="list*" propagation="REQUIRED" rollback-for="Exception"/>  

            </tx:attributes>  

        </tx:advice>  

           

        <aop:config>  

            <aop:pointcut id="serviceMethod" expression="execution(* com.how2java.service.*.*(..))"/>  

            <aop:advisor pointcut-ref="serviceMethod" advice-ref="txadvice"/>  

        </aop:config>   

    </beans>

    步骤 6 : 观察有事务管理的结果

    同样的,先删除掉product_里的所有数据,然后访问页面

    http://127.0.0.1:8080/ssh/listProduct


    就会观察到,无论访问多少次,都会抛出异常,并且数据库里的数据,一直都为空。
    为什么呢?作为一个事务里的方法,当i==2的时候,抛出异常,这个事务就回滚了,在i==0,i==1的时候插入到数据库里的两条数据,也就回滚了。
    从而达到了,要么一次性插入5条数据,要么一条也别插入的效果。

    观察有事务管理的结果

    步骤 7 : Spring事务类型详解

    配置事务管理中有这么一行配置信息:

    <tx:method name="add*" propagation="REQUIRED" rollback-for="Exception" />  


    这个REQUIRED,就是Spring事务类型,除了这种,还有其他好几种,都列罗在下:
    REQUIRED--支持当前事务,如果当前没有事务,就新建一个事务。这是最常见的选择。
    SUPPORTS--支持当前事务,如果当前没有事务,就以非事务方式执行。
    MANDATORY--支持当前事务,如果当前没有事务,就抛出异常。
    REQUIRES_NEW--新建事务,如果当前存在事务,把当前事务挂起。
    NOT_SUPPORTED--以非事务方式执行操作,如果当前存在事务,就把当前事务挂起。
    NEVER--以非事务方式执行,如果当前存在事务,则抛出异常。
    NESTED--如果当前存在事务,则在嵌套事务内执行。如果当前没有事务,则进行与REQUIRED类似的操作。

    最常见的就第一种REQUIRED,其他的,我也没怎么用过 -_-~

    步骤 8 : MYSQL 表的类型必须是INNODB才支持事务

    在Mysql中,只有当表的类型是INNODB的时候,才支持事务,所以需要把表的类型设置为INNODB,否则无法观察到事务.

    修改表的类型为INNODB的SQL:

    alter table product_ ENGINE  = innodb;



    查看表的类型的SQL

    show table status from how2java; 



    不过有个前提,就是当前的MYSQL服务器本身要支持INNODB,如果不支持,请看 开启MYSQL INNODB的办法


    更多内容,点击了解: https://how2j.cn/k/ssh/ssh-transaction/1076.html

  • 相关阅读:
    小工具之文件整合
    [JavaWeb基础] 031.dom4j写入xml的方法
    AES128_CBC模式加密
    eatwhatApp开发实战(九)
    [Objective-C] 021 KVC、KVO
    eatwhatApp开发实战(八)
    eatwhatApp开发实战(七)
    [Objective-C] 020_ Block
    eatwhatApp开发实战(六)
    年终总结--我的2019
  • 原文地址:https://www.cnblogs.com/Lanht/p/12789349.html
Copyright © 2011-2022 走看看