摘要: 本文結合《Spring源碼深度解析》來分析Spring 5.0.6版本的源代碼。若有描述錯誤之處，歡迎指正。

目錄

一、創建數據表結構

二、創建對應數據表的PO

三、創建表與實體間的映射

四、創建數據操作接口

五、創建數據操作接口實現類

六 、創建Spring配置文件

七、測試

Spring聲明式事務讓我們從復雜的事務處理中得到解脫，使我們再也不需要去處理獲得連接、關閉連接、事務提交和回滾等操作，再也不需要在與事務相關的方法中處理大置的 try...catch...finally代碼。Spring中事務的使用雖然已經相對簡單得多，但是，還是有很多的使用及配置規則，有興趣的讀者可以自己查閱相關資料進行深入研究，這裏只列舉出最常用的使用方法。

同樣，我們還是以最簡單的示例來進行直觀地介紹。

一、創建數據表結構

CREATE TABLE `user` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `username` varchar(20) DEFAULT NULL COMMENT ‘用戶名‘,
  `password` varchar(50) DEFAULT NULL COMMENT ‘密碼‘,
  `sex` tinyint(1) DEFAULT NULL COMMENT ‘用戶性別, 1: 男; 2: 女‘,
  `age` int(2) DEFAULT NULL COMMENT ‘
 
用戶年齡‘,
  `status` int(1) DEFAULT NULL COMMENT ‘用戶狀態, 1: 有效; 0: 無效‘,
  `create_tm` timestamp NULL DEFAULT NULL COMMENT ‘創建時間‘,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=33 DEFAULT CHARSET=utf8;

二、創建對應數據表的PO

public class User {
 
    private Long id;

    private String username;

    private
 
 String password;

    private Integer sex;

    private Integer age;

    private Integer status;

    private Date createTm;
    
    // 省略set/get方法
}

三、創建表與實體間的映射

public interface UserMapper {

    int insert(User record);
    
    User selectByPrimaryKey(Long id);
}

四、創建數據操作接口

public interface UserService {

    boolean register(UserDTO userDTO);
}

五、創建數據操作接口實現類

@Service("userService")
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    @Transactional(propagation = Propagation.REQUIRED)
    public boolean register(UserDTO userDTO) {
        if (!ObjectUtils.allNotNull(userDTO)) {
            return false;
        }

        User user = new User();
        try {
            BeanUtils.copyProperties(userDTO, user);
            user.setStatus(1);
            user.setCreateTm(new Date());
        }catch (BeansException e) {
            return false;
        }

        boolean ret = userMapper.insert(user) == 1;
        // 事務測試，加上這句代碼則數據不會保存到數據庫中
        throw new RuntimeException("insert error");

        return ret;
    }
}

六 、創建Spring配置文件

<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/tx
                           http://www.springframework.org/schema/tx/spring-tx.xsd">

    <!-- 配置數據源 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"
          lazy-init="true">
        <property name="driverClassName" value="${jdbc.driverClassName}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>

        <!-- 配置連接池初始化大小、最小、最大 -->
        <property name="initialSize" value="${jdbc.initialSize}"/>
        <property name="minIdle" value="${jdbc.minIdle}"/>
        <property name="maxActive" value="${jdbc.maxActive}"/>
        <!-- 配置獲取連接等待超時的時間，單位是毫秒 -->
        <property name="maxWait" value="${jdbc.maxWait}"/>
        <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}"/>
        <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}"/>
        <property name="validationQuery" value="select 1"/>
        <property name="testWhileIdle" value="${jdbc.testWhileIdle}"/>
        <property name="testOnBorrow" value="${jdbc.testOnBorrow}"/>
        <property name="testOnReturn" value="${jdbc.testOnReturn}"/>
        <!-- 打開PSCache，並且指定每個連接上PSCache的大小 -->
        <property name="poolPreparedStatements" value="${jdbc.poolPreparedStatements}"/>
        <property name="maxPoolPreparedStatementPerConnectionSize"
                  value="${jdbc.maxPoolPreparedStatementPerConnectionSize}"/>
        <!-- 統計sql filter -->
        <property name="proxyFilters">
            <list>
                <bean class="com.alibaba.druid.filter.stat.StatFilter">
                    <property name="mergeSql" value="true"/>
                    <property name="slowSqlMillis" value="${jdbc.slowSqlMillis}"/>
                    <property name="logSlowSql" value="true"/>
                </bean>
            </list>
        </property>
    </bean>

    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <tx:annotation-driven/>

</beans>

七、測試

public static void main(String[] args) {
    ApplicationContext context = new ClassPathXmlApplicationContext("spring/application.xml");
    UserService userService = (UserService) context.getBean("userService");
    UserDTO userDTO = new UserDTO();
    userDTO.setUsername("張三");
    userDTO.setAge(20);
    userDTO.setSex(1);
    // 保存一條記錄
     userService.register(userDTO);
}

上面的測試示例中，UserServicelmpl類對接口UserService中的register函數的實現最後加入了一句拋出異常的代碼：throw new RuntimeException("insert error")。當註掉這段代碼執行測試類，那 麽會看到數據被成功的保存到了數據庫中，但是如果加入這段代碼時再次運行測試類，發現此處的操作並不會將數據保存到數據庫中。

註意：默認情況下Spring中的事務處理只對RuntimeException方法進行回滾，所以，如果此處將RuntimeException替換成普通的Exception不會產生回滾效果。

Spring事務（一）JDBC方式下的事務使用示例