Spring事务管理

Spring事务管理 一、编程式事务（AOP实现）

        1、创建环绕型通知管理事务

import org.aspectj.lang.ProceedingJoinPoint;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

import javax.sql.DataSource;

public class TxAdvice {

    private DataSource dataSource;
    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    public Object transactionManager(ProceedingJoinPoint pjp) throws Throwable {
        //开启事务
        PlatformTransactionManager ptm = new DataSourceTransactionManager(dataSource);
        //事务定义
        TransactionDefinition td = new DefaultTransactionDefinition();
        //事务状态
        TransactionStatus ts = ptm.getTransaction(td);

        Object ret = pjp.proceed(pjp.getArgs());

        //提交事务
        ptm.commit(ts);

        return ret;
    }

}

2、编写spring配置文件，写明AOP的触发时机以及注入数据源

二、声明式事务（XML）

事务传播行为：事务传播行为主要是针对事务协调员对事务的处理方式的。A,B两个方法。A中调用了B。称A为事务管理员，B为事务协调员。

REQUIRED(Spring 默认的事务传播类型 ) ：如果当前没有事务，则自己新建一个事务，如果当前存在事 务，则加入这个事务 REQUIRES_NEW ：不论A是否有事务，B都会创建新的事务 SUPPORTS ：当前存在事务，则加入当前事务，如果当前没有事务，就以非事务方法执行 NOT_SUPPORTED ：不论A是否有事务，B都不以事务处理 MANDATORY ：当前存在事务，则加入当前事务，如果当前事务不存在，则抛出异常。 NEVER ：不使用事务，如果当前事务存在，则抛出异常  三、声明式事务（注解）

       1、在spring配置文件中打开事务注解驱动

2、在需要添加事务的类或者方法上添加@Transactional注解开启事务，通常配置在接口上以防止实现类改变导致的代码重写

//对当前接口的所有方法添加事务
@Transactional(
        readonly = false,
        isolation = Isolation.DEFAULT,
        timeout = -1,
        rollbackFor = {},
        noRollbackFor = {},
        propagation = Propagation.REQUIRED
)
public interface AccountService {

    
    //对当前方法添加事务，该配置将替换接口的配置
    @Transactional(
        readonly = false,
        timeout = -1,
        isolation = Isolation.DEFAULT,
        rollbackFor = {},   //java.lang.ArithmeticException.class, IOException.class
        noRollbackFor = {},
        propagation = Propagation.REQUIRED
        )
    public void transfer(String outName, String inName, Double money);

}