@Service
public class JdbcTransaction {
    @Autowired
    private DataSource dataSource;

    public int insertStudent(Student student) {
        Connection connection = null;
        int result = 0;
        try {
            // 獲取數(shù)據(jù)連接
            connection = dataSource.getConnection();
            // 開始事務(wù)
            connection.setAutoCommit(false);
            // 設(shè)置隔離級(jí)別
            connection.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
            // 執(zhí)行sql
            PreparedStatement prepareStatement = connection.prepareStatement("insert into t_student(name,gender,age) values (?,?,?)");
            prepareStatement.setString(1, student.getName());
            prepareStatement.setString(2, student.getGender());
            prepareStatement.setInt(3, student.getAge());
            result = prepareStatement.executeUpdate();
            // 提交事務(wù)
            connection.commit();
        } catch (Exception e1) {
            if (connection != null) {
                try {
                    // 事務(wù)回滾
                    connection.rollback();
                } catch (Exception e2) {
                    e2.printStackTrace();
                }
            }
            e1.printStackTrace();
        } finally {
            try {
                if (connection != null && !connection.isClosed()) {
                    // 關(guān)閉連接
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return result;
    }
}

select * from T where ID=2 lock in share mode;
select * from T where ID=2 for update;

@Service
public class StudentServiceImpl implements IStudentService {

    @Autowired
    private StudentRepository studentRepository;

    @Transactional(rollbackFor = RuntimeException.class)
    @Override
    public Student findStudentById(Long id) {
        return studentRepository.getOne(id);
    }

    ...

    @Transactional(rollbackFor = RuntimeException.class)
    @Override
    public void deleteStudent(Long id) {
        Student student = findStudentById(id);
        if(student == null){
            // data not exists
        }
        studentRepository.deleteById(id);
    }
    
    ...
}

package org.springframework.transaction.annotation;

import org.springframework.transaction.TransactionDefinition;

public enum Propagation {

	/**
	 * 支持當(dāng)前事務(wù)，如果不存在則創(chuàng)建一個(gè)新事務(wù)。 類似于同名的 EJB 事務(wù)屬性。
	 * 這是事務(wù)注釋的默認(rèn)設(shè)置。
	 */
	REQUIRED(TransactionDefinition.PROPAGATION_REQUIRED),

	/**
	 * 支持當(dāng)前事務(wù)，如果不存在則以非事務(wù)方式執(zhí)行。 類似于同名的 EJB 事務(wù)屬性。
	 * 注意：對(duì)于具有事務(wù)同步的事務(wù)管理器， SUPPORTS與根本沒有事務(wù)略有不同，因?yàn)樗x了同步將應(yīng)用的事務(wù)范圍。
     * 因此，相同的資源（JDBC 連接、Hibernate 會(huì)話等）將在整個(gè)指定范圍內(nèi)共享。 請(qǐng)注意，這取決于事務(wù)管理器的實(shí)際同步配置
	 */
	SUPPORTS(TransactionDefinition.PROPAGATION_SUPPORTS),

	/**
	 * 支持當(dāng)前事務(wù)，如果不存在則拋出異常。 類似于同名的 EJB 事務(wù)屬性。
	 */
	MANDATORY(TransactionDefinition.PROPAGATION_MANDATORY),

	
	/**
	 * 創(chuàng)建一個(gè)新事務(wù)，如果存在，則暫停當(dāng)前事務(wù)。 類似于同名的 EJB 事務(wù)屬性。
	 * 注意：實(shí)際的事務(wù)暫停不會(huì)在所有事務(wù)管理器上開箱即用。 
	 * 這尤其適用于org.springframework.transaction.jta.JtaTransactionManager 
	 * 它需要javax.transaction.TransactionManager對(duì)其可用（這在標(biāo)準(zhǔn) Java EE 中是特定于服務(wù)器的）
	 */
	REQUIRES_NEW(TransactionDefinition.PROPAGATION_REQUIRES_NEW),

	/**
	 * 以非事務(wù)方式執(zhí)行，如果存在則暫停當(dāng)前事務(wù)。 類似于同名的 EJB 事務(wù)屬性。
	 * 注意：實(shí)際的事務(wù)暫停不會(huì)在所有事務(wù)管理器上開箱即用。 這尤其適用于org.springframework.transaction.jta.JtaTransactionManager 
	 * 它需要javax.transaction.TransactionManager對(duì)其可用（這在標(biāo)準(zhǔn) Java EE 中是特定于服務(wù)器的）。
	 */
	NOT_SUPPORTED(TransactionDefinition.PROPAGATION_NOT_SUPPORTED),

	/**
	 * 以非事務(wù)方式執(zhí)行，如果存在事務(wù)則拋出異常。 類似于同名的 EJB 事務(wù)屬性。
	 */
	NEVER(TransactionDefinition.PROPAGATION_NEVER),

	/**
	 * 如果當(dāng)前事務(wù)存在，則在嵌套事務(wù)中執(zhí)行，否則行為類似于REQUIRED 。 EJB 中沒有類似的特性。
	 * 注意：嵌套事務(wù)的實(shí)際創(chuàng)建僅適用于特定的事務(wù)管理器。 開箱即用，
	 * 這僅適用于 JDBC DataSourceTransactionManager。 一些 JTA 提供者也可能支持嵌套事務(wù)。
	 * @see org.springframework.jdbc.datasource.DataSourceTransactionManager
	 */
	NESTED(TransactionDefinition.PROPAGATION_NESTED);


	private final int value;


	Propagation(int value) {
		this.value = value;
	}

	public int value() {
		return this.value;
	}

}

@Service
public class StudentServiceImpl implements IStudentService {

    ...
        
    @Transactional
    @Override
    public Student insertStudent(Student student) {
        return studentRepository.save(student);
    }

    ...
}

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Transactional {
    // 通過bean name執(zhí)行事務(wù)管理器
    @AliasFor("transactionManager")
    String value() default "";
	// 同value屬性
    @AliasFor("value")
    String transactionManager() default "";
	// 指定事務(wù)傳播行為，默認(rèn)是Propagation.REQUIRED
    Propagation propagation() default Propagation.REQUIRED;
	// 指定事務(wù)的隔離級(jí)別，默認(rèn)是使用底層數(shù)據(jù)存儲(chǔ)的默認(rèn)隔離級(jí)別。如MySQL是可重復(fù)讀
    Isolation isolation() default Isolation.DEFAULT;
	// 指定超時(shí)時(shí)間，單位時(shí)間秒
    int timeout() default -1;
	// 是否是只讀事務(wù)
    boolean readOnly() default false;
	// 在發(fā)生指定的異常是回滾事務(wù)，默認(rèn)是所有異常都回滾
    Class<? extends Throwable>[] rollbackFor() default {};
	// 方法在發(fā)生指定異常名稱時(shí)回滾事務(wù)，默認(rèn)是所有異常都回滾
    String[] rollbackForClassName() default {};
	// 在發(fā)生指定的異常是不回滾事務(wù)
    Class<? extends Throwable>[] noRollbackFor() default {};
	// 方法在發(fā)生指定異常名稱時(shí)不回滾事務(wù)
    String[] noRollbackForClassName() default {};
}

public interface PlatformTransactionManager extends TransactionManager {
	// 獲取事務(wù)m還可以設(shè)置數(shù)據(jù)屬性
	TransactionStatus getTransaction(@Nullable TransactionDefinition definition)
			throws TransactionException;
	// 提交事務(wù)
	void commit(TransactionStatus status) throws TransactionException;
	// 回滾事務(wù)
	void rollback(TransactionStatus status) throws TransactionException;

}

@Service
public class StudentServiceImpl implements IStudentService {

    @Autowired
    private StudentRepository studentRepository;

    @Transactional(rollbackFor = RuntimeException.class, isolation = Isolation.REPEATABLE_READ, propagation = Propagation.REQUIRES_NEW)
    @Override
    public Student insertStudent(Student student) {
        return studentRepository.save(student);
    }

}

@Service
public class BatchServiceImpl implements IBatchService {

    @Autowired
    private IStudentService studentService;

    @Transactional(rollbackFor = RuntimeException.class, isolation = Isolation.REPEATABLE_READ, propagation = Propagation.REQUIRED)
    @Override
    public void batchInsertStudent(List<Student> students) {
        for (Student student : students) {
            studentService.insertStudent(student);
        }
    }
}

@Service
public class StudentServiceImpl implements IStudentService {

    @Autowired
    private StudentRepository studentRepository;

    @Transactional(rollbackFor = RuntimeException.class, propagation = Propagation.REQUIRES_NEW)
    @Override
    public Student findStudentById(Long id) {
        return studentRepository.getOne(id);
    }

    @Transactional(rollbackFor = RuntimeException.class, isolation = Isolation.REPEATABLE_READ)
    @Override
    public void deleteStudent(Long id) {
        // 自調(diào)用
        Student db = findStudentById(id);
        if (db == null) {
            throw new RuntimeException("數(shù)據(jù)不存在");
        }
        studentRepository.deleteById(id);
    }

}

@Service
public class StudentServiceImpl implements IStudentService {

    @Autowired
    private StudentRepository studentRepository;
    
    // 注入Spring上下文對(duì)象
    @Autowired
    private ApplicationContext context;

    @Transactional(rollbackFor = RuntimeException.class, propagation = Propagation.REQUIRES_NEW)
    @Override
    public Student findStudentById(Long id) {
        return studentRepository.getOne(id);
    }

    @Transactional(rollbackFor = RuntimeException.class, isolation = Isolation.REPEATABLE_READ)
    @Override
    public void deleteStudent(Long id) {
        // 從上下文中獲取IStudentService
        IStudentService studentService = context.getBean(IStudentService.class);
        Student db = findStudentById(id);
        if (db == null) {
            throw new RuntimeException("數(shù)據(jù)不存在");
        }
        studentRepository.deleteById(id);
    }

}