Spring 使用注解對事務控制詳解與實例

1.什么是事務

一榮俱榮，一損俱損，很多復雜的操作我們可以把它看成是一個整體，要么同時成功，要么同時失敗。

事務的四個特征ACID：

原子性（Atomic）：表示組成一個事務的多個數據庫的操作的不可分割的單元，只有所有的操作成功才算成功，整個事務提交，其中任何一個操作失敗了都是導致整個所有操作失敗，事務會回滾。

一致性（Consistentcy）：事務操作成功后，數據庫所處的狀態和業務規則一致。如果A賬戶給B賬戶匯100，A賬戶減去100，B加上100，兩個賬戶的總額是不變的。
隔離性（islation）：在多個數據庫的操作相同的數據並發時，不同的事務有自己的數據空間，事務與事務之間不受干擾（不是絕對的）。干擾程度受數據庫或者操作事務的隔離級別來決定，隔離級別越高，干擾就越低，數據的一致性越好，並發性就越差。
持久性（Druability）：一旦事務提交成功，數據就被持久化到數據庫，不可以回滾。

 

 

2.spring使用注解對事務的控制

　　Spring 事務管理有兩種方式：編程式事務管理、聲明式事務管理
　　　　編程式事務管理通過TransactionTemplate手動管理事務，在實際應用中很少使用，我們來重點學習聲明式事務管理
　　　　聲明式事務管理有三種實現方式：基於TransactionProxyFactoryBean的方式、基於AspectJ的XML方式、基於注解的方式
　　

　　1. 新建一個java工程——導入spring 和事務管理所需要的jar   ——然后選擇全部jar 右鍵Build path   ——最后如圖           （我的java版本jre是1.8）                              Spring事務需要的jar

 

 

2.在src目錄下新建5個包   如圖

　　　　dao ：數據連接層，主要用於存放對數據進行操作的類

　　　　model：模型層，主要用於存放實體類

　　　　service：服務層，主要用於對數據連接層進行操作的一些服務類。

　　　　util：工具類，主要用於存儲工具方法

　　　　test：用於測試類

 

3.在dao數據連接層，建立里與數據庫操作的類與對應的接口 （Order 訂單 ，detail訂單明細）

　3.1　定義detailDao接口　代碼如下：

package com.spring.dao;

import com.spring.model.Detail;
import com.spring.model.Order;

public interface detailDao {
    //保存訂單明細
    public void saveDetail(Detail detail);
    
    
    
}

　　3.2  定義OrderDao接口 代碼如下：

package com.spring.dao;

import com.spring.model.Order;

public interface OrderDao {
    //保存訂單 
    public void saveOrder(Order order);
    
    
    
}

　　3.3 實現以上接口

detailDaoImp 代碼如下：

package com.spring.dao;

import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;

import com.spring.model.Detail;
import com.spring.model.Order;

public class detailDaoImp implements detailDao {

    private DataSource dataSource;
    private JdbcTemplate jdbcTemplate;

    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
        this.jdbcTemplate = new JdbcTemplate(dataSource);
    }
    //保存訂單明細
    public void saveDetail(Detail detail) {
        String SQL = "insert into t_detail values(null,?,?,?))";
        jdbcTemplate.update(SQL, new Object[] { detail.getItemName(),detail.getQuantity(),detail.getOrderId() });
        System.out.println("Insert detail success!");
    }

}

　　

 

     OrderDaoImp代碼如下：

package com.spring.dao;

import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;

import com.spring.model.Order;

public class OrderDaoImp implements OrderDao {

    private DataSource dataSource;
    private JdbcTemplate jdbcTemplate;

    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
        this.jdbcTemplate = new JdbcTemplate(dataSource);
    }
    //插入訂單
    public void saveOrder(Order order) {
        String SQL = "insert into t_order values (null,?)";
        System.out.println(SQL);
        System.out.println(order.getTotal_price());
        jdbcTemplate.update(SQL, new Object[]{order.getTotal_price()});
        System.out.println("Insert order success!");
    }

}

 

4.在model層中新建兩個實體類　　（Order訂單類，detail訂單明細類）

　　Order訂單類代碼如下：

package com.spring.model;

/*
 * 訂單表
 */
public class Order {
    //訂單編號
    private Integer order_id;
    //訂單總金額
    private Integer total_price;
    public Integer getOrder_id() {
        return order_id;
    }
    public void setOrder_id(Integer order_id) {
        this.order_id = order_id;
    }
    public Integer getTotal_price() {
        return total_price;
    }
    public void setTotal_price(Integer total_price) {
        this.total_price = total_price;
    }
}

　

　detail訂單明細類代碼如下：

package com.spring.model;

/**
 * 商品明細表
 * @author Administrator
 *
 */
public class Detail {
    //ID
    private Integer detailId;
    //外鍵　　暫時可以忽略
    private Integer orderId;
    public Integer getDetailId() {
        return detailId;
    }
    public void setDetailId(Integer detailId) {
        this.detailId = detailId;
    }
    public Integer getOrderId() {
        return orderId;
    }
    public void setOrderId(Integer orderId) {
        this.orderId = orderId;
    }
    public Integer getQuantity() {
        return quantity;
    }
    public void setQuantity(Integer quantity) {
        this.quantity = quantity;
    }
    public String getItemName() {
        return itemName;
    }
    public void setItemName(String itemName) {
        this.itemName = itemName;
    }
    //商品數量
    private Integer quantity;
    //商品數量
    private String itemName;

}

 

5.在service中定義一個接口並且實現它

　　　　OrderService代碼如下：

package com.spring.service;

import com.spring.model.Detail;
import com.spring.model.Order;

public interface OrderService {
    //插入訂單和訂單明細
    public void saveOrderAndDetail(Order order,Detail detail);
}

 

　　OrderServiceImp代碼如下：

package com.spring.service;

import org.springframework.transaction.annotation.Transactional;

import com.spring.dao.OrderDaoImp;
import com.spring.dao.detailDaoImp;
import com.spring.model.Detail;
import com.spring.model.Order;

/**
 * 服務層 使用注解來實現事務管理
 * 
 * @author Administrator
 *
 */

public class OrderServiceImp implements OrderService {
    // 注入兩個對象
    public OrderDaoImp OrderDaoImp;

    public detailDaoImp detailDaoImp;

    @Transactional
    @Override
    // 如果加上@Transaction時，方法執行有異常，整個事務數據都會回滾，數據庫中不會存在有數據。
    public void saveOrderAndDetail(Order order, Detail detail) {
        OrderDaoImp.saveOrder(order);
        /**
         * 如果不加@transaction時有異常存在，OrderDaoImp.saveOrder(order)方法將會執行。
         * 但detailDaoImp.saveDetail(detail)不會執行
         **/
        int i = 100 / 0;
        detailDaoImp.saveDetail(detail);

    }

    public OrderDaoImp getOrderDaoImp() {
        return OrderDaoImp;
    }

    public void setOrderDaoImp(OrderDaoImp orderDaoImp) {
        OrderDaoImp = orderDaoImp;
    }

    public detailDaoImp getDetailDaoImp() {
        return detailDaoImp;
    }

    public void setDetailDaoImp(detailDaoImp detailDaoImp) {
        this.detailDaoImp = detailDaoImp;
    }

}

 

6.在util包中定義一個通知方法類

package com.spring.util;

public class SeizedAdvice {
    /**
     * 定義通知
     */

    public void beforeAdvice(){
        System.out.println("——————我是前置通知————————");
        
    }
    public void afterAdvice(){
        System.out.println("------我是后置通知-------");
        
    }
    public void afterReturningAdvice(Object object){
        System.out.println("————————我是返回后通知——————————"+object.toString());
        
    }
    public void afterThrowingAdvice(IllegalAccessError illegalAccessError){
        System.out.println("--------我是異常返回異常返回通知---------"+illegalAccessError.toString());
    
        
    }
    
    
    
}

 

7.在test中定義個測試類，用於測試

package com.test;

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

import com.spring.model.Detail;
import com.spring.model.Order;
import com.spring.service.OrderServiceImp;

public class Test {

    public static void main(String[] args) {
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("bean.xml");
        OrderServiceImp imp=(OrderServiceImp)applicationContext.getBean("OrderServiceImp");
        
        Order order=new Order();
        order.setTotal_price(699);
        Detail detail=new Detail();
        detail.setItemName("牙刷");
        detail.setQuantity(3);
        detail.setOrderId(4);
        imp.saveOrderAndDetail(order,detail);
        
    }
}

 

8.最后就是我們的配置文件和數據庫中的兩張表

　　　Spring  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:tx="http://www.springframework.org/schema/tx"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-4.3.xsd 
   http://www.springframework.org/schema/tx
   http://www.springframework.org/schema/tx/spring-tx-4.3.xsd
   http://www.springframework.org/schema/aop
   http://www.springframework.org/schema/aop/spring-aop-4.3.xsd">
    <!-- 定義數據源 -->
    <bean id="dataSource"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/jerry" />
        <property name="username" value="root" />
        <property name="password" value="1234" />
    </bean>



    <!-- 事務管理方式注解驅動 -->
    <tx:annotation-driven transaction-manager="transactionManager" />

    <!-- 配置數據   proxy-target-class屬性值決定是基於接口的還是基於類的代理被創建。
        如果proxy-target-class 屬性值被設置為true，那么基於類的代理將起作用-->
    <aop:config proxy-target-class="true">
        <!-- 切 面-->
        <aop:aspect id="myAspect" ref="SeizedAdvice">
            <!-- 切 點-->
            <aop:pointcut expression="execution(* com.spring.service.OrderServiceImp.*(..))"
                id="myPointCut" />
            <aop:before pointcut-ref="myPointCut" method="beforeAdvice" />
            <aop:after pointcut-ref="myPointCut" method="afterAdvice" />
        </aop:aspect>
    </aop:config>


    <!-- 定義事務管理器 -->
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <!-- 定義我們所需的bean -->
    <bean id="SeizedAdvice" class="com.spring.util.SeizedAdvice"></bean>

    <bean id="OrderServiceImp" class="com.spring.service.OrderServiceImp">
        <property name="detailDaoImp" ref="detailDaoImp"></property>
        <property name="OrderDaoImp" ref="OrderDaoImp"></property>
    </bean>

    <bean id="detailDaoImp" class="com.spring.dao.detailDaoImp">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <bean id="OrderDaoImp" class="com.spring.dao.OrderDaoImp">
        <property name="dataSource" ref="dataSource" />
    </bean>

</beans>

 

　9.　數據庫設計

detail（訂單明細表  detail_id   訂單明細ID，item_name  商品名稱，quantity  訂單數量  ，order_id  外鍵   暫時不用管這個屬性）

 

Order（訂單表，order_id   訂單id，total_price   總金額）

 

 10. 沒有加@transaction測試如下：

 

這就會造成數據錯誤，不符合事務管理要求。加上@transaction再次測試如下圖；