摘要：概念的異常體系建立在運(yùn)行期異常的基礎(chǔ)上，封裝了源異常數(shù)據(jù)訪問流程準(zhǔn)備資源啟動(dòng)事務(wù)在事務(wù)中執(zhí)行具體數(shù)據(jù)訪問操作提交回滾事務(wù)關(guān)閉資源，處理異常將相同的數(shù)據(jù)訪問流程固化到模板類中，把數(shù)據(jù)訪問中固定和變化的部分分開，同時(shí)保證模板類是線程安全的。

Spring的DAO異常體系建立在運(yùn)行期異常的基礎(chǔ)上，封裝了源異常

JDBC數(shù)據(jù)訪問流程：

準(zhǔn)備資源

啟動(dòng)事務(wù)

在事務(wù)中執(zhí)行具體數(shù)據(jù)訪問操作

提交/回滾事務(wù)

關(guān)閉資源，處理異常

Spring將相同的數(shù)據(jù)訪問流程固化到模板類中，把數(shù)據(jù)訪問中固定和變化的部分分開，同時(shí)保證模板類是線程安全的。Spring為不同的持久化技術(shù)都提供了簡化操作的模板和回調(diào)

數(shù)據(jù)庫事務(wù)：原子性，一致性，隔離性和持久性（ACID）

5類數(shù)據(jù)庫并發(fā)問題：

臟讀：A事務(wù)讀取到B事務(wù)尚未提交的數(shù)據(jù)

不可重復(fù)讀：A事務(wù)中讀取到B事務(wù)已經(jīng)提交的==更新==數(shù)據(jù)，即連續(xù)兩次讀取結(jié)果不同

幻讀：A事務(wù)讀取B事務(wù)的==新增==數(shù)據(jù)

第一類更新丟失：A事務(wù)撤銷時(shí)覆蓋了B事務(wù)的提交

第二類更新丟失：A事務(wù)覆蓋B事務(wù)已經(jīng)提交的數(shù)據(jù)

JDBC默認(rèn)情況下自動(dòng)提交，即每條執(zhí)行的SQL語句都對(duì)應(yīng)一個(gè)事務(wù)，AutoCommit = TRUE

Spring基于ThreadLocal解決有狀態(tài)的Connetion的并發(fā)問題，事務(wù)同步管理器org.springframework.transaction.support.TransactionSynchronizationManager使用ThreadLocal為不同事務(wù)線程提供獨(dú)立的資源副本

Spring事務(wù)管理基于3個(gè)接口：TransactionDefinition，TransactionStatus和PlatformTransactionManager

Spring為不同持久化技術(shù)提供了從TransactionSynchronizationManager獲取對(duì)應(yīng)線程綁定資源的工具類，如DataSourceUtils.getConnection(DataSource dataSource)。模板類在內(nèi)部通過工具類訪問TransactionSynchronizationManager中的線程綁定資源

Spring通過事務(wù)傳播行為控制當(dāng)前的事務(wù)如何傳播到被嵌套調(diào)用的目標(biāo)服務(wù)接口方法中

使用對(duì)標(biāo)注@Transactional注解的bean進(jìn)行加工處理，織入事務(wù)管理切面

@Transactional注解的屬性

事務(wù)傳播行為：propagation，默認(rèn)PROPAGATION_REQUIRED，即如果當(dāng)前沒有事務(wù)，就新建一個(gè)事務(wù)；否則加入到當(dāng)前事務(wù)

事務(wù)隔離級(jí)別：isolation，默認(rèn)ISOLATION_DEFAULT

讀寫事務(wù)屬性：readOnly

超時(shí)時(shí)間：timeout

回滾設(shè)置：rollbackFor，rollbackForClassName，noRollbackFor，noRollbackForClassName

在相同線程中進(jìn)行相互嵌套調(diào)用的事務(wù)方法工作于相同的事務(wù)中；如果在不同線程中，則工作在獨(dú)立的事務(wù)中

特殊方法：

注解不能被繼承，所以業(yè)務(wù)接口中的@Transactional注解不會(huì)被業(yè)務(wù)實(shí)現(xiàn)類繼承；方法處的注解會(huì)覆蓋類定義處的注解

對(duì)于基于接口動(dòng)態(tài)代理的AOP事務(wù)，由于接口方法都是public的，實(shí)現(xiàn)類的實(shí)現(xiàn)方法必須是public的，同時(shí)不能使用static修飾符。因此，可以通過接口動(dòng)態(tài)代理實(shí)施AOP增強(qiáng)、實(shí)現(xiàn)Spring事務(wù)的方法只能是public或public final的

基于CGLib動(dòng)態(tài)代理實(shí)施AOP的時(shí)候，由于使用final、static、private的方法不能被子類覆蓋，相應(yīng)的，這些方法不能實(shí)施AOP增強(qiáng)，實(shí)現(xiàn)事務(wù)

不能被Spring進(jìn)行AOP事務(wù)增強(qiáng)的方法不能啟動(dòng)事務(wù)，但是外層方法的事務(wù)上下文仍然可以傳播到這些方法中

本地mysql建表

CREATE TABLE `t_user` (
  `user_id` varchar(256) NOT NULL,
  `user_name` varchar(256) DEFAULT NULL,
  PRIMARY KEY (`user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8

springDAO.xml

User

package com.data;

public class User {

    private String userId;

    private String userName;

    public String getUserId() {
        return userId;
    }

    public void setUserId(String userId) {
        this.userId = userId;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

}

BaseDAO

package com.dao;

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

public class BaseDAO {

    @Autowired
    protected JdbcTemplate jdbcTemplate;
}

UserDAO

package com.dao;

import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

import com.data.User;
import com.mapper.UserRowMapper;

@Repository
public class UserDAO extends BaseDAO {

    private static final String SQL_GET_USER = "select * from t_user where " + "user_id = ?;";

    private static final String SQL_INSERT_USER = "insert into t_user values(?, ?);";

    private static final String SQL_CLEAN_USER = "delete from t_user where 1=1;";

    @Transactional
    public User getUserById(String userId) {
    return jdbcTemplate.queryForObject(SQL_GET_USER, new Object[]{userId}, new UserRowMapper());
    }

    @Transactional
    public int insertUser(User user) {
        return jdbcTemplate.update(SQL_INSERT_USER, user.getUserId(), user.getUserName());
    }

    @Transactional
    public int cleanUser() {
        return jdbcTemplate.update(SQL_CLEAN_USER);
    }
}

UserRowMapper

package com.dao;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;

import com.data.User;

public class UserRowMapper implements RowMapper{

    public User mapRow(ResultSet rs, int rowNumber) throws SQLException {
        User user = new User();
        user.setUserId(rs.getString("user_id"));
        user.setUserName(rs.getString("user_name"));
        return user;
    }
}

BaseTestCase

package com;

import org.junit.Assert;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations={"/springDAO.xml"})
public class BaseTestCase extends Assert {

}

TestUserDAO

package com.dao;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;

import com.BaseTestCase;
import com.data.User;

public class TestUserDAO extends BaseTestCase{

    @Before
    @After
    public void clean() {
        dao.cleanUser();
    }

    @Autowired
    private UserDAO dao;

    @Test
    public void getUserById() {
        User user = new User();
        String id = "id";
        String name = "name";
        user.setUserId(id);
        user.setUserName(name);
        assertEquals(dao.insertUser(user), 1);

        user = dao.getUserById(id);
        assertEquals(user.getUserId(), id);
        assertEquals(user.getUserName(), name);
    }
}