聲明事務-注解配置

Spring事務控制我們要明確的：

1.JavaEE體系進行分層開發，事務處理位於業務層，所以，一般情況下我們使用事務代理，一般放在分層設計業務層。

2.spring框架為我們提供了一組事務控制的應用程序接口（API）。

3.spring的事務控制都是基於AOP的，它既可以使用編程的方式實現，也可以使用配置的方式實現。所以我們學習的重點是使用配置的方式實現。

 

出現以下錯誤可能是Service層代碼的AccountServiceImpl下，的真正業務代碼里沒有添加@Transactional(readOnly=false)

applicationContext.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    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/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        ">
        
    <!-- 配置組件包掃描的位置 -->
    <context:component-scan base-package="top.abcdit.spring"/>
    
    <!-- 讀取db.properties配置文件到Spring容器中 -->
    <context:property-placeholder location="classpath:db.properties"/>    
    
    <!-- 配置 阿里巴巴的 druid 數據源（連接池） -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        
        <!-- SpringEL 語法 ${key}  -->
        
        <property name="driverClassName" value="${jdbc.driverClassName}"/>
        <property name="url" value="${jdbc.url}"/>
        
        <!-- 
            ${username}如果key是username，name 默認spring框架調用的當前操作系統的賬號
            解決方案：可以統一給key加一個前綴
         -->
         
         <property name="username" value="${jdbc.username}"/>
         <property name="password" value="${jdbc.password}"/>
         <property name="maxActive" value="${jdbc.maxActive}"/>
    </bean>
    
    <!-- 配置jdbcTemplate 模板類  -->
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    
        <!-- 注入數據源（連接池），set方法注入 -->
        <property name="dataSource" ref="dataSource"/>
        <!-- 構造器注入 -->
           <!-- <constructor-arg name="dataSource" ref="dataSource"/> -->
        
    </bean>
    
    <!--
         開始Spring的事務配置 
         配置思路
         1.配置事務管理器
         2.配置事務細節
             把事務管理器配置到事務管理器中
         3.把事務管理器 使用aop切入Service層中
    -->
    
    <!-- 配置事務管理器 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!-- 注入數據源（連接池） -->
        <property name="dataSource" ref="dataSource"/>
    
    </bean>
    
    <!-- 開啟事務注解驅動 
        transaction-manager: 是萬物管理器
    -->
    <tx:annotation-driven transaction-manager="transactionManager"/>    
    
</beans>

AccountDao：

package top.abcdit.spring.dao;

public interface AccountDao {
    
    /**
     * 轉出方法
     * @param OutId
     * @param money
     */
    void transOut(Integer outId,Integer money);
    
    /**
     * 轉入方法
     * @param inId
     * @param money
     */
    void transInt(Integer inId,Integer money);
    
    
    
}

AccountDaoImpl：

package top.abcdit.spring.dao.impl;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import top.abcdit.spring.dao.AccountDao;

@Repository
public class AccountDaoImpl implements AccountDao {
    
    
    @Autowired  //默認按類型注入
    private JdbcTemplate jdbcTemplate;
    
    
    public void transOut(Integer outId, Integer money) {
        String sql = "update s_account set balance = balance - ? where id = ?";
        jdbcTemplate.update(sql, money, outId);
        
    }

    public void transInt(Integer inId, Integer money) {
        String sql = "update s_account set balance = balance + ? where id = ?";
        jdbcTemplate.update(sql, money, inId);
        
    }
    
}

AccountService:

package top.abcdit.spring.service;

public interface AccountService {
    
    /**
     * 這是轉賬的業務方法
     * @param outId 轉出賬號
     * @param inId  轉入賬號
     * @param money 金額
     */
    void trans(Integer outId,Integer inId, Integer money);
    
    void selectByPrimaryKey (Integer id);
    
    void selectList();
}

AccountServiceImpl:

package top.abcdit.spring.service.impl;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import top.abcdit.spring.dao.AccountDao;
import top.abcdit.spring.service.AccountService;


/*
 * 
 * @Transactional
 *     開啟注解事務配置，一個 @Transactional只能對當前類有效,當前類下面所有方法配置一樣
 *  isolation=Isolation.REPEATABLE_READ, 隔離級別
    propagation=Propagation.REQUIRED, 傳播行為（規則）
    timeout=5, 超時時間
    readOnly=true  是否是只讀事務
 * 
 */

@Service
@Transactional(isolation=Isolation.REPEATABLE_READ,
                propagation=Propagation.REQUIRED,
                timeout=5,
                readOnly=true
        )

public class AccountServiceImpl implements AccountService{
    
    @Autowired
    private AccountDao accountDao;
    
    
    /**
     *  這是真正的業務方法
     * 一個業務方法有多個 功能 (多個dao層方法)
     * 
     */
    @Transactional(readOnly=false) //注解配置時，這里也要添加 43     public void trans(Integer outId, Integer inId, Integer money) {
        
        accountDao.transOut(outId, money);
        //System.out.println(1/0);
        accountDao.transInt(inId, money);
        
    }
    
    @Transactional(readOnly=true)
    public void selectByPrimaryKey(Integer id) {
        
    }
    
    @Transactional(readOnly=true)
    public void selectList() {
        
    }

    
}　　

db.properties配置文件

jdbc.driverClassName=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring_jdbc?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT
jdbc.username=root
jdbc.password=myroot
jdbc.maxActive=10

測試代碼：

package top.abcdit.spring.test;

import static org.junit.Assert.*;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import top.abcdit.spring.service.AccountService;



@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class AccountServiceTest {
    
    @Autowired
    private AccountService service;
    
    @Test
    public void testName() throws Exception {
        service.trans(10001, 10002, 3000);
    }

}