public interface TransactionDefinition {
    // 如果當(dāng)前沒有事物，則新建一個(gè)事物；如果已經(jīng)存在一個(gè)事物，則加入到這個(gè)事物中。
    int PROPAGATION_REQUIRED = 0;
    // 支持當(dāng)前事物，如果當(dāng)前沒有事物，則以非事物方式執(zhí)行。
    int PROPAGATION_SUPPORTS = 1;
    // 使用當(dāng)前事物，如果當(dāng)前沒有事物，則拋出異常。
    int PROPAGATION_MANDATORY = 2;
    // 新建事物，如果當(dāng)前已經(jīng)存在事物，則掛起當(dāng)前事物。
    int PROPAGATION_REQUIRES_NEW = 3;
    // 以非事物方式執(zhí)行，如果當(dāng)前存在事物，則掛起當(dāng)前事物。
    int PROPAGATION_NOT_SUPPORTED = 4;
    // 以非事物方式執(zhí)行，如果當(dāng)前存在事物，則拋出異常。
    int PROPAGATION_NEVER = 5;
    // 如果當(dāng)前存在事物，則在嵌套事物內(nèi)執(zhí)行；如果當(dāng)前沒有事物，則與PROPAGATION_REQUIRED傳播特性相同
    int PROPAGATION_NESTED = 6;
    // 使用后端數(shù)據(jù)庫(kù)默認(rèn)的隔離級(jí)別。
    int ISOLATION_DEFAULT = -1;
    // READ_UNCOMMITTED 隔離級(jí)別
    int ISOLATION_READ_UNCOMMITTED = Connection.TRANSACTION_READ_UNCOMMITTED;
    // READ_COMMITTED 隔離級(jí)別
    int ISOLATION_READ_COMMITTED = Connection.TRANSACTION_READ_COMMITTED;
    // REPEATABLE_READ 隔離級(jí)別
    int ISOLATION_REPEATABLE_READ = Connection.TRANSACTION_REPEATABLE_READ;
    // SERIALIZABLE 隔離級(jí)別
    int ISOLATION_SERIALIZABLE = Connection.TRANSACTION_SERIALIZABLE;
    // 默認(rèn)超時(shí)時(shí)間
    int TIMEOUT_DEFAULT = -1;
    // 獲取事物傳播特性
    int getPropagationBehavior();
    // 獲取事物隔離級(jí)別
    int getIsolationLevel();
    // 獲取事物超時(shí)時(shí)間
    int getTimeout();
    // 判斷事物是否可讀
    boolean isReadOnly();
    // 獲取事物名稱
    @Nullable
    String getName();
}

public interface PlatformTransactionManager {
    // 根據(jù)指定的傳播行為，返回當(dāng)前活動(dòng)的事務(wù)或創(chuàng)建新事務(wù)。
    TransactionStatus getTransaction(@Nullable TransactionDefinition definition) throws TransactionException;
    // 就給定事務(wù)的狀態(tài)提交給定事務(wù)。
    void commit(TransactionStatus status) throws TransactionException;
    // 執(zhí)行給定事務(wù)的回滾。
    void rollback(TransactionStatus status) throws TransactionException;
}

public interface TransactionStatus extends SavepointManager, Flushable {
    // 返回當(dāng)前事務(wù)是否為新事務(wù)（否則將參與到現(xiàn)有事務(wù)中，或者可能一開始就不在實(shí)際事務(wù)中運(yùn)行）
    boolean isNewTransaction();
    // 返回該事務(wù)是否在內(nèi)部攜帶保存點(diǎn)，也就是說，已經(jīng)創(chuàng)建為基于保存點(diǎn)的嵌套事務(wù)。
    boolean hasSavepoint();
    // 設(shè)置事務(wù)僅回滾。
    void setRollbackOnly();
    // 返回事務(wù)是否已標(biāo)記為僅回滾
    boolean isRollbackOnly();
    // 將會(huì)話刷新到數(shù)據(jù)存儲(chǔ)區(qū)
    @Override
    void flush();
    // 返回事物是否已經(jīng)完成，無論提交或者回滾。
    boolean isCompleted();
}

public interface SavepointManager {
    // 創(chuàng)建一個(gè)新的保存點(diǎn)。
    Object createSavepoint() throws TransactionException;
    // 回滾到給定的保存點(diǎn)。
    // 注意：調(diào)用此方法回滾到給定的保存點(diǎn)之后，不會(huì)自動(dòng)釋放保存點(diǎn)，
    // 可以通過調(diào)用releaseSavepoint方法釋放保存點(diǎn)。
    void rollbackToSavepoint(Object savepoint) throws TransactionException;
    // 顯式釋放給定的保存點(diǎn)。（大多數(shù)事務(wù)管理器將在事務(wù)完成時(shí)自動(dòng)釋放保存點(diǎn)）
    void releaseSavepoint(Object savepoint) throws TransactionException;
}

CREATE TABLE `account` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增主鍵',
  `balance` int(11) DEFAULT NULL COMMENT '賬戶余額',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8 COMMENT='--賬戶表'

import org.apache.commons.dbcp.BasicDataSource;
 import org.springframework.dao.DataAccessException;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 import org.springframework.transaction.TransactionDefinition;
 import org.springframework.transaction.TransactionStatus;
 import org.springframework.transaction.support.DefaultTransactionDefinition;
 import javax.sql.DataSource;
 public class MyTransaction {
     private JdbcTemplate jdbcTemplate;
     private DataSourceTransactionManager txManager;
     private DefaultTransactionDefinition txDefinition;
     private String insert_sql = "insert into account (balance) values ('100')";
     public void save() {
         // 1、初始化jdbcTemplate
         DataSource dataSource = getDataSource();
         jdbcTemplate = new JdbcTemplate(dataSource);
         // 2、創(chuàng)建物管理器
         txManager = new DataSourceTransactionManager();
         txManager.setDataSource(dataSource);
         // 3、定義事物屬性
         txDefinition = new DefaultTransactionDefinition();
         txDefinition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
         // 3、開啟事物
         TransactionStatus txStatus = txManager.getTransaction(txDefinition);
         // 4、執(zhí)行業(yè)務(wù)邏輯
         try {
             jdbcTemplate.execute(insert_sql);
             //int i = 1/0;
             jdbcTemplate.execute(insert_sql);
             txManager.commit(txStatus);
         } catch (DataAccessException e) {
             txManager.rollback(txStatus);
             e.printStackTrace();
         }
     }
     public DataSource getDataSource() {
         BasicDataSource dataSource = new BasicDataSource();
         dataSource.setDriverClassName("com.mysql.jdbc.Driver");
         dataSource.setUrl("jdbc:mysql://localhost:3306/my_test?useSSL=false&useUnicode=true&characterEncoding=UTF-8");
         dataSource.setUsername("root");
         dataSource.setPassword("dabin1991@");
         return dataSource;
     }
 }

public class MyTest {
    @Test
    public void test1() {
        MyTransaction myTransaction = new MyTransaction();
        myTransaction.save();
    }
}

import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
@Transactional(propagation = Propagation.REQUIRED)
public interface AccountServiceImp {
    void save() throws RuntimeException;
}

import org.springframework.jdbc.core.JdbcTemplate;
public class AccountServiceImpl implements AccountServiceImp {
    private JdbcTemplate jdbcTemplate;
    private static String insert_sql = "insert into account(balance) values (100)";
    @Override
    public void save() throws RuntimeException {
        System.out.println("==開始執(zhí)行sql");
        jdbcTemplate.update(insert_sql);
        System.out.println("==結(jié)束執(zhí)行sql");
        System.out.println("==準(zhǔn)備拋出異常");
        throw new RuntimeException("==手動(dòng)拋出一個(gè)異常");
    }
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
}

<?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">

    <!--開啟tx注解-->
    <tx:annotation-driven transaction-manager="transactionManager"/>

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

    <!--數(shù)據(jù)源-->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/my_test?useSSL=false&amp;useUnicode=true&amp;characterEncoding=UTF-8"/>
        <property name="username" value="root"/>
        <property name="password" value="dabin1991@"/>
    </bean>

    <!--jdbcTemplate-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!--業(yè)務(wù)bean-->
    <bean id="accountService" class="com.dabin.aop.AccountServiceImpl">
        <property name="jdbcTemplate" ref="jdbcTemplate"/>
    </bean>

</beans>

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

public class MyTest {

    @Test
    public void test1() {
        // 基于tx標(biāo)簽的聲明式事物
        ApplicationContext ctx = new ClassPathXmlApplicationContext("aop.xml");
        AccountServiceImp studentService = ctx.getBean("accountService", AccountServiceImp.class);
        studentService.save();
    }
}